Class: Fluent::DockerMetadataFilter

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

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ DockerMetadataFilter

Returns a new instance of DockerMetadataFilter.



35
36
37
 
# File 'lib/fluent/plugin/filter_docker_metadata.rb', line 35

def initialize
  super
end

Class Method Details

.get_metadata(container_id) ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/fluent/plugin/filter_docker_metadata.rb', line 27

def self.get_metadata(container_id)
  begin
    Docker::Container.get(container_id).info
  rescue Docker::Error::NotFoundError
    nil
  end
end

Instance Method Details

#configure(conf) ⇒ Object 



39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/fluent/plugin/filter_docker_metadata.rb', line 39

def configure(conf)
  super

  require 'docker'
  require 'json'
  require 'lru_redux'

  Docker.url = @docker_url

  @cache = LruRedux::ThreadSafeCache.new(@cache_size)
  @container_id_regexp_compiled = Regexp.compile(@container_id_regexp)
end

#filter_stream(tag, es) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/fluent/plugin/filter_docker_metadata.rb', line 52

def filter_stream(tag, es)
  new_es = es
  container_id = tag.match(@container_id_regexp_compiled)
  if container_id && container_id[0]
    container_id = container_id[0]
    metadata = @cache.getset(container_id){DockerMetadataFilter.get_metadata(container_id)}

    if metadata
      new_es = MultiEventStream.new

      es.each {|time, record|
        record['docker'] = {
          'id' => metadata['id'],
          'name' => metadata['Name'][1..-1],
          'container_hostname' => metadata['Config']['Hostname'],
          'image' => metadata['Config']['Image'],
          'image_id' => metadata['Image'],
          'labels' => metadata['Config']['Labels']
        }
        new_es.add(time, record)
      }
    end
  end

  return new_es
end