connect

Documentation

Index

• type Pub
  • func NewPub(conf conf.PubSubConf, log *logrus.Entry, storeManager store.Manager, ...) *Pub
  • func (s *Pub) Run() error
  • func (s *Pub) Stop()
• type Sub
  • func NewSub(conf conf.PubSubConf, log *logrus.Entry, storeManager store.Manager, ...) *Sub
  • func (s *Sub) Run() error
  • func (s *Sub) Stop()
• type SubClient

Types

type Pub

type Pub struct {
	Closed chan struct{}

	RadioChan chan db.ClusterMessage
	// contains filtered or unexported fields
}

func NewPub

func NewPub(conf conf.PubSubConf, log *logrus.Entry, storeManager store.Manager, discover discover.Manager) *Pub

NewPub 创建zmq pub服务端

func (*Pub) Run

func (s *Pub) Run() error

Run 执行

func (*Pub) Stop

func (s *Pub) Stop()

Stop 停止

type Sub

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

func NewSub

func NewSub(conf conf.PubSubConf, log *logrus.Entry, storeManager store.Manager, discover dis.Manager, distribution *distribution.Distribution) *Sub

NewSub 创建zmq sub客户端

func (*Sub) Run

func (s *Sub) Run() error

Run 执行

func (*Sub) Stop

func (s *Sub) Stop()

Stop 停止

type SubClient

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