Sha256: 35b2de258a47a6848108fb44973b1046a96ec96a333047fc42974a660b5dd2df
Contents?: true
Size: 1.5 KB
Versions: 6
Compression:
Stored size: 1.5 KB
Contents
# encoding: utf-8
module LogStash module Filters
class SingleValueUpdate
class CoerceString
def call(source) source; end
end
class CoerceArray
def call(source) source.first.to_s; end
end
class CoerceOther
def call(source) source.to_s end
end
def initialize(field, destination, fallback, lookup)
@field = field
@destination = destination
@fallback = fallback
@use_fallback = !fallback.nil? # fallback is not nil, the user set a value in the config
@lookup = lookup
@coercers_table = {}
@coercers_table.default = CoerceOther.new
@coercers_table[String] = CoerceString.new
@coercers_table[Array] = CoerceArray.new
end
def test_for_inclusion(event, override)
# Skip translation in case @destination field already exists and @override is disabled.
return false if !override && event.include?(@destination)
event.include?(@field)
end
def update(event)
# If source field is array use first value and make sure source value is string
# source = Array(event.get(@field)).first.to_s
source = event.get(@field)
source = @coercers_table[source.class].call(source)
matched = [true, nil]
@lookup.fetch_strategy.fetch(source, matched)
if matched.first
event.set(@destination, matched.last)
elsif @use_fallback
event.set(@destination, event.sprintf(@fallback))
matched[0] = true
end
return matched.first
end
end
end end
Version data entries
6 entries across 6 versions & 1 rubygems