zmq

Documentation

Index

• type Subscriber
  • func NewSubscriber() *Subscriber
  • func (s *Subscriber) AddDestination(d delivery.Publisher) int
  • func (s *Subscriber) BatchSubscribe(channels []string)
  • func (s *Subscriber) Detach() error
  • func (s *Subscriber) Listen() <-chan interface{}
  • func (s *Subscriber) RemoveDestination(d delivery.Publisher) int
  • func (s *Subscriber) Sock() *goczmq.Channeler
  • func (s *Subscriber) Start() chan bool
  • func (s *Subscriber) Subscribe(channel string)

Types

type Subscriber

type Subscriber struct {
	sync.Mutex

	Close chan os.Signal
	Wait  chan bool
	Error chan error
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber() *Subscriber

func (*Subscriber) AddDestination

func (s *Subscriber) AddDestination(d delivery.Publisher) int

func (*Subscriber) BatchSubscribe

func (s *Subscriber) BatchSubscribe(channels []string)

func (*Subscriber) Detach

func (s *Subscriber) Detach() error

func (*Subscriber) Listen

func (s *Subscriber) Listen() <-chan interface{}

func (*Subscriber) RemoveDestination

func (s *Subscriber) RemoveDestination(d delivery.Publisher) int

func (*Subscriber) Sock

func (s *Subscriber) Sock() *goczmq.Channeler

func (*Subscriber) Start

func (s *Subscriber) Start() chan bool

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(channel string)