rainbond: github.com/goodrain/rainbond/eventlog/cluster/connect Index | Files

package connect

import "github.com/goodrain/rainbond/eventlog/cluster/connect"

Index

Package Files

pub.go sub.go

type Pub Uses

type Pub struct {
    Closed chan struct{}

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

func NewPub Uses

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

NewPub 创建zmq pub服务端

func (*Pub) Run Uses

func (s *Pub) Run() error

Run 执行

func (*Pub) Stop Uses

func (s *Pub) Stop()

Stop 停止

type Sub Uses

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

func NewSub Uses

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

NewSub 创建zmq sub客户端

func (*Sub) Run Uses

func (s *Sub) Run() error

Run 执行

func (*Sub) Stop Uses

func (s *Sub) Stop()

Stop 停止

type SubClient Uses

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

Package connect imports 14 packages (graph) and is imported by 1 packages. Updated 2019-03-16. Refresh now. Tools for package owners.