metrics

Documentation

Index

• func Register()
• type MetricsPublisher
  • func NewMetricsPublisher() MetricsPublisher

Functions

func Register

func Register()

Types

type MetricsPublisher

type MetricsPublisher interface {
	PublishOffsetMetrics(highWaterMarks map[string]map[int32]int64)
	UpdateOffset(topic string, partition int32, delay int64)
	IncrementRecordsConsumed(count int)
	RecordEndpointLatency(latency float64)
	BufferFull(full bool)
	ElasticsearchRetries(count int)
	ElasticsearchConflicts(count int)
	ElasticsearchBadRequests(cont int)
}

func NewMetricsPublisher

func NewMetricsPublisher() MetricsPublisher