Class: Fluent::Plugin::NaisRemapKubernetesFilter

Inherits:
Filter
  • Object
show all
Defined in:
lib/fluent/plugin/filter_nais_remap_kubernetes.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



9
10
11
 
# File 'lib/fluent/plugin/filter_nais_remap_kubernetes.rb', line 9

def configure(conf)
  super
end

#filter(tag, time, record) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# 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