Module: Fluent::Plugin::FeatureAvailabilityChecker

Defined in:

lib/fluent/plugin.rb

Instance Method Summary

• #configure(conf) ⇒ Object

Instance Method Details

#configure(conf) ⇒ Object

# File 'lib/fluent/plugin.rb', line 163

def configure(conf)
  super

  # extend plugin instance by this module
  # to run this check after all #configure methods of plugins and plugin helpers
  sysconf = if self.respond_to?(:owner) && owner.respond_to?(:system_config)
              owner.system_config
            elsif self.respond_to?(:system_config)
              self.system_config
            else
              nil
            end

  if sysconf && sysconf.workers > 1 && !self.multi_workers_ready?
    type = Fluent::Plugin.lookup_type_from_class(self.class)
    raise Fluent::ConfigError, "Plugin '#{type}' does not support multi workers configuration (#{self.class})"
  end
end