waiting

Documentation

Index

• Variables
• type MultiShutdownAwaiter
  • func NewMultiShutdownAwaiter(slots uint) *MultiShutdownAwaiter
  • func (msa *MultiShutdownAwaiter) AwaitDone()
  • func (msa *MultiShutdownAwaiter) AwaitShutdown(slot uint) error
  • func (msa *MultiShutdownAwaiter) AwaitShutdownChan(slot uint) <-chan bool
  • func (msa *MultiShutdownAwaiter) SignalDone()
  • func (msa *MultiShutdownAwaiter) SignalShutdown()
• type ShutdownAwaiter
  • func NewShutdownAwaiter() *ShutdownAwaiter
  • func (sa *ShutdownAwaiter) AwaitDone() error
  • func (sa *ShutdownAwaiter) AwaitShutdown() error
  • func (sa *ShutdownAwaiter) AwaitShutdownChan() <-chan bool
  • func (sa *ShutdownAwaiter) SignalDone()
  • func (sa *ShutdownAwaiter) SignalShutdown()
• type Waiter
  • func NewWaiter() *Waiter
  • func NewWaiterWithTimeout(timeout time.Duration) *Waiter
  • func (w *Waiter) Await() error
  • func (w *Waiter) Reset()
  • func (w *Waiter) Signal()

Variables

var ErrWaiterTimeout = fmt.Errorf("waiter timed out")

Types

type MultiShutdownAwaiter

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

func NewMultiShutdownAwaiter

func NewMultiShutdownAwaiter(
	slots uint,
) *MultiShutdownAwaiter

func (*MultiShutdownAwaiter) AwaitDone

func (msa *MultiShutdownAwaiter) AwaitDone()

func (*MultiShutdownAwaiter) AwaitShutdown

func (msa *MultiShutdownAwaiter) AwaitShutdown(
	slot uint,
) error

func (*MultiShutdownAwaiter) AwaitShutdownChan

func (msa *MultiShutdownAwaiter) AwaitShutdownChan(
	slot uint,
) <-chan bool

func (*MultiShutdownAwaiter) SignalDone

func (msa *MultiShutdownAwaiter) SignalDone()

func (*MultiShutdownAwaiter) SignalShutdown

func (msa *MultiShutdownAwaiter) SignalShutdown()

type ShutdownAwaiter

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

func NewShutdownAwaiter

func NewShutdownAwaiter() *ShutdownAwaiter

func (*ShutdownAwaiter) AwaitDone

func (sa *ShutdownAwaiter) AwaitDone() error

func (*ShutdownAwaiter) AwaitShutdown

func (sa *ShutdownAwaiter) AwaitShutdown() error

func (*ShutdownAwaiter) AwaitShutdownChan

func (sa *ShutdownAwaiter) AwaitShutdownChan() <-chan bool

func (*ShutdownAwaiter) SignalDone

func (sa *ShutdownAwaiter) SignalDone()

func (*ShutdownAwaiter) SignalShutdown

func (sa *ShutdownAwaiter) SignalShutdown()

type Waiter

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

func NewWaiter

func NewWaiter() *Waiter

func NewWaiterWithTimeout

func NewWaiterWithTimeout(
	timeout time.Duration,
) *Waiter

func (*Waiter) Await

func (w *Waiter) Await() error

func (*Waiter) Reset

func (w *Waiter) Reset()

func (*Waiter) Signal

func (w *Waiter) Signal()