updatenotifier

Documentation

Index

• type Notifier
  • func (n *Notifier) Notify()
  • func (n *Notifier) Subscribe(s func())
  • func (n *Notifier) Update(ctx context.Context, wg *sync.WaitGroup)

Types

type Notifier

type Notifier struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Notifier) Notify

func (n *Notifier) Notify()

Notify schedules a update to subscribers in the next cycle

func (*Notifier) Subscribe

func (n *Notifier) Subscribe(s func())

Subscribe adds a subscriber to the list of interested parties

func (*Notifier) Update

func (n *Notifier) Update(ctx context.Context, wg *sync.WaitGroup)

Update starts the process of notifying subscribers