process

Documentation

Index

• type ProcessContext
  • func NewProcessContext() *ProcessContext
  • func (b *ProcessContext) ComponentFinished()
  • func (b *ProcessContext) ComponentStarted()
  • func (b *ProcessContext) Context() context.Context
  • func (b *ProcessContext) Degraded(err error)
  • func (b *ProcessContext) IsDegraded() (bool, []string)
  • func (b *ProcessContext) ShutdownDendrite()
  • func (b *ProcessContext) WaitForComponentsToFinish()
  • func (b *ProcessContext) WaitForShutdown() <-chan struct{}

Types

type ProcessContext

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

func NewProcessContext

func NewProcessContext() *ProcessContext

func (*ProcessContext) ComponentFinished

func (b *ProcessContext) ComponentFinished()

func (*ProcessContext) ComponentStarted

func (b *ProcessContext) ComponentStarted()

func (*ProcessContext) Context

func (b *ProcessContext) Context() context.Context

func (*ProcessContext) Degraded

func (b *ProcessContext) Degraded(err error)

func (*ProcessContext) IsDegraded

func (b *ProcessContext) IsDegraded() (bool, []string)

func (*ProcessContext) ShutdownDendrite

func (b *ProcessContext) ShutdownDendrite()

func (*ProcessContext) WaitForComponentsToFinish

func (b *ProcessContext) WaitForComponentsToFinish()

func (*ProcessContext) WaitForShutdown

func (b *ProcessContext) WaitForShutdown() <-chan struct{}