Contents

require 'fluent/output'

module Fluent
  class Fluent::AppendKubernetesLabelsToTag < Fluent::Output
    Fluent::Plugin.register_output('append_kubernetes_labels_to_tag', self)

    config_param :labels, :string

    def configure(conf)
      super

      @labels = conf['labels'].split(',')
    end

    def emit(tag, es, chain)
      es.each do |time, record|
        events(tag, time, record).each do |(tag, time, record)|
          router.emit(tag, time, record)
        end
      end

      chain.next

    rescue
      log.error "Failed to re-format docker record #{record}"
      # this seems to be a way to safely swallow records we don't know how to format
      ""
    end

    private

    def events(tag, time, record)
      [
        event(tag, time, record)
      ]
    end

    def event(tag, time, record)
      new_tag = if record.has_key?('kubernetes') && record['kubernetes'].has_key?('labels')
        kubernetes_labels_tag_appender.append(tag, record['kubernetes']['labels'])
      else
        tag
      end

      [
        new_tag,
        time,
        record
      ]
    end

    def kubernetes_labels_tag_appender
      @kubernetes_labels_tag_appender ||= KubernetesLabelsTagAppender.new(@labels)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-append-kubernetes-labels-to-tag-0.0.3.pre.alpha2	lib/fluent/plugin/out_append_kubernetes_labels_to_tag.rb