Documentation
¶
Index ¶
- Constants
- func IncreaseConsumerElasticsearchClientFailed(phase string)
- func IncreaseKafkaMessagesIncoming(topic string)
- func IncreaseKafkaMessagesStoredTotal(topic string)
- func IncreaseKafkaMessagesStoredTotalWithError(topic string, errorMessage string)
- func IncreaseLogStoredCounter(index string, result string, status int, errorMessage string)
- func IncreaseProducerKafkaClientFailed()
- func IncreaseProducerTPSExceededCounter(topic string, n int)
- func InitConsumerInstrumentation()
- func InitProducerInstrumentation()
- func ObserveBulkProcessTime(elapsedTime float64)
- func ObserveSendToKafkaTime(topic string, elapsedTime float64)
Constants ¶
View Source
const ( ESClientFailedPhaseInit = "init" ESClientFailedPhaseRetry = "retry" )
Variables ¶
This section is empty.
Functions ¶
func IncreaseConsumerElasticsearchClientFailed ¶ added in v0.13.4
func IncreaseConsumerElasticsearchClientFailed(phase string)
func IncreaseKafkaMessagesIncoming ¶
func IncreaseKafkaMessagesIncoming(topic string)
func IncreaseKafkaMessagesStoredTotal ¶
func IncreaseKafkaMessagesStoredTotal(topic string)
func IncreaseKafkaMessagesStoredTotalWithError ¶ added in v0.13.2
func IncreaseProducerKafkaClientFailed ¶ added in v0.13.4
func IncreaseProducerKafkaClientFailed()
func IncreaseProducerTPSExceededCounter ¶ added in v0.13.2
func InitConsumerInstrumentation ¶
func InitConsumerInstrumentation()
func InitProducerInstrumentation ¶
func InitProducerInstrumentation()
func ObserveBulkProcessTime ¶
func ObserveBulkProcessTime(elapsedTime float64)
func ObserveSendToKafkaTime ¶ added in v0.13.2
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.