metrics

Documentation

Index

• type Client
• type DatadogClient
  • func NewDatadogClient(apiKey, appKey string, opts ...DatadogClientOpt) *DatadogClient
  • func (d *DatadogClient) Close() error
• type DatadogClientOpt
  • func WithDatadogFrozenClock(frozenTime float64) DatadogClientOpt
  • func WithDatadogSubmitInterval(dur time.Duration) DatadogClientOpt
  • func WithDatadogTags(tags []string) DatadogClientOpt
  • func WithDatadogURL(datadog url.URL) DatadogClientOpt
• type NoopClient
  • func (*NoopClient) CheckAttestationError(string, error)
  • func (*NoopClient) CheckAttestationLatency(string, time.Duration)
  • func (*NoopClient) CheckAttestationStart(string)
  • func (*NoopClient) CheckAttestationSuccess(string)
  • func (*NoopClient) CheckRunError(string, error)
  • func (*NoopClient) CheckRunFailure(string)
  • func (*NoopClient) CheckRunLatency(string, time.Duration)
  • func (*NoopClient) CheckRunStart(string)
  • func (*NoopClient) CheckRunSuccess(string)
  • func (*NoopClient) PubSubMessageReceived()
  • func (*NoopClient) PubSubTotalLatency(time.Duration)
• type StatsdClient
  • func NewStatsdClient(addr string, samplingRate float64, tags []string) (*StatsdClient, error)
  • func (d *StatsdClient) CheckAttestationError(check string, err error)
  • func (d *StatsdClient) CheckAttestationLatency(check string, dur time.Duration)
  • func (d *StatsdClient) CheckAttestationStart(check string)
  • func (d *StatsdClient) CheckAttestationSuccess(check string)
  • func (d *StatsdClient) CheckRunError(check string, err error)
  • func (d *StatsdClient) CheckRunFailure(check string)
  • func (d *StatsdClient) CheckRunLatency(check string, dur time.Duration)
  • func (d *StatsdClient) CheckRunStart(check string)
  • func (d *StatsdClient) CheckRunSuccess(check string)
  • func (d *StatsdClient) PubSubMessageReceived()
  • func (d *StatsdClient) PubSubTotalLatency(duration time.Duration)

Types

type Client

type Client interface {
	CheckRunStart(string)
	CheckRunLatency(string, time.Duration)
	CheckAttestationLatency(string, time.Duration)
	CheckRunFailure(string)
	CheckRunError(string, error)
	CheckRunSuccess(string)
	CheckAttestationStart(string)
	CheckAttestationError(string, error)
	CheckAttestationSuccess(string)
	PubSubMessageReceived()
	PubSubTotalLatency(time.Duration)
}

type DatadogClient

type DatadogClient struct {
	StatsdClient
	// contains filtered or unexported fields
}

DatadogClient is a metrics.Client that emits directly to Datadog.

func NewDatadogClient

func NewDatadogClient(apiKey, appKey string, opts ...DatadogClientOpt) *DatadogClient

func (*DatadogClient) Close

func (d *DatadogClient) Close() error

type DatadogClientOpt

type DatadogClientOpt func(*DatadogClient)

func WithDatadogFrozenClock

func WithDatadogFrozenClock(frozenTime float64) DatadogClientOpt

func WithDatadogSubmitInterval

func WithDatadogSubmitInterval(dur time.Duration) DatadogClientOpt

func WithDatadogTags

func WithDatadogTags(tags []string) DatadogClientOpt

func WithDatadogURL

func WithDatadogURL(datadog url.URL) DatadogClientOpt

type NoopClient

type NoopClient struct{}

func (*NoopClient) CheckAttestationError

func (*NoopClient) CheckAttestationError(string, error)

func (*NoopClient) CheckAttestationLatency

func (*NoopClient) CheckAttestationLatency(string, time.Duration)

func (*NoopClient) CheckAttestationStart

func (*NoopClient) CheckAttestationStart(string)

func (*NoopClient) CheckAttestationSuccess

func (*NoopClient) CheckAttestationSuccess(string)

func (*NoopClient) CheckRunError

func (*NoopClient) CheckRunError(string, error)

func (*NoopClient) CheckRunFailure

func (*NoopClient) CheckRunFailure(string)

func (*NoopClient) CheckRunLatency

func (*NoopClient) CheckRunLatency(string, time.Duration)

func (*NoopClient) CheckRunStart

func (*NoopClient) CheckRunStart(string)

func (*NoopClient) CheckRunSuccess

func (*NoopClient) CheckRunSuccess(string)

func (*NoopClient) PubSubMessageReceived

func (*NoopClient) PubSubMessageReceived()

func (*NoopClient) PubSubTotalLatency

func (*NoopClient) PubSubTotalLatency(time.Duration)

type StatsdClient

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

StatsdClient is a metrics.Client that emits via statsd UDP protocol.

func NewStatsdClient

func NewStatsdClient(addr string, samplingRate float64, tags []string) (*StatsdClient, error)

NewStatsdClient creates a client to emit metrics to a statsd server, probably dogstatsd.

func (*StatsdClient) CheckAttestationError

func (d *StatsdClient) CheckAttestationError(check string, err error)

func (*StatsdClient) CheckAttestationLatency

func (d *StatsdClient) CheckAttestationLatency(check string, dur time.Duration)

func (*StatsdClient) CheckAttestationStart

func (d *StatsdClient) CheckAttestationStart(check string)

func (*StatsdClient) CheckAttestationSuccess

func (d *StatsdClient) CheckAttestationSuccess(check string)

func (*StatsdClient) CheckRunError

func (d *StatsdClient) CheckRunError(check string, err error)

func (*StatsdClient) CheckRunFailure

func (d *StatsdClient) CheckRunFailure(check string)

func (*StatsdClient) CheckRunLatency

func (d *StatsdClient) CheckRunLatency(check string, dur time.Duration)

func (*StatsdClient) CheckRunStart

func (d *StatsdClient) CheckRunStart(check string)

func (*StatsdClient) CheckRunSuccess

func (d *StatsdClient) CheckRunSuccess(check string)

func (*StatsdClient) PubSubMessageReceived

func (d *StatsdClient) PubSubMessageReceived()

PubSubMessageReceived tracks the number of messages received from pub/sub

func (*StatsdClient) PubSubTotalLatency

func (d *StatsdClient) PubSubTotalLatency(duration time.Duration)

PubSubTotalLatency tracks the time it takes to process a pub/sub message