metrics

package

v1.1.4 Latest Latest Go to latest Published: Oct 30, 2019 License: MIT Imports: 10 Imported by: 0

Documentation ¶

Index ¶

func Register()
type MetricsPublisher
- func NewMetricsPublisher() MetricsPublisher

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL