Contents

require 'json'

class KubernetesAnnotationsTagAppender
  attr_reader :annotations

  def initialize(annotations)
    @annotations = annotations
  end

  def append(tag, data, container_name)
    matches = annotations.select do | annotation |
      json = data[annotation] || "[]"
      JSON.parse(json)&.include? container_name
    end

    return ([tag] + matches).join(".")
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
fluent-plugin-append-kubernetes-annotations-to-tag-0.1.0.pre.4	lib/kubernetes_annotations_tag_appender.rb
fluent-plugin-append-kubernetes-annotations-to-tag-0.1.0.pre.3	lib/kubernetes_annotations_tag_appender.rb
fluent-plugin-append-kubernetes-annotations-to-tag-0.1.0.pre.2	lib/kubernetes_annotations_tag_appender.rb