s_cherry_e/sr/internal/actor_remote/center_ops.go

package actorRemote

import (
	cherryApp "f1-game/internal/cherry_app"
	"f1-game/internal/code"
	nameActor "f1-game/internal/name/actor"
	nameRemote "f1-game/internal/name/remote"
	"f1-game/internal/pb"

	cfacade "github.com/cherry-game/cherry/facade"
)

type centerOps struct {
}

func newCenterOps() *centerOps {
	return &centerOps{}
}

// Ping center节点是否响应
func (p *centerOps) Ping() bool {
	rsp := &pb.Bool{}

	errCode := cherryApp.CallWait(p.target(), nameRemote.CenterOps_Ping, nil, rsp)
	if code.IsFail(errCode) {
		return false
	}

	return rsp.Value
}

func (p *centerOps) GetDBReport() (*pb.DBQueueReportList, int32) {
	rsp := &pb.DBQueueReportList{}

	errCode := cherryApp.CallWait(p.target(), nameRemote.Ops_DbReport, nil, rsp)
	if code.IsFail(errCode) {
		return nil, errCode
	}

	return rsp, code.OK
}

func (*centerOps) target() string {
	return cfacade.NewPath(centerNodeID(), nameActor.CenterOps)
}