cherryCluster

Documentation

Index

• Constants
• func GetLocalNodeSubject(nodeType string, nodeId string) string
• func GetRemoteNodeSubject(nodeType string, nodeId string) string
• type Component
  • func NewComponent() *Component
  • func (c *Component) Client() facade.RPCClient
  • func (c *Component) ForwardLocal(session *cherrySession.Session, msg *cherryMessage.Message)
  • func (c *Component) Init()
  • func (c *Component) Name() string
  • func (c *Component) OnStop()
  • func (c *Component) Server() facade.RPCServer
• type NatsRPCClient
  • func NewRPCClient() *NatsRPCClient
  • func (n *NatsRPCClient) CallLocal(nodeId string, packet *cherryProto.LocalPacket) error
  • func (n *NatsRPCClient) CallRemote(nodeId string, route string, val interface{}, timeout time.Duration, ...)
  • func (n *NatsRPCClient) CallRemoteAsync(nodeId string, route string, val interface{})
  • func (n *NatsRPCClient) Init(app cherryFacade.IApplication)
  • func (n *NatsRPCClient) OnStop()
  • func (n *NatsRPCClient) Publish(subject string, val interface{}) error
  • func (n *NatsRPCClient) SendKick(nodeId string, uid cherryFacade.UID, reason interface{})
  • func (n *NatsRPCClient) SendPush(nodeId string, route string, uid cherryFacade.UID, val interface{})
• type NatsRPCServer
  • func NewRPCServer(rpcClient cherryFacade.RPCClient) *NatsRPCServer
  • func (n *NatsRPCServer) Init(app cherryFacade.IApplication)
  • func (n *NatsRPCServer) OnStop()

Constants

const (
	PushRoute = "sys.sessionHandler.push"
	KickRoute = "sys.sessionHandler.kick"
)

Functions

func GetLocalNodeSubject

func GetLocalNodeSubject(nodeType string, nodeId string) string

GetLocalNodeSubject local packet nats chan

func GetRemoteNodeSubject

func GetRemoteNodeSubject(nodeType string, nodeId string) string

GetRemoteNodeSubject remote packet nats chan

Types

type Component

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

func NewComponent

func NewComponent() *Component

func (*Component) Client

func (c *Component) Client() facade.RPCClient

func (*Component) ForwardLocal

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

ForwardLocal forward message to backend node

func (*Component) Init

func (c *Component) Init()

func (*Component) Name

func (c *Component) Name() string

func (*Component) OnStop

func (c *Component) OnStop()

func (*Component) Server

func (c *Component) Server() facade.RPCServer

type NatsRPCClient

type NatsRPCClient struct {
	cherryFacade.IApplication
}

func NewRPCClient

func NewRPCClient() *NatsRPCClient

func (*NatsRPCClient) CallLocal

func (n *NatsRPCClient) CallLocal(nodeId string, packet *cherryProto.LocalPacket) error

func (*NatsRPCClient) CallRemote

func (n *NatsRPCClient) CallRemote(nodeId string, route string, val interface{}, timeout time.Duration, rsp *cherryProto.Response)

func (*NatsRPCClient) CallRemoteAsync

func (n *NatsRPCClient) CallRemoteAsync(nodeId string, route string, val interface{})

func (*NatsRPCClient) Init

func (n *NatsRPCClient) Init(app cherryFacade.IApplication)

func (*NatsRPCClient) OnStop

func (n *NatsRPCClient) OnStop()

func (*NatsRPCClient) Publish

func (n *NatsRPCClient) Publish(subject string, val interface{}) error

func (*NatsRPCClient) SendKick

func (n *NatsRPCClient) SendKick(nodeId string, uid cherryFacade.UID, reason interface{})

func (*NatsRPCClient) SendPush

func (n *NatsRPCClient) SendPush(nodeId string, route string, uid cherryFacade.UID, val interface{})

type NatsRPCServer

type NatsRPCServer struct {
	cherryFacade.IApplication
	// contains filtered or unexported fields
}

func NewRPCServer

func NewRPCServer(rpcClient cherryFacade.RPCClient) *NatsRPCServer

func (*NatsRPCServer) Init

func (n *NatsRPCServer) Init(app cherryFacade.IApplication)

func (*NatsRPCServer) OnStop

func (n *NatsRPCServer) OnStop()