metrics

Documentation

Index

• type AxiomMetrics
  • func NewMetrics() (*AxiomMetrics, error)
  • func (m *AxiomMetrics) GetThroughput() uint64
  • func (m *AxiomMetrics) IncrementThroughput()
  • func (m *AxiomMetrics) SendMetrics() error
• type Metrics

Types

type AxiomMetrics

type AxiomMetrics struct {
	ServerId    string
	DatasetName string
	ApiToken    string
	IngestUrl   string
	Throughput  uint64
	Mutex       sync.Mutex
}

func NewMetrics

func NewMetrics() (*AxiomMetrics, error)

func (*AxiomMetrics) GetThroughput

func (m *AxiomMetrics) GetThroughput() uint64

Return the throughput and reset the count

func (*AxiomMetrics) IncrementThroughput

func (m *AxiomMetrics) IncrementThroughput()

Increment the throughput count

func (*AxiomMetrics) SendMetrics

func (m *AxiomMetrics) SendMetrics() error

Send the metrics over to Axiom

type Metrics

type Metrics interface {
	IncrementThroughput()
	GetThroughput() uint64
	SendMetrics() error
}