Module: WaterDrop

Defined in:
lib/water_drop.rb,
lib/water_drop/config.rb,
lib/water_drop/errors.rb,
lib/water_drop/version.rb,
lib/water_drop/contracts.rb,
lib/water_drop/base_producer.rb,
lib/water_drop/sync_producer.rb,
lib/water_drop/async_producer.rb,
lib/water_drop/config_applier.rb,
lib/water_drop/contracts/config.rb,
lib/water_drop/instrumentation/monitor.rb,
lib/water_drop/contracts/message_options.rb,
lib/water_drop/instrumentation/stdout_listener.rb

Overview

WaterDrop library

Defined Under Namespace

Modules: ConfigApplier, Contracts, Errors, Instrumentation Classes: AsyncProducer, BaseProducer, Config, SyncProducer

Constant Summary collapse

VERSION =

Current WaterDrop version

'1.3.3'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.logger ⇒ Object

Returns the value of attribute logger.



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

def logger
  @logger
end

Class Method Details

.config ⇒ WaterDrop::Config

Returns config instance.

Returns:



30
31
32
 
# File 'lib/water_drop.rb', line 30

def config
  Config.config
end

.gem_root ⇒ String

Returns root path of this gem.

Returns:

  • (String) —

    root path of this gem



40
41
42
 
# File 'lib/water_drop.rb', line 40

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

.monitor ⇒ ::WaterDrop::Monitor

Returns monitor that we want to use.

Returns:

  • (::WaterDrop::Monitor) —

    monitor that we want to use



35
36
37
 
# File 'lib/water_drop.rb', line 35

def monitor
  config.monitor
end

.setup(&block) ⇒ Object

Sets up the whole configuration

Parameters:

  • block (Block) —

    configuration block



23
24
25
26
27
 
# File 'lib/water_drop.rb', line 23

def setup(&block)
  Config.setup(&block)
  DeliveryBoy.logger = self.logger = config.logger
  ConfigApplier.call(DeliveryBoy.config, Config.config.to_h)
end