cherryNatsCluster

Documentation

Index

• func New(app cfacade.IApplication, options ...OptionFunc) cfacade.ICluster
• type Cluster
  • 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 WithBufferSize(size int) OptionFunc

Functions

func New

func New(app cfacade.IApplication, options ...OptionFunc) cfacade.ICluster

Types

type Cluster

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

func (*Cluster) Init

func (p *Cluster) Init()

func (*Cluster) Publish

func (p *Cluster) Publish(subject string, data []byte) error

func (*Cluster) PublishLocal

func (p *Cluster) PublishLocal(nodeId string, request *cproto.ClusterPacket) error

func (*Cluster) PublishRemote

func (p *Cluster) PublishRemote(nodeId string, request *cproto.ClusterPacket) error

func (*Cluster) RequestRemote

func (p *Cluster) RequestRemote(nodeId string, request *cproto.ClusterPacket, timeout ...time.Duration) cproto.Response

func (*Cluster) Stop

func (p *Cluster) Stop()

type OptionFunc

type OptionFunc func(o *Cluster)

func WithBufferSize

func WithBufferSize(size int) OptionFunc