Module: WaterDrop::Polling

Defined in:
lib/waterdrop/polling.rb,
lib/waterdrop/polling/latch.rb,
lib/waterdrop/polling/state.rb,
lib/waterdrop/polling/config.rb,
lib/waterdrop/polling/poller.rb,
lib/waterdrop/polling/queue_pipe.rb

Overview

Namespace for FD-based polling components Contains the global Poller singleton and State class for managing producer polling

Defined Under Namespace

Classes: Config, Latch, Poller, QueuePipe, State

Class Method Summary collapse

Class Method Details

.setup(&block) {|config| ... } ⇒ Object

Configures the global FD poller settings

Examples:

Configure before creating any producers

WaterDrop::Polling.setup do |config|
  config.thread_priority = -1
  config.poll_timeout = 500
end

Yield Parameters:

  • config (Karafka::Core::Configurable::Node) —

    config node



17
18
19
 
# File 'lib/waterdrop/polling.rb', line 17

def setup(&block)
  Config.setup(&block)
end