evacuation

Documentation

Index

• type EvacuationCleanup
  • func NewEvacuationCleanup(logger lager.Logger, cellID string, gracefulShutdownInterval time.Duration, ...) *EvacuationCleanup
  • func (e *EvacuationCleanup) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type Evacuator
  • func NewEvacuator(logger lager.Logger, clock clock.Clock, executorClient executor.Client, ...) *Evacuator
  • func (e *Evacuator) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Types

type EvacuationCleanup

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

func NewEvacuationCleanup

func NewEvacuationCleanup(
	logger lager.Logger,
	cellID string,
	gracefulShutdownInterval time.Duration,
	proxyReloadDuration time.Duration,
	bbsClient bbs.InternalClient,
	executorClient executor.Client,
	clock clock.Clock,
	metronClient loggingclient.IngressClient,
) *EvacuationCleanup

func (*EvacuationCleanup) Run

func (e *EvacuationCleanup) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type Evacuator

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

func NewEvacuator

func NewEvacuator(
	logger lager.Logger,
	clock clock.Clock,
	executorClient executor.Client,
	evacuationNotifier evacuation_context.EvacuationNotifier,
	cellID string,
	evacuationTimeout time.Duration,
	pollingInterval time.Duration,
) *Evacuator

func (*Evacuator) Run

func (e *Evacuator) Run(signals <-chan os.Signal, ready chan<- struct{}) error