heartbeat

Documentation

Index

• func NewLoggerHandler(logger lager.Logger) *loggerHandler
• func NewMetricHandler(ma stackdriver.MetricAdapter, logger lager.Logger, ...) *metricHandler
• type Handler
• type Heartbeater
  • func NewHeartbeater(logger lager.Logger, trigger <-chan time.Time) Heartbeater
  • func NewLoggerMetricHeartbeater(metricHandler Handler, logger lager.Logger, trigger <-chan time.Time) Heartbeater

Functions

func NewLoggerHandler

func NewLoggerHandler(logger lager.Logger) *loggerHandler

func NewMetricHandler

func NewMetricHandler(ma stackdriver.MetricAdapter, logger lager.Logger, nozzleId, nozzleName, nozzleZone string) *metricHandler

Types

type Handler

type Handler interface {
	Handle(string)
	Flush() error
	Name() string
}

type Heartbeater

type Heartbeater interface {
	Start()
	Increment(string)
	Stop()
}

func NewHeartbeater

func NewHeartbeater(logger lager.Logger, trigger <-chan time.Time) Heartbeater

func NewLoggerMetricHeartbeater

func NewLoggerMetricHeartbeater(metricHandler Handler, logger lager.Logger, trigger <-chan time.Time) Heartbeater