kafka_metrics

Documentation

Index

• type ConsumerStorage
  • func NewConsumerStorage(reg *metrics.Registry) *ConsumerStorage
  • func (c *ConsumerStorage) IncCommitCount(consumerGroup, topic string)
  • func (c *ConsumerStorage) IncRetryCount(consumerGroup, topic string)
  • func (c *ConsumerStorage) ObserveConsumeDuration(consumerGroup, topic string, t time.Duration)
  • func (c *ConsumerStorage) ObserveConsumeMsgSize(consumerGroup, topic string, size int)
• type PublisherStorage
  • func NewPublisherStorage(reg *metrics.Registry) *PublisherStorage
  • func (c *PublisherStorage) IncPublishError(topic string)
  • func (c *PublisherStorage) ObservePublishDuration(topic string, t time.Duration)
  • func (c *PublisherStorage) ObservePublishMsgSize(topic string, size int)

Types

type ConsumerStorage

type ConsumerStorage struct {
	// contains filtered or unexported fields
}

func NewConsumerStorage

func NewConsumerStorage(reg *metrics.Registry) *ConsumerStorage

func (*ConsumerStorage) IncCommitCount

func (c *ConsumerStorage) IncCommitCount(consumerGroup, topic string)

func (*ConsumerStorage) IncRetryCount

func (c *ConsumerStorage) IncRetryCount(consumerGroup, topic string)

func (*ConsumerStorage) ObserveConsumeDuration

func (c *ConsumerStorage) ObserveConsumeDuration(consumerGroup, topic string, t time.Duration)

func (*ConsumerStorage) ObserveConsumeMsgSize

func (c *ConsumerStorage) ObserveConsumeMsgSize(consumerGroup, topic string, size int)

type PublisherStorage

type PublisherStorage struct {
	// contains filtered or unexported fields
}

func NewPublisherStorage

func NewPublisherStorage(reg *metrics.Registry) *PublisherStorage

func (*PublisherStorage) IncPublishError

func (c *PublisherStorage) IncPublishError(topic string)

func (*PublisherStorage) ObservePublishDuration

func (c *PublisherStorage) ObservePublishDuration(topic string, t time.Duration)

func (*PublisherStorage) ObservePublishMsgSize

func (c *PublisherStorage) ObservePublishMsgSize(topic string, size int)