class Fluent::Plugin::NaisRemapKubernetesFilter
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_nais_remap_kubernetes.rb, line 9 def configure(conf) super end
filter(tag, time, record)
click to toggle source
# File lib/fluent/plugin/filter_nais_remap_kubernetes.rb, line 13 def filter(tag, time, record) record["category"] = record.delete("stream") if record.has_key?("stream") if record["docker"].is_a?(Hash) record["container"] = record["docker"]["container_id"] record.delete("docker") end if record["kubernetes"].is_a?(Hash) record["host"] = record["kubernetes"]["host"] record["namespace"] = record["kubernetes"]["namespace_name"] record["application"] = record["kubernetes"]["container_name"] record["pod"] = record["kubernetes"]["pod_name"] if record["kubernetes"]["labels"].is_a?(Hash) unless @labels.nil? || @labels == "" @labels.split(',').each {|label| if record["kubernetes"]["labels"].has_key?(label) && !record["kubernetes"]["labels"][label].nil? && record["kubernetes"]["labels"][label] != "" record[label] = record["kubernetes"]["labels"][label] end } end end record.delete("kubernetes") end record end