Module: Fluent::PluginHelper::ServiceDiscovery

Includes:
Timer
Defined in:
lib/fluent/plugin_helper/service_discovery.rb,
lib/fluent/plugin_helper/service_discovery/manager.rb,
lib/fluent/plugin_helper/service_discovery/round_robin_balancer.rb

Defined Under Namespace

Modules: ServiceDiscoveryParams Classes: Manager, RoundRobinBalancer

Constant Summary

Constants included from EventLoop

EventLoop::EVENT_LOOP_RUN_DEFAULT_TIMEOUT, EventLoop::EVENT_LOOP_SHUTDOWN_TIMEOUT

Constants included from Thread

Thread::THREAD_DEFAULT_WAIT_SECONDS, Thread::THREAD_SHUTDOWN_HARD_TIMEOUT_IN_TESTS

Instance Attribute Summary

Attributes included from Timer

#_timers

Attributes included from EventLoop

#_event_loop

Attributes included from Thread

#_threads

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Timer

#initialize, #stop, #terminate, #timer_execute, #timer_running?

Methods included from EventLoop

#after_shutdown, #close, #event_loop_attach, #event_loop_detach, #event_loop_running?, #event_loop_wait_until_start, #event_loop_wait_until_stop, #initialize, #shutdown, #terminate

Methods included from Thread

#after_shutdown, #close, #initialize, #stop, #terminate, #thread_create, #thread_current_running?, #thread_exist?, #thread_running?, #thread_started?, #thread_wait_until_start, #thread_wait_until_stop

Class Method Details

.included(mod) ⇒ Object 



25
26
27
 
# File 'lib/fluent/plugin_helper/service_discovery.rb', line 25

def self.included(mod)
  mod.include ServiceDiscoveryParams
end

Instance Method Details

#start ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/fluent/plugin_helper/service_discovery.rb', line 29

def start
  unless @discovery_manager
    log.warn('There is no discovery_manager. skip start them')
    super
    return
  end

  @discovery_manager.start
  unless @discovery_manager.static_config?
    timer_execute(@_plugin_helper_service_discovery_title, @_plugin_helper_service_discovery_iterval) do
      @discovery_manager.run_once
    end
  end

  super
end