cherryCluster

Documentation

Index

• Variables
• type Component
  • func NewComponent() *Component
  • func (c *Component) ForwardLocalMessage(session *cherrySession.Session, msg *cherryMessage.Message)
  • func (c *Component) ForwardRemoteMessage(session *cherrySession.Session, route string, val interface{})
  • func (c *Component) GetClusterClient(nodeId string) (cherryProto.ClusterServiceClient, bool)
  • func (c *Component) GetGRPCServer() *grpc.Server
  • func (c *Component) Init()
  • func (c *Component) Name() string
  • func (c *Component) OnStop()
  • func (c *Component) SendCloseSession(session *cherrySession.Session)
  • func (c *Component) SendKickUser(nodeId string, message *cherryProto.KickMessage)
  • func (c *Component) SendLocalMessage(nodeId string, message *cherryProto.LocalMessage)
  • func (c *Component) SendPushToUser(nodeId string, message *cherryProto.PushMessage)
  • func (c *Component) SendRemoteMessage(nodeId string, message *cherryProto.RemoteMessage)
  • func (c *Component) SetClusterServer(clusterServer cherryProto.ClusterServiceServer)
  • func (c *Component) SetNodeRouter(nodeRouter *cherryRouter.NodeRouter)
• type IBindStorage

Variables

var (
	GrpcOptions = []grpc.DialOption{grpc.WithInsecure()}
)

Types

type Component

type Component struct {
	facade.Component
	// contains filtered or unexported fields
}

func NewComponent

func NewComponent() *Component

func (*Component) ForwardLocalMessage

func (c *Component) ForwardLocalMessage(session *cherrySession.Session, msg *cherryMessage.Message)

func (*Component) ForwardRemoteMessage

func (c *Component) ForwardRemoteMessage(session *cherrySession.Session, route string, val interface{})

func (*Component) GetClusterClient

func (c *Component) GetClusterClient(nodeId string) (cherryProto.ClusterServiceClient, bool)

func (*Component) GetGRPCServer

func (c *Component) GetGRPCServer() *grpc.Server

func (*Component) Init

func (c *Component) Init()

func (*Component) Name

func (c *Component) Name() string

func (*Component) OnStop

func (c *Component) OnStop()

func (*Component) SendCloseSession

func (c *Component) SendCloseSession(session *cherrySession.Session)

func (*Component) SendKickUser

func (c *Component) SendKickUser(nodeId string, message *cherryProto.KickMessage)

func (*Component) SendLocalMessage

func (c *Component) SendLocalMessage(nodeId string, message *cherryProto.LocalMessage)

func (*Component) SendPushToUser

func (c *Component) SendPushToUser(nodeId string, message *cherryProto.PushMessage)

func (*Component) SendRemoteMessage

func (c *Component) SendRemoteMessage(nodeId string, message *cherryProto.RemoteMessage)

func (*Component) SetClusterServer

func (c *Component) SetClusterServer(clusterServer cherryProto.ClusterServiceServer)

func (*Component) SetNodeRouter

func (c *Component) SetNodeRouter(nodeRouter *cherryRouter.NodeRouter)

type IBindStorage

type IBindStorage interface {
	GetFrontendID(uid cherryFacade.UID, nodeType string) (string, error)
	Binding(uid cherryFacade.UID) error
}

IBindStorage 绑定存储，用于存储UID对应的前端节点id