package notify

import "go.etcd.io/etcd/pkg/v3/notify"

Index ¶

• type Notifier
• func NewNotifier() *Notifier
• func (n *Notifier) Notify()
• func (n *Notifier) Receive() <-chan struct{}

Types ¶

type Notifier ¶

type Notifier struct {
	// contains filtered or unexported fields
}

Notifier is a thread safe struct that can be used to send notification about some event to multiple consumers.

func NewNotifier ¶

func NewNotifier() *Notifier

NewNotifier returns new notifier

func (*Notifier) Notify ¶

func (n *Notifier) Notify()

Notify closes the channel passed to consumers and creates new channel to used for next notification.

func (*Notifier) Receive ¶

func (n *Notifier) Receive() <-chan struct{}

Receive returns channel that can be used to wait for notification. Consumers will be informed by closing the channel.

Source Files ¶

notify.go