metrics

Documentation

Index

• type KafkaMetrics
  • func NewKafkaMetrics() *KafkaMetrics
  • func (m *KafkaMetrics) IncreaseReaderOffset(topic string, offset int64)
  • func (m *KafkaMetrics) IncreaseWriterOffset(topic string, offset int64)
  • func (m *KafkaMetrics) ObserveLatency(topic string, latency float64)
  • func (m *KafkaMetrics) SwitchTopic(origin, target string)
• type S3Metrics
  • func NewS3Metrics() *S3Metrics
  • func (m *S3Metrics) IncreaseReadSize(bucket string, size int64)
  • func (m *S3Metrics) IncreaseWriteSize(bucket string, size int64)
  • func (m *S3Metrics) ObserveReadLatency(bucket string, latency float64)
  • func (m *S3Metrics) ObserveWriteLatency(bucket string, latency float64)

Types

type KafkaMetrics

type KafkaMetrics struct {
	KafkaWriterOffset *prometheus.Counter
	KafkaReaderOffset *prometheus.Counter
	KafkaCurrentTopic *prometheus.Gauge
	KafkaLatency      *prometheus.Histogram
}

func NewKafkaMetrics

func NewKafkaMetrics() *KafkaMetrics

func (*KafkaMetrics) IncreaseReaderOffset

func (m *KafkaMetrics) IncreaseReaderOffset(topic string, offset int64)

func (*KafkaMetrics) IncreaseWriterOffset

func (m *KafkaMetrics) IncreaseWriterOffset(topic string, offset int64)

func (*KafkaMetrics) ObserveLatency

func (m *KafkaMetrics) ObserveLatency(topic string, latency float64)

func (*KafkaMetrics) SwitchTopic

func (m *KafkaMetrics) SwitchTopic(origin, target string)

type S3Metrics

type S3Metrics struct {
	S3WriteLatency *prometheus.Histogram
	S3ReadLatency  *prometheus.Histogram
	S3WriteSize    *prometheus.Counter
	S3ReadSize     *prometheus.Counter
}

func NewS3Metrics

func NewS3Metrics() *S3Metrics

func (*S3Metrics) IncreaseReadSize

func (m *S3Metrics) IncreaseReadSize(bucket string, size int64)

func (*S3Metrics) IncreaseWriteSize

func (m *S3Metrics) IncreaseWriteSize(bucket string, size int64)

func (*S3Metrics) ObserveReadLatency

func (m *S3Metrics) ObserveReadLatency(bucket string, latency float64)

func (*S3Metrics) ObserveWriteLatency

func (m *S3Metrics) ObserveWriteLatency(bucket string, latency float64)