Documentation ¶
Index ¶
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Click to show internal directories.
Click to hide internal directories.