metricspipeline

Documentation

Index

• func NewRouter(metricAdapter stackdriver.MetricAdapter, ...) stackdriver.MetricAdapter
• type MetricsBuffer
  • func NewAutoCulledMetricsBuffer(ctx context.Context, logger lager.Logger, frequency time.Duration, ...) MetricsBuffer

Functions

func NewRouter

func NewRouter(metricAdapter stackdriver.MetricAdapter, metricEvents []events.Envelope_EventType, logAdapter stackdriver.LogAdapter, logEvents []events.Envelope_EventType) stackdriver.MetricAdapter

NewRouter provides a MetricAdapter that routes a given metric to Stackdriver Logging and Stackdriver Monitoring based on configuration

Types

type MetricsBuffer

type MetricsBuffer interface {
	stackdriver.MetricAdapter
	IsEmpty() bool
}

func NewAutoCulledMetricsBuffer

func NewAutoCulledMetricsBuffer(ctx context.Context, logger lager.Logger, frequency time.Duration, adapter stackdriver.MetricAdapter) MetricsBuffer

NewAutoCulledMetricsBuffer provides a MetricsBuffer that will cull like metrics over the defined frequency. A like metric is defined as a metric with the same stackdriver.Metric.Hash()