cherryCluster

package

v1.2.7 Latest Latest Go to latest Published: Dec 2, 2022 License: MIT Imports: 16 Imported by: 7

Details

View Source

const (
	Name = "cluster_component"
)

This section is empty.

This section is empty.

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

func NewComponent() *Component

func (c *Component) Init()

func (c *Component) Name() string

func (c *Component) OnStop()

type NatsRPCClient struct {
	cfacade.IApplication
}

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 struct {
	cfacade.IApplication
	// contains filtered or unexported fields
}

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

func (n *NatsRPCServer) Init()

func (n *NatsRPCServer) OnStop()

Path	Synopsis
discovery
nats