lifecycle

Documentation

Index

• func AllDone(components ...module.ReadyDoneAware) <-chan struct{}
• func AllReady(components ...module.ReadyDoneAware) <-chan struct{}
• type LifecycleManager
  • func NewLifecycleManager() *LifecycleManager
  • func (lm *LifecycleManager) OnStart(startupFns ...func())
  • func (lm *LifecycleManager) OnStop(shutdownFns ...func())
  • func (lm *LifecycleManager) ShutdownSignal() <-chan struct{}
  • func (lm *LifecycleManager) Started() <-chan struct{}
  • func (lm *LifecycleManager) Stopped() <-chan struct{}

Functions

func AllDone

func AllDone(components ...module.ReadyDoneAware) <-chan struct{}

AllDone calls Done on all input components and returns a channel that is closed when all input components are done.

func AllReady

func AllReady(components ...module.ReadyDoneAware) <-chan struct{}

AllReady calls Ready on all input components and returns a channel that is closed when all input components are ready.

Types

type LifecycleManager

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

LifecycleManager is a support struct for implementing module.ReadyDoneAware

func NewLifecycleManager

func NewLifecycleManager() *LifecycleManager

func (*LifecycleManager) OnStart

func (lm *LifecycleManager) OnStart(startupFns ...func())

OnStart will commence startup of the LifecycleManager. If OnStop has already been called before the first call to OnStart, startup will not be performed. After the first call, subsequent calls to OnStart do nothing.

func (*LifecycleManager) OnStop

func (lm *LifecycleManager) OnStop(shutdownFns ...func())

OnStop will commence shutdown of the LifecycleManager. If the LifecycleManager is still starting up, we will wait for startup to complete before shutting down. After the first call, subsequent calls to OnStop do nothing.

func (*LifecycleManager) ShutdownSignal

func (lm *LifecycleManager) ShutdownSignal() <-chan struct{}

ShutdownSignal returns a channel that is closed when shutdown has commenced.

func (*LifecycleManager) Started

func (lm *LifecycleManager) Started() <-chan struct{}

Started returns a channel that is closed when startup has completed. If the LifecycleManager is stopped before OnStart() is ever called, the returned channel will never be closed.

func (*LifecycleManager) Stopped

func (lm *LifecycleManager) Stopped() <-chan struct{}

Stopped returns a channel that is closed when shutdown has completed