class Fluent::DebugAgentInput
Public Class Methods
new()
click to toggle source
Calls superclass method
Fluent::Input.new
# File lib/fluent/plugin/in_debug_agent.rb, line 22 def initialize require 'drb/drb' super end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
Fluent::Input#configure
# File lib/fluent/plugin/in_debug_agent.rb, line 33 def configure(conf) super end
shutdown()
click to toggle source
# File lib/fluent/plugin/in_debug_agent.rb, line 49 def shutdown @server.stop_service if @server end
start()
click to toggle source
# File lib/fluent/plugin/in_debug_agent.rb, line 37 def start if @unix_path require 'drb/unix' uri = "drbunix:#{@unix_path}" else uri = "druby://#{@bind}:#{@port}" end log.info "listening dRuby", :uri => uri, :object => @object obj = eval(@object) @server = DRb::DRbServer.new(uri, obj) end