Versions in this module Expand all Collapse all v1 v1.0.0 Sep 16, 2024 Changes in this version + func New(app cfacade.IApplication, options ...OptionFunc) cfacade.ICluster + type Cluster struct + func (p *Cluster) Init() + func (p *Cluster) Publish(subject string, data []byte) error + func (p *Cluster) PublishLocal(nodeId string, request *cproto.ClusterPacket) error + func (p *Cluster) PublishRemote(nodeId string, request *cproto.ClusterPacket) error + func (p *Cluster) RequestRemote(nodeId string, request *cproto.ClusterPacket, timeout ...time.Duration) cproto.Response + func (p *Cluster) Stop() + type OptionFunc func(o *Cluster) + func WithBufferSize(size int) OptionFunc
Go to main page