Documentation ¶
Index ¶
- type Master
- type MasterHttpServer
- type MasterServer
- func (s *MasterServer) MemberHeart(ss session.Session, input *deal.Ping) error
- func (s *MasterServer) MemberInfo(ss session.Session, input *deal.MemberInfoNotice) error
- func (s *MasterServer) MemberStart(ss session.Session, input *deal.MemberStartRequest) error
- func (s *MasterServer) MemberStop(ss session.Session, input *deal.MemberStopNotice) error
- func (s *MasterServer) ServerHeart(ss session.Session, input *deal.Ping) error
- func (s *MasterServer) ServerStart(ss session.Session, input *deal.ServerStartRequest) error
- func (s *MasterServer) ServerStop(ss session.Session, input *deal.ServerStopNotice) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MasterHttpServer ¶
type MasterHttpServer struct{}
func (*MasterHttpServer) MemberNode ¶
func (s *MasterHttpServer) MemberNode(ss session.Session, input *deal.MemberNodeRequest) error
获取所有的node
func (*MasterHttpServer) ServerNode ¶
func (s *MasterHttpServer) ServerNode(ss session.Session, input *deal.ServerNodeRequest) error
获取所有的node
type MasterServer ¶
type MasterServer struct { Mux sync.Mutex MemberSessions []session.Session ServerSessions []session.Session MemberMchID uint64 }
主节点的服务对象
func (*MasterServer) MemberHeart ¶
member ping
func (*MasterServer) MemberInfo ¶
func (s *MasterServer) MemberInfo(ss session.Session, input *deal.MemberInfoNotice) error
member session
func (*MasterServer) MemberStart ¶
func (s *MasterServer) MemberStart(ss session.Session, input *deal.MemberStartRequest) error
member start
func (*MasterServer) MemberStop ¶
func (s *MasterServer) MemberStop(ss session.Session, input *deal.MemberStopNotice) error
member stop
func (*MasterServer) ServerHeart ¶
member ping
func (*MasterServer) ServerStart ¶
func (s *MasterServer) ServerStart(ss session.Session, input *deal.ServerStartRequest) error
server start
func (*MasterServer) ServerStop ¶
func (s *MasterServer) ServerStop(ss session.Session, input *deal.ServerStopNotice) error
member stop
Click to show internal directories.
Click to hide internal directories.