class Fluent::NorikraOutput
Public Instance Methods
client(opts={})
click to toggle source
# File lib/fluent/plugin/out_norikra.rb, line 57 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/out_norikra.rb, line 35 def configure(conf) super @host,@port = @norikra.split(':', 2) @port = @port.to_i if !@target_map_tag && @target_map_key.nil? && @target_string.nil? raise Fluent::ConfigError, 'target naming not specified (target_map_tag/target_map_key/target_string)' end conf.elements.each do |element| case element.name when 'default', 'target' # ignore: processed in OutputMixin else raise Fluent::ConfigError, "unknown configuration section name for this plugin: #{element.name}" end end setup_output(conf, false) # <query> disabled in <default> and <target TARGET> end
fetchable?()
click to toggle source
# File lib/fluent/plugin/out_norikra.rb, line 75 def fetchable? true end
shutdown()
click to toggle source
# File lib/fluent/plugin/out_norikra.rb, line 70 def shutdown stop_output shutdown_output end
start()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_norikra.rb, line 65 def start super start_output end