Table of Contents - waterdrop-2.8.5 Documentation
Pages
Classes and Modules
- WaterDrop
- WaterDrop::Clients
- WaterDrop::Clients::Buffered
- WaterDrop::Clients::Dummy
- WaterDrop::Clients::Dummy::Handle
- WaterDrop::Clients::Rdkafka
- WaterDrop::Config
- WaterDrop::Contracts
- WaterDrop::Contracts::Config
- WaterDrop::Contracts::Message
- WaterDrop::Contracts::TransactionalOffset
- WaterDrop::Contracts::Variant
- WaterDrop::Errors
- WaterDrop::Errors::ProduceManyError
- WaterDrop::Helpers
- WaterDrop::Helpers::Counter
- WaterDrop::Instrumentation
- WaterDrop::Instrumentation::Callbacks
- WaterDrop::Instrumentation::Callbacks::Delivery
- WaterDrop::Instrumentation::Callbacks::Error
- WaterDrop::Instrumentation::Callbacks::OauthbearerTokenRefresh
- WaterDrop::Instrumentation::Callbacks::Statistics
- WaterDrop::Instrumentation::LoggerListener
- WaterDrop::Instrumentation::Monitor
- WaterDrop::Instrumentation::Notifications
- WaterDrop::Instrumentation::Vendors
- WaterDrop::Instrumentation::Vendors::Datadog
- WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
- WaterDrop::Middleware
- WaterDrop::Producer
- WaterDrop::Producer::Async
- WaterDrop::Producer::Buffer
- WaterDrop::Producer::Builder
- WaterDrop::Producer::Status
- WaterDrop::Producer::Sync
- WaterDrop::Producer::Transactions
- WaterDrop::Producer::Variant
Methods
- ::gem_root — WaterDrop
- ::new — WaterDrop::Clients::Buffered
- ::new — WaterDrop::Clients::Dummy
- ::new — WaterDrop::Clients::Dummy::Handle
- ::new — WaterDrop::Contracts::Message
- ::new — WaterDrop::Errors::ProduceManyError
- ::new — WaterDrop::Helpers::Counter
- ::new — WaterDrop::Instrumentation::Callbacks::Delivery
- ::new — WaterDrop::Instrumentation::Callbacks::Error
- ::new — WaterDrop::Instrumentation::Callbacks::OauthbearerTokenRefresh
- ::new — WaterDrop::Instrumentation::Callbacks::Statistics
- ::new — WaterDrop::Instrumentation::LoggerListener
- ::new — WaterDrop::Instrumentation::Monitor
- ::new — WaterDrop::Instrumentation::Notifications
- ::new — WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
- ::new — WaterDrop::Middleware
- ::new — WaterDrop::Producer
- ::new — WaterDrop::Producer::Status
- ::new — WaterDrop::Producer::Variant
- ::new — WaterDrop::Clients::Rdkafka
- #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
- #build_error — WaterDrop::Instrumentation::Callbacks::Delivery
- #call — WaterDrop::Instrumentation::Callbacks::Delivery
- #call — WaterDrop::Instrumentation::Callbacks::Error
- #call — WaterDrop::Instrumentation::Callbacks::OauthbearerTokenRefresh
- #call — WaterDrop::Instrumentation::Callbacks::Statistics
- #call — WaterDrop::Producer::Builder
- #client — WaterDrop::Producer
- #close — WaterDrop::Producer
- #close! — WaterDrop::Producer
- #commit_transaction — WaterDrop::Clients::Buffered
- #create_result — WaterDrop::Clients::Dummy::Handle
- #current_variant — WaterDrop::Producer
- #debug — WaterDrop::Instrumentation::LoggerListener
- #decrement — WaterDrop::Helpers::Counter
- #default? — WaterDrop::Producer::Variant
- #ensure_active! — WaterDrop::Producer
- #error — WaterDrop::Instrumentation::LoggerListener
- #flush — WaterDrop::Producer::Buffer
- #flush_async — WaterDrop::Producer::Buffer
- #flush_sync — WaterDrop::Producer::Buffer
- #idempotent? — WaterDrop::Producer
- #increment — WaterDrop::Helpers::Counter
- #info — WaterDrop::Instrumentation::LoggerListener
- #instrument_acknowledged — WaterDrop::Instrumentation::Callbacks::Delivery
- #instrument_error — WaterDrop::Instrumentation::Callbacks::Delivery
- #instrument_purged — WaterDrop::Instrumentation::Callbacks::Delivery
- #log_messages? — WaterDrop::Instrumentation::LoggerListener
- #merge_kafka_defaults! — WaterDrop::Config
- #messages_for — WaterDrop::Clients::Buffered
- #method_missing — WaterDrop::Clients::Dummy
- #middleware — WaterDrop::Producer
- #namespaced_metric — WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
- #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::Buffered
- #produce — WaterDrop::Clients::Dummy
- #produce — WaterDrop::Producer
- #produce_async — WaterDrop::Producer::Async
- #produce_many_async — WaterDrop::Producer::Async
- #produce_many_sync — WaterDrop::Producer::Sync
- #produce_sync — WaterDrop::Producer::Sync
- #purge — WaterDrop::Producer
- #report_message — WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
- #report_metric — WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
- #reset — WaterDrop::Clients::Buffered
- #respond_to_missing? — WaterDrop::Clients::Dummy
- #run — WaterDrop::Middleware
- #run_many — WaterDrop::Middleware
- #send_offsets_to_transaction — WaterDrop::Clients::Buffered
- #setup — WaterDrop::Config
- #setup — WaterDrop::Instrumentation::Vendors::Datadog::MetricsListener
- #setup — WaterDrop::Producer
- #to_h — WaterDrop::Producer::Variant
- #to_s — WaterDrop::Producer::Status
- #transaction — WaterDrop::Producer::Transactions
- #transaction? — WaterDrop::Producer::Transactions
- #transaction_mark_as_consumed — WaterDrop::Producer::Transactions
- #transactional? — WaterDrop::Producer::Transactions
- #transactional_instrument — WaterDrop::Producer::Transactions
- #transactional_reload_client_if_needed — WaterDrop::Producer::Transactions
- #validate_message! — WaterDrop::Producer
- #variant — WaterDrop::Producer
- #wait — WaterDrop::Clients::Dummy::Handle
- #wait — WaterDrop::Producer
- #with — WaterDrop::Producer
- #with_transaction_if_transactional — WaterDrop::Producer::Transactions
- #with_transactional_error_handling — WaterDrop::Producer::Transactions