class Fluent::Plugin::DebugAgentInput
Public Class Methods
new()
click to toggle source
Calls superclass method
Fluent::Compat::Input.new
# File lib/fluent/plugin/in_debug_agent.rb, line 23 def initialize require 'drb/drb' require 'fluent/plugin/file_util' super end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
Fluent::PluginLoggerMixin#configure
# File lib/fluent/plugin/in_debug_agent.rb, line 35 def configure(conf) super if system_config.workers > 1 @port += fluentd_worker_id end if @unix_path unless ::Fluent::FileUtil.writable?(@unix_path) raise Fluent::ConfigError, "in_debug_agent: `#{@unix_path}` is not writable" end end end
multi_workers_ready?()
click to toggle source
# File lib/fluent/plugin/in_debug_agent.rb, line 47 def multi_workers_ready? @unix_path.nil? end
shutdown()
click to toggle source
Calls superclass method
Fluent::Compat::Input#shutdown
# File lib/fluent/plugin/in_debug_agent.rb, line 65 def shutdown @server.stop_service if @server super end
start()
click to toggle source
Calls superclass method
Fluent::Compat::Input#start
# File lib/fluent/plugin/in_debug_agent.rb, line 51 def start super if @unix_path require 'drb/unix' uri = "drbunix:#{@unix_path}" else uri = "druby://#{@bind}:#{@port}" end log.info "listening dRuby", uri: uri, object: @object, worker: fluentd_worker_id obj = eval(@object) @server = DRb::DRbServer.new(uri, obj) end