lib/fluent/plugin/out_woothee.rb in fluent-plugin-woothee-0.1.0 vs lib/fluent/plugin/out_woothee.rb in fluent-plugin-woothee-0.1.1
- old
+ new
@@ -20,23 +20,19 @@
config_param :merge_agent_info, :bool, :default => false
config_param :out_key_name, :string, :default => 'agent_name'
config_param :out_key_category, :string, :default => 'agent_category'
config_param :out_key_os, :string, :default => 'agent_os'
+ config_param :out_key_os_version, :string, :default => nil # supress output
config_param :out_key_version, :string, :default => nil # supress output
config_param :out_key_vendor, :string, :default => nil # supress output
def initialize
super
require 'woothee'
end
- # Define `log` method for v0.10.42 or earlier
- unless method_defined?(:log)
- define_method("log") { $log }
- end
-
def configure(conf)
super
# tag ->
if not @tag and not @remove_prefix and not @add_prefix
@@ -124,9 +120,10 @@
record = record.merge({
@out_key_name => parsed[Woothee::ATTRIBUTE_NAME],
@out_key_category => parsed[Woothee::ATTRIBUTE_CATEGORY].to_s,
@out_key_os => parsed[Woothee::ATTRIBUTE_OS]
})
+ record[@out_key_os_version] = parsed[Woothee::ATTRIBUTE_OS_VERSION] if @out_key_os_version
record[@out_key_version] = parsed[Woothee::ATTRIBUTE_VERSION] if @out_key_version
record[@out_key_vendor] = parsed[Woothee::ATTRIBUTE_VENDOR] if @out_key_vendor
end
Fluent::Engine.emit(tag, time, record)
end