connect

package
v3.6.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 11, 2018 License: LGPL-3.0 Imports: 14 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL