metrics

Documentation

Index

• func StartDebugServer(address string, sink *lager.ReconfigurableSink, metrics Metrics) (ifrit.Process, error)
• type Duration
  • func (name Duration) Send(duration time.Duration)
• type Metric
  • func (name Metric) Send(value int)
• type Metrics
  • func NewMetrics(logger lager.Logger, backingStoresPath, depotPath string) Metrics
• type PeriodicMetronNotifier
  • func NewPeriodicMetronNotifier(logger lager.Logger, metrics Metrics, interval time.Duration, ...) *PeriodicMetronNotifier
  • func (notifier PeriodicMetronNotifier) Start()
  • func (notifier PeriodicMetronNotifier) Stop()

Functions

func StartDebugServer

func StartDebugServer(address string, sink *lager.ReconfigurableSink, metrics Metrics) (ifrit.Process, error)

Types

type Duration

type Duration string

func (Duration) Send

func (name Duration) Send(duration time.Duration)

type Metric

type Metric string

func (Metric) Send

func (name Metric) Send(value int)

type Metrics

type Metrics interface {
	NumCPU() int
	NumGoroutine() int
	LoopDevices() int
	BackingStores() int
	DepotDirs() int
}

func NewMetrics

func NewMetrics(logger lager.Logger, backingStoresPath, depotPath string) Metrics

type PeriodicMetronNotifier

type PeriodicMetronNotifier struct {
	Interval time.Duration
	Logger   lager.Logger
	Clock    clock.Clock
	// contains filtered or unexported fields
}

func NewPeriodicMetronNotifier

func NewPeriodicMetronNotifier(
	logger lager.Logger,
	metrics Metrics,
	interval time.Duration,
	clock clock.Clock,
) *PeriodicMetronNotifier

func (PeriodicMetronNotifier) Start

func (notifier PeriodicMetronNotifier) Start()

func (PeriodicMetronNotifier) Stop

func (notifier PeriodicMetronNotifier) Stop()