master

type CmdHandlerFunc func(cmd, nodeId string, date []byte)

type IMaster interface {
	Run() error
	AddHandler(cmd string, handler CmdHandlerFunc)
	SendCMD(cmd, nodeId string, data []byte) (result []byte, err error)
	SendCMDJson(cmd, nodeId string, obj interface{}) (result []byte, err error)
	SendCMDProto(cmd, nodeId string, obj interface{}) (result []byte, err error)
	TimeOutServerListListener(tHandler TimeOutHandlerFunc)
	GetRunTimeMemStats(nodeId string) (*runtime.MemStats, error)
	Done()
	GetNodeInfos() map[string]*NodeInfo
	AddExceptionHandler(handler gnError.ExceptionHandleFunc)
}

type Master struct {
	// contains filtered or unexported fields
}

type NodeInfo struct {
	NodeId     string
	LastTime   int64
	CurrenTime int64
	DiffTime   time.Duration
	RoutineNum int64
	Host       string
	Port       int
}

type TimeOutHandlerFunc func(list []NodeInfo)