Class: Fluent::Plugin::ObsoletePluginsFilter

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

Constant Summary collapse

OBSOLETE_PLUGINS_URL = 
"https://raw.githubusercontent.com/fluent/fluentd-website/master/scripts/obsolete-plugins.yml"

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/fluent/plugin/filter_obsolete_plugins.rb', line 32

def configure(conf)
  super

  @obsolete_plugins = open(@obsolete_plugins_yml) do |io|
    YAML.safe_load(io.read)
  end

  obsolete_plugins = Gem.loaded_specs.keys & @obsolete_plugins.keys
  obsolete_plugins.each do |name|
    log.warn("#{name} is obsolete: #{@obsolete_plugins[name].chomp}")
  end
  if @raise_error && !obsolete_plugins.empty?
    raise Fluent::ConfigError, "Detected obsolete plugins"
  end
end

#filter(tag, time, record) ⇒ Object 



48
49
50
 
# File 'lib/fluent/plugin/filter_obsolete_plugins.rb', line 48

def filter(tag, time, record)
  record
end