s_cherry_e/sr/internal/component/check_center/component.go

package checkCenter

import (
	actorRemote "f1-game/internal/actor_remote"
	"time"

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

// component 启动时,检查center节点是否存活
type component struct {
	cfacade.Component
}

func New() *component {
	return &component{}
}

func (c *component) Name() string {
	return "run_check_component"
}

func (c *component) OnAfterInit() {
	for {
		if actorRemote.CenterOps.Ping() {
			break
		}
		time.Sleep(2 * time.Second)
		clog.Warn("center node connect fail. retrying in 2 seconds.")
	}
}