Class: Fluent::Plugin::ObsoletePluginsInput

Inherits:
Input
  • Object
show all
Defined in:
lib/fluent/plugin/in_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 



22
23
24
25
26
27
28
29
30
31
 
# File 'lib/fluent/plugin/in_obsolete_plugins.rb', line 22

def configure(conf)
  super

  obsolete_plugins = ObsoletePluginsUtils.obsolete_plugins_from_json(@plugins_json, timeout: @timeout)
  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

#multi_workers_ready? ⇒ Boolean

Returns:

  • (Boolean) 


18
19
20
 
# File 'lib/fluent/plugin/in_obsolete_plugins.rb', line 18

def multi_workers_ready?
  true
end