metrics

package
v0.0.0-...-02374a7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 17, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const MetricsInfluxDB = "InfluxDB"
View Source 
const TenSeconds time.Duration = time.Second * 10

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.