Method: Kafka::Prometheus::ProducerSubscriber#deliver_messages

Defined in:

lib/kafka/prometheus.rb

#deliver_messages(event) ⇒ Object

# File 'lib/kafka/prometheus.rb', line 231

def deliver_messages(event)
  key = { client: event.payload.fetch(:client_id) }
  message_count = event.payload.fetch(:delivered_message_count)
  attempts = event.payload.fetch(:attempts)

  @deliver_errors.increment(labels: key) if event.payload.key?(:exception)
  @deliver_latency.observe(event.duration, labels: key)

  # Messages delivered to Kafka:
  @deliver_messages.increment(by: message_count, labels: key)

  # Number of attempts to deliver messages:
  @deliver_attempts.observe(attempts, labels: key)
end