package ops import ( "github.com/mhaya/game/game_cluster/internal/code" "github.com/mhaya/game/game_cluster/internal/pb" cactor "github.com/mhaya/net/actor" ) var ( pingReturn = &pb.Bool{Value: true} ) type ( ActorOps struct { cactor.Base } ) func (p *ActorOps) AliasID() string { return "ops" } // OnInit 注册remote函数 func (p *ActorOps) OnInit() { p.Remote().Register("ping", p.ping) } // ping 请求logstash是否响应 func (p *ActorOps) ping() (*pb.Bool, int32) { return pingReturn, code.OK }