cherryNatsCluster

package

v1.4.21 Latest Latest Go to latest Published: Apr 17, 2026 License: MIT Imports: 11 Imported by: 1

Details

This section is empty.

This section is empty.

func GetLocalSubject(prefix, nodeType, nodeID string) string

GetLocalSubject local message nats chan

func GetRemoteSubject(prefix, nodeType, nodeID string) string

GetRemoteSubject remote message nats chan

func GetRemoteTypeSubject(prefix, nodeType string) string

func GetReplySubject(prefix, nodeType, nodeID string) string

func New(app cfacade.IApplication) cfacade.ICluster

type Cluster struct {
	// contains filtered or unexported fields
}

func (p *Cluster) Init()

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

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

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

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

func (p *Cluster) Stop()