metrics

Documentation

Index

• Constants
• type DBOperation
• type Metrics
  • func NewMetrics(prefix string) *Metrics
  • func (m *Metrics) RecordDBError(operation DBOperation)
  • func (m *Metrics) RecordEventSequenceProcessed(queue, msgTpe string)
  • func (m *Metrics) RecordPulsarConnectionError()
  • func (m *Metrics) RecordPulsarMessageError(error PulsarMessageError)
  • func (m *Metrics) RecordPulsarMessageProcessed()
• type PulsarMessageError

Constants

const (
	DBOperationRead                   DBOperation        = "read"
	DBOperationInsert                 DBOperation        = "insert"
	DBOperationUpdate                 DBOperation        = "update"
	DBOperationCreateTempTable        DBOperation        = "create_temp_table"
	PulsarMessageErrorDeserialization PulsarMessageError = "deserialization"
	PulsarMessageErrorProcessing      PulsarMessageError = "processing"
)

const (
	ArmadaLookoutIngesterV2MetricsPrefix = "armada_lookout_ingester_v2_"
	ArmadaEventIngesterMetricsPrefix     = "armada_event_ingester_"
)

Types

type DBOperation

type DBOperation string

type Metrics

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

func NewMetrics

func NewMetrics(prefix string) *Metrics

func (*Metrics) RecordDBError

func (m *Metrics) RecordDBError(operation DBOperation)

func (*Metrics) RecordEventSequenceProcessed

func (m *Metrics) RecordEventSequenceProcessed(queue, msgTpe string)

func (*Metrics) RecordPulsarConnectionError

func (m *Metrics) RecordPulsarConnectionError()

func (*Metrics) RecordPulsarMessageError

func (m *Metrics) RecordPulsarMessageError(error PulsarMessageError)

func (*Metrics) RecordPulsarMessageProcessed

func (m *Metrics) RecordPulsarMessageProcessed()

type PulsarMessageError

type PulsarMessageError string