class Racecar::Datadog::ProducerSubscriber

Public Instance Methods

acknowledged_message(event) click to toggle source
# File lib/racecar/datadog.rb, line 237
def acknowledged_message(event)
  tags = { client: event.payload.fetch(:client_id) }

  # Number of messages ACK'd for the topic.
  increment("producer.ack.messages", tags: tags)
end
deliver_messages(event) click to toggle source
# File lib/racecar/datadog.rb, line 223
def deliver_messages(event)
  client = event.payload.fetch(:client_id)
  message_count = event.payload.fetch(:delivered_message_count)

  tags = {
    client: client,
  }

  timing("producer.deliver.latency", event.duration, tags: tags)

  # Messages delivered to Kafka:
  count("producer.deliver.messages", message_count, tags: tags)
end
produce_message(event) click to toggle source
# File lib/racecar/datadog.rb, line 199
def produce_message(event)
  client = event.payload.fetch(:client_id)
  topic = event.payload.fetch(:topic)
  message_size = event.payload.fetch(:message_size)
  buffer_size = event.payload.fetch(:buffer_size)

  tags = {
    client: client,
    topic: topic,
  }

  # This gets us the write rate.
  increment("producer.produce.messages", tags: tags.merge(topic: topic))

  # Information about typical/average/95p message size.
  histogram("producer.produce.message_size", message_size, tags: tags.merge(topic: topic))

  # Aggregate message size.
  count("producer.produce.message_size.sum", message_size, tags: tags.merge(topic: topic))

  # This gets us the avg/max buffer size per producer.
  histogram("producer.buffer.size", buffer_size, tags: tags)
end