evacuator

Documentation

Index

• type Evacuator
  • func New(messageBus yagnats.NATSConn, store store.Store, clock clock.Clock, ...) *Evacuator
  • func (e *Evacuator) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Types

type Evacuator

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

func New

func New(messageBus yagnats.NATSConn, store store.Store, clock clock.Clock, metricsAccountant metricsaccountant.MetricsAccountant, config *config.Config, logger lager.Logger) *Evacuator

func (*Evacuator) Run

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