cherryCluster

Documentation

Index

• Constants
• type Component
  • func NewComponent() *Component
  • func (c *Component) Init()
  • func (c *Component) Name() string
  • func (c *Component) OnStop()
• type NatsRPCClient
  • func NewRPCClient(app cfacade.IApplication) *NatsRPCClient
  • func (n *NatsRPCClient) OnStop()
  • func (n *NatsRPCClient) Publish(subject string, data []byte) error
  • func (n *NatsRPCClient) PublishKick(nodeId string, kick *cproto.Kick) error
  • func (n *NatsRPCClient) PublishLocal(nodeId string, request *cproto.Request) error
  • func (n *NatsRPCClient) PublishPush(frontendId cfacade.FrontendId, push *cproto.Push) error
  • func (n *NatsRPCClient) PublishRemote(nodeId string, request *cproto.Request) error
  • func (n *NatsRPCClient) RequestRemote(nodeId string, request *cproto.Request, timeout ...time.Duration) (*cproto.Response, error)
• type NatsRPCServer
  • func NewNatsRPCServer(app cfacade.IApplication, rpcClient cfacade.RPCClient, bufferSize int) *NatsRPCServer
  • func (n *NatsRPCServer) Init()
  • func (n *NatsRPCServer) OnStop()

Constants

const (
	Name = "cluster_component"
)

Types

type Component

type Component struct {
	cfacade.Component
	cfacade.RPCClient
	cfacade.RPCServer
}

func NewComponent

func NewComponent() *Component

func (*Component) Init

func (c *Component) Init()

func (*Component) Name

func (c *Component) Name() string

func (*Component) OnStop

func (c *Component) OnStop()

type NatsRPCClient

type NatsRPCClient struct {
	cfacade.IApplication
}

func NewRPCClient

func NewRPCClient(app cfacade.IApplication) *NatsRPCClient

func (*NatsRPCClient) OnStop

func (n *NatsRPCClient) OnStop()

func (*NatsRPCClient) Publish

func (n *NatsRPCClient) Publish(subject string, data []byte) error

func (*NatsRPCClient) PublishKick

func (n *NatsRPCClient) PublishKick(nodeId string, kick *cproto.Kick) error

func (*NatsRPCClient) PublishLocal

func (n *NatsRPCClient) PublishLocal(nodeId string, request *cproto.Request) error

func (*NatsRPCClient) PublishPush

func (n *NatsRPCClient) PublishPush(frontendId cfacade.FrontendId, push *cproto.Push) error

func (*NatsRPCClient) PublishRemote

func (n *NatsRPCClient) PublishRemote(nodeId string, request *cproto.Request) error

func (*NatsRPCClient) RequestRemote

func (n *NatsRPCClient) RequestRemote(nodeId string, request *cproto.Request, timeout ...time.Duration) (*cproto.Response, error)

type NatsRPCServer

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

func NewNatsRPCServer

func NewNatsRPCServer(app cfacade.IApplication, rpcClient cfacade.RPCClient, bufferSize int) *NatsRPCServer

func (*NatsRPCServer) Init

func (n *NatsRPCServer) Init()

func (*NatsRPCServer) OnStop

func (n *NatsRPCServer) OnStop()