rabbitmq_metrics

Documentation

Index

• type ConsumerStorage
  • func NewConsumerStorage(reg *metrics.Registry) *ConsumerStorage
  • func (c *ConsumerStorage) IncDlqCount(exchange string, routingKey string)
  • func (c *ConsumerStorage) IncRequeueCount(exchange string, routingKey string)
  • func (c *ConsumerStorage) IncRetryCount(exchange string, routingKey string)
  • func (c *ConsumerStorage) IncSuccessCount(exchange string, routingKey string)
  • func (c *ConsumerStorage) ObserveConsumeDuration(exchange string, routingKey string, duration time.Duration)
  • func (c *ConsumerStorage) ObserveConsumeMsgSize(exchange string, routingKey string, size int)
• type PublisherStorage
  • func NewPublisherStorage(reg *metrics.Registry) *PublisherStorage
  • func (c *PublisherStorage) IncPublishError(exchange string, routingKey string)
  • func (c *PublisherStorage) ObservePublishDuration(exchange string, routingKey string, duration time.Duration)
  • func (c *PublisherStorage) ObservePublishMsgSize(exchange string, routingKey string, size int)

Types

type ConsumerStorage

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

func NewConsumerStorage

func NewConsumerStorage(reg *metrics.Registry) *ConsumerStorage

func (*ConsumerStorage) IncDlqCount

func (c *ConsumerStorage) IncDlqCount(exchange string, routingKey string)

func (*ConsumerStorage) IncRequeueCount

func (c *ConsumerStorage) IncRequeueCount(exchange string, routingKey string)

func (*ConsumerStorage) IncRetryCount

func (c *ConsumerStorage) IncRetryCount(exchange string, routingKey string)

func (*ConsumerStorage) IncSuccessCount

func (c *ConsumerStorage) IncSuccessCount(exchange string, routingKey string)

func (*ConsumerStorage) ObserveConsumeDuration

func (c *ConsumerStorage) ObserveConsumeDuration(exchange string, routingKey string, duration time.Duration)

func (*ConsumerStorage) ObserveConsumeMsgSize

func (c *ConsumerStorage) ObserveConsumeMsgSize(exchange string, routingKey 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(exchange string, routingKey string)

func (*PublisherStorage) ObservePublishDuration

func (c *PublisherStorage) ObservePublishDuration(exchange string, routingKey string, duration time.Duration)

func (*PublisherStorage) ObservePublishMsgSize

func (c *PublisherStorage) ObservePublishMsgSize(exchange string, routingKey string, size int)