316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
|
# File 'lib/kafka/datadog.rb', line 316
def deliver_messages(event)
client = event.payload.fetch(:client_id)
message_count = event.payload.fetch(:delivered_message_count)
attempts = event.payload.fetch(:attempts)
tags = {
client: client,
}
if event.payload.key?(:exception)
increment("producer.deliver.errors", tags: tags)
end
timing("producer.deliver.latency", event.duration, tags: tags)
count("producer.deliver.messages", message_count, tags: tags)
histogram("producer.deliver.attempts", attempts, tags: tags)
end
|