Documentation ¶ Index ¶ Variables func New() (broadcast.Broadcast, error) type Broker func (b *Broker) Send(namespace *config.ConfigResponse) error func (b *Broker) Watch() broadcast.Watcher type Watcher func (w *Watcher) Next() (*config.ConfigResponse, error) func (w *Watcher) Stop() error Constants ¶ This section is empty. Variables ¶ View Source var ErrWatcherStopped = errors.New("watcher stopped") Functions ¶ func New ¶ func New() (broadcast.Broadcast, error) Types ¶ type Broker ¶ type Broker struct { sync.RWMutex // contains filtered or unexported fields } func (*Broker) Send ¶ func (b *Broker) Send(namespace *config.ConfigResponse) error func (*Broker) Watch ¶ func (b *Broker) Watch() broadcast.Watcher type Watcher ¶ type Watcher struct { // contains filtered or unexported fields } func (*Watcher) Next ¶ func (w *Watcher) Next() (*config.ConfigResponse, error) func (*Watcher) Stop ¶ func (w *Watcher) Stop() error Source Files ¶ View all Source files database.go watcher.go Click to show internal directories. Click to hide internal directories.