Class: Fluent::Plugin::ObsoletePluginsFilter

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

Constant Summary collapse

PLUGINS_JSON_URL = 
"https://raw.githubusercontent.com/fluent/fluentd-website/master/scripts/plugins.json"

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/fluent/plugin/filter_obsolete_plugins.rb', line 35

def configure(conf)
  super

  obsolete_plugins =
    if @obsolete_plugins_yml
      ObsoletePluginsUtils.obsolete_plugins_from_yaml(@obsolete_plugins_yml, timeout: @timeout)
    else
      ObsoletePluginsUtils.obsolete_plugins_from_json(@plugins_json, timeout: @timeout)
    end

  ObsoletePluginsUtils.notify(log, obsolete_plugins, raise_error: @raise_error)
rescue Fluent::ConfigError
  raise
rescue => e
  log.info("Failed to notify obsolete plugins", error: e)
end

#filter(tag, time, record) ⇒ Object 



52
53
54
 
# File 'lib/fluent/plugin/filter_obsolete_plugins.rb', line 52

def filter(tag, time, record)
  record
end