cherryCluster

package

v1.6.6 Latest Latest Go to latest Published: Aug 31, 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, msg *cfacade.Message) error

func (p *Component) PublishRemote(nodeID string, msg *cfacade.Message) error

func (p *Component) PublishRemoteType(nodeType string, msg *cfacade.Message) error

func (p *Component) RawPublish(subject string, data []byte) error

RawPublish publishes data to a raw subject via the publish connect.

func (p *Component) RawRequest(subject string, data []byte, timeout ...time.Duration) ([]byte, error)

RawRequest sends a request to a raw subject via the publish connect.

func (p *Component) RequestRemote(nodeID string, msg *cfacade.Message, timeout ...time.Duration) ([]byte, int32)

func (p *Component) RequestReply(reqID, replySubject string, data []byte) error

RequestReply publishes a reqID-carrying message to a raw subject via the publish connect.

func (p *Component) RequestSync(subject string, data []byte, timeout ...time.Duration) ([]byte, error)