metrics

Documentation

Index

• Constants
• type InfluxConnectionMetrics
  • func NewInfluxConnectionMetrics(r metrics.Registry) *InfluxConnectionMetrics
• type InfluxMetrics
  • func CreateInfluxMetrics() *InfluxMetrics
  • func (m InfluxMetrics) Export(cfg config.Metrics)
  • func (m *InfluxMetrics) GetEngineRegistry() interface{}
  • func (m *InfluxMetrics) GetMetricsEngineName() string
  • func (m *InfluxMetrics) RecordAcceptConnectionErrors()
  • func (m *InfluxMetrics) RecordCloseConnectionErrors()
  • func (m *InfluxMetrics) RecordConnectionClosed()
  • func (m *InfluxMetrics) RecordConnectionOpen()
  • func (m *InfluxMetrics) RecordGetBackendDuration(duration time.Duration)
  • func (m *InfluxMetrics) RecordGetBackendError()
  • func (m *InfluxMetrics) RecordGetBackendTotal()
  • func (m *InfluxMetrics) RecordGetBadRequest()
  • func (m *InfluxMetrics) RecordGetDuration(duration time.Duration)
  • func (m *InfluxMetrics) RecordGetError()
  • func (m *InfluxMetrics) RecordGetTotal()
  • func (m *InfluxMetrics) RecordKeyNotFoundError()
  • func (m *InfluxMetrics) RecordMissingKeyError()
  • func (m *InfluxMetrics) RecordPutBackendDuration(duration time.Duration)
  • func (m *InfluxMetrics) RecordPutBackendError()
  • func (m *InfluxMetrics) RecordPutBackendInvalid()
  • func (m *InfluxMetrics) RecordPutBackendJson()
  • func (m *InfluxMetrics) RecordPutBackendSize(sizeInBytes float64)
  • func (m *InfluxMetrics) RecordPutBackendTTLSeconds(duration time.Duration)
  • func (m *InfluxMetrics) RecordPutBackendXml()
  • func (m *InfluxMetrics) RecordPutBadRequest()
  • func (m *InfluxMetrics) RecordPutDuration(duration time.Duration)
  • func (m *InfluxMetrics) RecordPutError()
  • func (m *InfluxMetrics) RecordPutKeyProvided()
  • func (m *InfluxMetrics) RecordPutTotal()
• type InfluxMetricsEntry
  • func NewInfluxMetricsEntryEndpointPuts(name string, r metrics.Registry) *InfluxMetricsEntry
  • func NewInfluxMetricsEntryGet(name string, r metrics.Registry) *InfluxMetricsEntry
• type InfluxMetricsEntryByFormat
  • func NewInfluxMetricsEntryBackendPuts(name string, r metrics.Registry) *InfluxMetricsEntryByFormat
• type InfluxMetricsGetErrors
  • func NewInfluxGetErrorMetrics(name string, r metrics.Registry) *InfluxMetricsGetErrors

Constants

const MetricsInfluxDB = "InfluxDB"

const TenSeconds time.Duration = time.Second * 10

Types

type InfluxConnectionMetrics

type InfluxConnectionMetrics struct {
	ActiveConnections      metrics.Counter
	ConnectionCloseErrors  metrics.Meter
	ConnectionAcceptErrors metrics.Meter
}

func NewInfluxConnectionMetrics

func NewInfluxConnectionMetrics(r metrics.Registry) *InfluxConnectionMetrics

type InfluxMetrics

type InfluxMetrics struct {
	Registry    metrics.Registry
	Puts        *InfluxMetricsEntry
	Gets        *InfluxMetricsEntry
	PutsBackend *InfluxMetricsEntryByFormat
	GetsBackend *InfluxMetricsEntry
	GetsErr     *InfluxMetricsGetErrors
	Connections *InfluxConnectionMetrics
	MetricsName string
}

func CreateInfluxMetrics

func CreateInfluxMetrics() *InfluxMetrics

func (InfluxMetrics) Export

func (m InfluxMetrics) Export(cfg config.Metrics)

Export begins metric publishing services.

func (*InfluxMetrics) GetEngineRegistry

func (m *InfluxMetrics) GetEngineRegistry() interface{}

func (*InfluxMetrics) GetMetricsEngineName

func (m *InfluxMetrics) GetMetricsEngineName() string

func (*InfluxMetrics) RecordAcceptConnectionErrors

func (m *InfluxMetrics) RecordAcceptConnectionErrors()

func (*InfluxMetrics) RecordCloseConnectionErrors

func (m *InfluxMetrics) RecordCloseConnectionErrors()

func (*InfluxMetrics) RecordConnectionClosed

func (m *InfluxMetrics) RecordConnectionClosed()

func (*InfluxMetrics) RecordConnectionOpen

func (m *InfluxMetrics) RecordConnectionOpen()

func (*InfluxMetrics) RecordGetBackendDuration

func (m *InfluxMetrics) RecordGetBackendDuration(duration time.Duration)

func (*InfluxMetrics) RecordGetBackendError

func (m *InfluxMetrics) RecordGetBackendError()

func (*InfluxMetrics) RecordGetBackendTotal

func (m *InfluxMetrics) RecordGetBackendTotal()

func (*InfluxMetrics) RecordGetBadRequest

func (m *InfluxMetrics) RecordGetBadRequest()

func (*InfluxMetrics) RecordGetDuration

func (m *InfluxMetrics) RecordGetDuration(duration time.Duration)

func (*InfluxMetrics) RecordGetError

func (m *InfluxMetrics) RecordGetError()

func (*InfluxMetrics) RecordGetTotal

func (m *InfluxMetrics) RecordGetTotal()

func (*InfluxMetrics) RecordKeyNotFoundError

func (m *InfluxMetrics) RecordKeyNotFoundError()

func (*InfluxMetrics) RecordMissingKeyError

func (m *InfluxMetrics) RecordMissingKeyError()

func (*InfluxMetrics) RecordPutBackendDuration

func (m *InfluxMetrics) RecordPutBackendDuration(duration time.Duration)

func (*InfluxMetrics) RecordPutBackendError

func (m *InfluxMetrics) RecordPutBackendError()

func (*InfluxMetrics) RecordPutBackendInvalid

func (m *InfluxMetrics) RecordPutBackendInvalid()

func (*InfluxMetrics) RecordPutBackendJson

func (m *InfluxMetrics) RecordPutBackendJson()

func (*InfluxMetrics) RecordPutBackendSize

func (m *InfluxMetrics) RecordPutBackendSize(sizeInBytes float64)

func (*InfluxMetrics) RecordPutBackendTTLSeconds

func (m *InfluxMetrics) RecordPutBackendTTLSeconds(duration time.Duration)

func (*InfluxMetrics) RecordPutBackendXml

func (m *InfluxMetrics) RecordPutBackendXml()

func (*InfluxMetrics) RecordPutBadRequest

func (m *InfluxMetrics) RecordPutBadRequest()

func (*InfluxMetrics) RecordPutDuration

func (m *InfluxMetrics) RecordPutDuration(duration time.Duration)

func (*InfluxMetrics) RecordPutError

func (m *InfluxMetrics) RecordPutError()

func (*InfluxMetrics) RecordPutKeyProvided

func (m *InfluxMetrics) RecordPutKeyProvided()

func (*InfluxMetrics) RecordPutTotal

func (m *InfluxMetrics) RecordPutTotal()

type InfluxMetricsEntry

type InfluxMetricsEntry struct {
	Duration   metrics.Timer
	Errors     metrics.Meter
	BadRequest metrics.Meter
	Request    metrics.Meter
	Update     metrics.Meter
}

func NewInfluxMetricsEntryEndpointPuts

func NewInfluxMetricsEntryEndpointPuts(name string, r metrics.Registry) *InfluxMetricsEntry

NewInfluxMetricsEntryEndpointPuts initializes all the metrics of InfluxMetricsEntry including Update which will account for the Put requests that come with their own Key to store the value in.

func NewInfluxMetricsEntryGet

func NewInfluxMetricsEntryGet(name string, r metrics.Registry) *InfluxMetricsEntry

NewInfluxMetricsEntryGet initializes all the metrics of InfluxMetricsEntry except for Update which makes no sense in the context of a Get call

type InfluxMetricsEntryByFormat

type InfluxMetricsEntryByFormat struct {
	Duration       metrics.Timer
	Request        metrics.Meter
	Errors         metrics.Meter
	BadRequest     metrics.Meter
	JsonRequest    metrics.Meter
	XmlRequest     metrics.Meter
	InvalidRequest metrics.Meter
	RequestLength  metrics.Histogram
	RequestTTL     metrics.Timer
}

func NewInfluxMetricsEntryBackendPuts

func NewInfluxMetricsEntryBackendPuts(name string, r metrics.Registry) *InfluxMetricsEntryByFormat

type InfluxMetricsGetErrors

type InfluxMetricsGetErrors struct {
	KeyNotFoundErrors metrics.Meter
	MissingKeyErrors  metrics.Meter
}

func NewInfluxGetErrorMetrics

func NewInfluxGetErrorMetrics(name string, r metrics.Registry) *InfluxMetricsGetErrors