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) 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 New ¶
func New() *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) 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)
Source Files
Click to show internal directories.
Click to hide internal directories.