telemetry

type Counter ¶

type Counter struct {
	expvar.Int
	Labels map[string]string
}

A Counter is a monotonically-increasing integer expvar associated with a set of labels expressed as a key-value string map.

Note that exporting custom labels for Counters to Stackdriver is only implemented for counters that are part of a CounterMap.

func NewCounter(mp MetricPrefix, name string) *Counter

func (c *Counter) Increment()

func (c *Counter) IntValue() int

type CounterMap ¶

type CounterMap struct {
	expvar.Map

	LabelKeys []string
	// contains filtered or unexported fields
}

A CounterMap is used to export a set of related Counters which have the same label keys.

func NewCounterMap(mp MetricPrefix, name string, labelKeys ...string) *CounterMap

func (cm *CounterMap) Counter(labelValues ...string) (*Counter, error)

func (cm *CounterMap) MustCounter(labelValues ...string) *Counter

type MetricPrefix ¶

type MetricPrefix string

A MetricPrefix is a path element prepended to metric names.

const Nozzle MetricPrefix = "stackdriver-nozzle"

func (mp MetricPrefix) Qualify(name string) string

type Reporter ¶

type Reporter interface {
	Start(ctx context.Context)
}

Reporter aggregates telemetry registered with expvar and reports it to Sink endpoints

func NewReporter(period time.Duration, sinks ...Sink) Reporter

type Sink ¶

type Sink interface {
	// Init is called a single time when the Reporter is starting before any data is reported
	Init([]*expvar.KeyValue)
	// Report is a snapshot of the cumulative telemetry values at the current time
	Report([]*expvar.KeyValue)
}

Sink represents an endpoint that records telemetry to an external source

func NewLogSink(logger lager.Logger) Sink