class Fluent::NorikraInput
Public Instance Methods
client(opts={})
click to toggle source
# File lib/fluent/plugin/in_norikra.rb, line 59 def client(opts={}) Norikra::Client.new(@host, @port, { :connect_timeout => opts[:connect_timeout] || @connect_timeout, :send_timeout => opts[:send_timeout] || @send_timeout, :receive_timeout => opts[:receive_timeout] || @receive_timeout, }) end
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_norikra.rb, line 41 def configure(conf) super @host,@port = @norikra.split(':', 2) @port = @port.to_i conf.elements.each do |element| case element.name when 'fetch' # ignore: processed in InputMixin, and set @fetch_queue else raise Fluent::ConfigError, "unknown configuration section name for this plugin: #{element.name}" end end setup_input(conf) end
fetchable?()
click to toggle source
# File lib/fluent/plugin/in_norikra.rb, line 77 def fetchable? true end
shutdown()
click to toggle source
# File lib/fluent/plugin/in_norikra.rb, line 72 def shutdown stop_input shutdown_input end
start()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_norikra.rb, line 67 def start super start_input end