hm

Documentation

Index

• func Analyze(l lager.Logger, sink lager.Sink, conf *config.Config, poll bool)
• func Dump(l lager.Logger, conf *config.Config, raw bool)
• func NewFixedClock(now time.Time) clock.Clock
• func ServeAPI(l lager.Logger, conf *config.Config)
• func Shred(l lager.Logger, conf *config.Config, poll bool)
• func StartEvacuator(logger lager.Logger, conf *config.Config)
• func StartListeningForActual(logger lager.Logger, conf *config.Config)
• type Component
  • func NewComponent(name string, conf *config.Config, pollingInterval time.Duration, ...) *Component
  • func (hm *Component) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Functions

func Analyze

func Analyze(l lager.Logger, sink lager.Sink, conf *config.Config, poll bool)

func Dump

func Dump(l lager.Logger, conf *config.Config, raw bool)

func NewFixedClock

func NewFixedClock(now time.Time) clock.Clock

func ServeAPI

func ServeAPI(l lager.Logger, conf *config.Config)

func Shred

func Shred(l lager.Logger, conf *config.Config, poll bool)

func StartEvacuator

func StartEvacuator(logger lager.Logger, conf *config.Config)

func StartListeningForActual

func StartListeningForActual(logger lager.Logger, conf *config.Config)

Types

type Component

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

func NewComponent

func NewComponent(name string, conf *config.Config, pollingInterval time.Duration, timeout time.Duration,
	logger lager.Logger, action func() error) *Component

func (*Component) Run

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