Method List

Classes Methods Files

Search:

#abort_transaction WaterDrop::Clients::Buffered
#active? WaterDrop::Producer::Status
#append WaterDrop::Middleware
#begin_transaction WaterDrop::Clients::Buffered
#buffer WaterDrop::Producer::Buffer
#buffer_many WaterDrop::Producer::Buffer
#call WaterDrop::Producer::Builder
#call WaterDrop::Instrumentation::Callbacks::Error
#call WaterDrop::Instrumentation::Callbacks::Delivery
#call WaterDrop::Instrumentation::Callbacks::Statistics
#call WaterDrop::Instrumentation::Callbacks::OauthbearerTokenRefresh
#client WaterDrop::Producer
#close WaterDrop::Producer
#close! WaterDrop::Producer
#commit_transaction WaterDrop::Clients::Buffered
#config WaterDrop::Producer
#create_result WaterDrop::Clients::Dummy::Handle
#decrement WaterDrop::Helpers::Counter
#default? WaterDrop::Producer::Variant
#dispatched WaterDrop::Errors::ProduceManyError
#flush_async WaterDrop::Producer::Buffer
#flush_sync WaterDrop::Producer::Buffer
gem_root WaterDrop
#id WaterDrop::Producer
#idempotent? WaterDrop::Producer
#increment WaterDrop::Helpers::Counter
#initialize WaterDrop::Errors::ProduceManyError
#initialize WaterDrop::Producer
#initialize WaterDrop::Middleware
#initialize WaterDrop::Clients::Dummy::Handle
#initialize WaterDrop::Clients::Dummy
#initialize WaterDrop::Helpers::Counter
#initialize WaterDrop::Producer::Status
#initialize WaterDrop::Clients::Buffered
#initialize WaterDrop::Producer::Variant
#initialize WaterDrop::Contracts::Message
#initialize WaterDrop::Instrumentation::Monitor
#initialize WaterDrop::Instrumentation::Notifications
#initialize WaterDrop::Instrumentation::Callbacks::Error
#initialize WaterDrop::Instrumentation::LoggerListener
#initialize WaterDrop::Instrumentation::Callbacks::Delivery
#initialize WaterDrop::Instrumentation::Callbacks::Statistics
#initialize WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
#initialize WaterDrop::Instrumentation::Callbacks::OauthbearerTokenRefresh
#key_location WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
#max_payload_size WaterDrop::Contracts::Message
#max_wait_timeout WaterDrop::Producer::Variant
#messages WaterDrop::Producer
#messages WaterDrop::Clients::Buffered
#messages_for WaterDrop::Clients::Buffered
#method_missing WaterDrop::Clients::Dummy
#middleware WaterDrop::Producer
#monitor WaterDrop::Producer
#name WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
new WaterDrop::Clients::Rdkafka
#on_buffer_flushed_async WaterDrop::Instrumentation::LoggerListener
#on_buffer_flushed_sync WaterDrop::Instrumentation::LoggerListener
#on_buffer_purged WaterDrop::Instrumentation::LoggerListener
#on_error_occurred WaterDrop::Instrumentation::LoggerListener
#on_error_occurred WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
#on_message_acknowledged WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
#on_message_buffered WaterDrop::Instrumentation::LoggerListener
#on_message_produced_async WaterDrop::Instrumentation::LoggerListener
#on_message_produced_sync WaterDrop::Instrumentation::LoggerListener
#on_messages_buffered WaterDrop::Instrumentation::LoggerListener
#on_messages_produced_async WaterDrop::Instrumentation::LoggerListener
#on_messages_produced_sync WaterDrop::Instrumentation::LoggerListener
#on_producer_closed WaterDrop::Instrumentation::LoggerListener
#on_producer_closing WaterDrop::Instrumentation::LoggerListener
#on_producer_reloaded WaterDrop::Instrumentation::LoggerListener
#on_statistics_emitted WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
#on_transaction_aborted WaterDrop::Instrumentation::LoggerListener
#on_transaction_committed WaterDrop::Instrumentation::LoggerListener
#on_transaction_finished WaterDrop::Instrumentation::LoggerListener
#on_transaction_marked_as_consumed WaterDrop::Instrumentation::LoggerListener
#on_transaction_started WaterDrop::Instrumentation::LoggerListener
#partition_count WaterDrop::Producer
#prepend WaterDrop::Middleware
#produce WaterDrop::Clients::Dummy
#produce WaterDrop::Clients::Buffered
#produce_async WaterDrop::Producer::Async
#produce_many_async WaterDrop::Producer::Async
#produce_many_sync WaterDrop::Producer::Sync
#produce_sync WaterDrop::Producer::Sync
#producer WaterDrop::Producer::Variant
#purge WaterDrop::Producer
#reset WaterDrop::Clients::Buffered
#respond_to_missing? WaterDrop::Clients::Dummy
#run WaterDrop::Middleware
#run_many WaterDrop::Middleware
#scope WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
#send_offsets_to_transaction WaterDrop::Clients::Buffered
#setup WaterDrop::Config
#setup WaterDrop::Producer
#setup WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
#status WaterDrop::Producer
#to_s WaterDrop::Producer::Status
#topic_config WaterDrop::Producer::Variant
#transaction WaterDrop::Producer::Transactions
#transaction? WaterDrop::Producer::Transactions
#transaction_mark_as_consumed WaterDrop::Producer::Transactions
#transactional? WaterDrop::Producer::Transactions
#type WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener::RdKafkaMetric
#value WaterDrop::Helpers::Counter
#wait WaterDrop::Clients::Dummy::Handle
#with WaterDrop::Producer