Documentation
¶
Index ¶
- func GetCloseSessionSubject() string
- func GetKickSubject(nodeType string, nodeId string) string
- func GetLocalSubject(nodeType string, nodeId string) string
- func GetPushSubject(nodeType string, nodeId string) string
- func GetRemoteSubject(nodeType string, nodeId string) string
- type Component
- func (c *Component) Client() facade.RPCClient
- func (c *Component) ForwardLocal(session *cherrySession.Session, msg *cherryMessage.Message)
- func (c *Component) ForwardRemote(route string, val interface{}, timeout time.Duration) *cherryProto.Response
- func (c *Component) Init()
- func (c *Component) Name() string
- func (c *Component) OnStop()
- func (c *Component) RPCAsyncToNode(nodeId string, route string, arg proto.Message)
- func (c *Component) RPCToNode(nodeId string, route string, reply proto.Message, arg proto.Message, ...) error
- func (c *Component) SendKickUser(nodeId string, message *cherryProto.KickMessage)
- func (c *Component) SendPushToUser(nodeId string, message *cherryProto.PushMessage)
- func (c *Component) Server() facade.RPCServer
- type NatsRPCClient
- func (n *NatsRPCClient) CallAsyncRemote(nodeId string, message *cherryProto.RemoteMessage)
- func (n *NatsRPCClient) CallLocal(nodeId string, message *cherryProto.LocalMessage) error
- func (n *NatsRPCClient) CallRemote(nodeId string, message *cherryProto.RemoteMessage, timeout time.Duration) *cherryProto.Response
- func (n *NatsRPCClient) Init(app cherryFacade.IApplication)
- func (n *NatsRPCClient) OnStop()
- func (n *NatsRPCClient) Send(route string, data []byte) error
- func (n *NatsRPCClient) SendKick(fid cherryFacade.FrontendId, message *cherryProto.KickMessage) error
- func (n *NatsRPCClient) SendPush(fid cherryFacade.FrontendId, message *cherryProto.PushMessage) error
- type NatsRPCServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCloseSessionSubject ¶ added in v1.1.17
func GetCloseSessionSubject() string
GetCloseSessionSubject 关闭Session主题 publish-subscribe (每个集群节点订阅)
cherry.close_session
func GetKickSubject ¶ added in v1.1.17
GetKickSubject 踢用户下线主题 publish-subscribe (仅前端节点订阅)
cherry.kick.{node_type}.{node_id}
func GetLocalSubject ¶ added in v1.1.17
GetLocalSubject 本地消息主题 publish-subscribe (每个集群节点订阅)
cherry.local.{node_type}.{node_id}
func GetPushSubject ¶ added in v1.1.17
GetPushSubject 推送给客户端主题 publish-subscribe (仅前端节点订阅)
cherry.push.{node_type}.{node_id}
func GetRemoteSubject ¶ added in v1.1.17
GetRemoteSubject 远程消息主题 request-reply (每个集群节点订阅)
cherry.remote.{node_type}.{node_id}
Types ¶
type Component ¶ added in v1.1.1
func NewComponent ¶ added in v1.1.5
func NewComponent(handlerComponent *cherryHandler.Component) *Component
func (*Component) ForwardLocal ¶ added in v1.1.17
func (c *Component) ForwardLocal(session *cherrySession.Session, msg *cherryMessage.Message)
func (*Component) ForwardRemote ¶ added in v1.1.17
func (*Component) RPCAsyncToNode ¶ added in v1.1.17
func (*Component) SendKickUser ¶ added in v1.1.9
func (c *Component) SendKickUser(nodeId string, message *cherryProto.KickMessage)
func (*Component) SendPushToUser ¶ added in v1.1.9
func (c *Component) SendPushToUser(nodeId string, message *cherryProto.PushMessage)
type NatsRPCClient ¶ added in v1.1.17
type NatsRPCClient struct { cherryFacade.IApplication // contains filtered or unexported fields }
func NewNatsRPCClient ¶ added in v1.1.17
func NewNatsRPCClient(conn *nats.Conn, natsConfig *cherryProfile.NatsConfig) *NatsRPCClient
func (*NatsRPCClient) CallAsyncRemote ¶ added in v1.1.17
func (n *NatsRPCClient) CallAsyncRemote(nodeId string, message *cherryProto.RemoteMessage)
func (*NatsRPCClient) CallLocal ¶ added in v1.1.17
func (n *NatsRPCClient) CallLocal(nodeId string, message *cherryProto.LocalMessage) error
func (*NatsRPCClient) CallRemote ¶ added in v1.1.17
func (n *NatsRPCClient) CallRemote(nodeId string, message *cherryProto.RemoteMessage, timeout time.Duration) *cherryProto.Response
func (*NatsRPCClient) Init ¶ added in v1.1.17
func (n *NatsRPCClient) Init(app cherryFacade.IApplication)
func (*NatsRPCClient) OnStop ¶ added in v1.1.17
func (n *NatsRPCClient) OnStop()
func (*NatsRPCClient) Send ¶ added in v1.1.17
func (n *NatsRPCClient) Send(route string, data []byte) error
func (*NatsRPCClient) SendKick ¶ added in v1.1.17
func (n *NatsRPCClient) SendKick(fid cherryFacade.FrontendId, message *cherryProto.KickMessage) error
func (*NatsRPCClient) SendPush ¶ added in v1.1.17
func (n *NatsRPCClient) SendPush(fid cherryFacade.FrontendId, message *cherryProto.PushMessage) error
type NatsRPCServer ¶ added in v1.1.17
type NatsRPCServer struct { cherryFacade.IApplication // contains filtered or unexported fields }
func NewRpcServer ¶ added in v1.1.17
func NewRpcServer(handler *cherryHandler.Component, conn *nats.Conn, rpcClient cherryFacade.RPCClient) *NatsRPCServer
func (*NatsRPCServer) Init ¶ added in v1.1.17
func (n *NatsRPCServer) Init(app cherryFacade.IApplication)
func (*NatsRPCServer) OnStop ¶ added in v1.1.17
func (n *NatsRPCServer) OnStop()
Click to show internal directories.
Click to hide internal directories.