Module: WaterDrop

Defined in:
lib/waterdrop.rb,
lib/waterdrop/config.rb,
lib/waterdrop/errors.rb,
lib/waterdrop/version.rb,
lib/waterdrop/producer.rb,
lib/waterdrop/contracts.rb,
lib/waterdrop/middleware.rb,
lib/waterdrop/clients/dummy.rb,
lib/waterdrop/producer/sync.rb,
lib/waterdrop/producer/async.rb,
lib/waterdrop/clients/rdkafka.rb,
lib/waterdrop/helpers/counter.rb,
lib/waterdrop/producer/buffer.rb,
lib/waterdrop/producer/status.rb,
lib/waterdrop/clients/buffered.rb,
lib/waterdrop/contracts/config.rb,
lib/waterdrop/producer/builder.rb,
lib/waterdrop/producer/variant.rb,
lib/waterdrop/contracts/message.rb,
lib/waterdrop/contracts/variant.rb,
lib/waterdrop/producer/transactions.rb,
lib/waterdrop/instrumentation/monitor.rb,
lib/waterdrop/instrumentation/notifications.rb,
lib/waterdrop/contracts/transactional_offset.rb,
lib/waterdrop/instrumentation/callbacks/error.rb,
lib/waterdrop/instrumentation/logger_listener.rb,
lib/waterdrop/instrumentation/callbacks/delivery.rb,
lib/waterdrop/instrumentation/callbacks/statistics.rb,
lib/waterdrop/instrumentation/vendors/datadog/metrics_listener.rb,
lib/waterdrop/instrumentation/callbacks/oauthbearer_token_refresh.rb

Overview

WaterDrop library

Defined Under Namespace

Modules: Clients, Contracts, Errors, Helpers, Instrumentation Classes: Config, Middleware, Producer

Constant Summary collapse

AbortTransaction =

Alias so we can have a nicer API to abort transactions This makes referencing easier

Errors::AbortTransaction
VERSION =

Current WaterDrop version

'2.8.0'

Class Method Summary collapse

Class Method Details

.gem_root ⇒ String

Returns root path of this gem.

Returns:

  • (String) —

    root path of this gem



19
20
21
 
# File 'lib/waterdrop.rb', line 19

def gem_root
  Pathname.new(File.expand_path('..', __dir__))
end