master

Documentation

Index

• type Master
  • func NewMaster() *Master
  • func (m *Master) Close()
  • func (m *Master) Run()
• type MasterHttpServer
  • func (s *MasterHttpServer) MemberNode(ss session.Session, input *deal.MemberNodeRequest) error
  • func (s *MasterHttpServer) ServerNode(ss session.Session, input *deal.ServerNodeRequest) error
• 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

Types

type Master

type Master struct{}

主节点处理

func NewMaster

func NewMaster() *Master

func (*Master) Close

func (m *Master) Close()

func (*Master) Run

func (m *Master) Run()

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

func (s *MasterServer) MemberHeart(ss session.Session, input *deal.Ping) error

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

func (s *MasterServer) ServerHeart(ss session.Session, input *deal.Ping) error

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