cherryCluster

package

v1.5.0 Latest Latest Go to latest Published: May 9, 2026 License: MIT Imports: 11 Imported by: 7

Details

View Source

const (
	Name = "cluster_component"
)

This section is empty.

This section is empty.

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

func New() *Component

func (p *Component) GetLocalSubject(prefix, nodeType, nodeID string) string

func (p *Component) GetRemoteSubject(prefix, nodeType, nodeID string) string

GetRemoteSubject remote message nats chan

func (p *Component) GetRemoteTypeSubject(prefix, nodeType string) string

func (p *Component) GetReplySubject(prefix, nodeType, nodeID string) string

func (p *Component) Init()

func (*Component) Mode() string

func (*Component) Name() string

func (p *Component) OnStop()

func (p *Component) PublishLocal(nodeID string, cpacket *cproto.ClusterPacket) error

func (p *Component) PublishRemote(nodeID string, cpacket *cproto.ClusterPacket) error

func (p *Component) PublishRemoteType(nodeType string, cpacket *cproto.ClusterPacket) error

func (p *Component) RequestRemote(nodeID string, cpacket *cproto.ClusterPacket, timeout ...time.Duration) ([]byte, int32)