metrics

Documentation

Index

• type Metrics

Types

type Metrics

type Metrics interface {
	IncrementReceivedCounter()
	IncrementSentCounter()
	IncrementSourceErrCounter()
	IncrementSinkErrCounter()

	RegisterProcessors(processors []string)

	SetProcessorExecutionTime(proc string, time int64)
	IncrementProcessorDroppedMessages(proc string)
	IncrementProcessorReceivedMessages(proc string)
	IncrementProcessorSentMessages(proc string)
}