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