Class: Kafka::Datadog::FetcherSubscriber
- Inherits:
-
StatsdSubscriber
- Object
- ActiveSupport::Subscriber
- StatsdSubscriber
- Kafka::Datadog::FetcherSubscriber
- Defined in:
- lib/kafka/datadog.rb
Instance Method Summary collapse
Instance Method Details
#loop(event) ⇒ Object
391 392 393 394 395 396 397 398 399 400 |
# File 'lib/kafka/datadog.rb', line 391 def loop(event) queue_size = event.payload.fetch(:queue_size) = { client: event.payload.fetch(:client_id), group_id: event.payload.fetch(:group_id), } gauge("fetcher.queue_size", queue_size, tags: ) end |