Class: WaterDrop::Instrumentation::Callbacks::Delivery

Inherits:

Object

• Object
• WaterDrop::Instrumentation::Callbacks::Delivery

Defined in:

lib/water_drop/instrumentation/callbacks/delivery.rb

Overview

Note:

We don’t have to provide client_name here as this callback is per client instance

Creates a callable that we want to run upon each message delivery or failure

Instance Method Summary

• #call(delivery_report) ⇒ Object

  Emits delivery details to the monitor.

• #initialize(producer_id, monitor) ⇒ Delivery constructor

  A new instance of Delivery.

Constructor Details

#initialize(producer_id, monitor) ⇒ Delivery

Returns a new instance of Delivery.

Parameters:

• producer_id (String) —

  id of the current producer

• monitor (WaterDrop::Instrumentation::Monitor) —

  monitor we are using

# File 'lib/water_drop/instrumentation/callbacks/delivery.rb', line 12

def initialize(producer_id, monitor)
  @producer_id = producer_id
  @monitor = monitor
end

Instance Method Details

#call(delivery_report) ⇒ Object

Emits delivery details to the monitor

Parameters:

• delivery_report (Rdkafka::Producer::DeliveryReport) —

  delivery report

# File 'lib/water_drop/instrumentation/callbacks/delivery.rb', line 19

def call(delivery_report)
  @monitor.instrument(
    'message.acknowledged',
    producer_id: @producer_id,
    offset: delivery_report.offset,
    partition: delivery_report.partition
  )
end