Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var EventChanBufferLength = 10
EventChanBufferLength is the number of unhandled events which can be queued to the event channel buffer before further events are lost.
Functions ¶
This section is empty.
Types ¶
type Bus ¶
type Bus struct {
// contains filtered or unexported fields
}
Bus provides an ari.Bus interface to NATS
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
Subscription represents an ari.Subscription over NATS
func (*Subscription) Events ¶
func (s *Subscription) Events() <-chan ari.Event
Events returns the channel on which events from this subscription will be sent
Source Files
Click to show internal directories.
Click to hide internal directories.