watchers

Documentation

Index

• Variables
• type WatchersHub
  • func New(doneUpto uint64, maxWaiting int) *WatchersHub
  • func (w *WatchersHub) Close() error
  • func (w *WatchersHub) DoneUpto(t uint64) error
  • func (w *WatchersHub) Status() (doneUpto uint64, waiting int, err error)
  • func (w *WatchersHub) WaitFor(t uint64, cancellation <-chan struct{}) error

Variables

var ErrAlreadyClosed = errors.New("watchers: already closed")

var ErrCancellationRequested = errors.New("watchers: cancellation requested")

var ErrMaxWaitessLimitExceeded = errors.New("watchers: max waiting limit exceeded")

Types

type WatchersHub

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

func New

func New(doneUpto uint64, maxWaiting int) *WatchersHub

func (*WatchersHub) Close

func (w *WatchersHub) Close() error

func (*WatchersHub) DoneUpto

func (w *WatchersHub) DoneUpto(t uint64) error

func (*WatchersHub) Status

func (w *WatchersHub) Status() (doneUpto uint64, waiting int, err error)

func (*WatchersHub) WaitFor

func (w *WatchersHub) WaitFor(t uint64, cancellation <-chan struct{}) error