class Fluent::Compat::Output

Private Class Methods

new() click to toggle source
Calls superclass method Fluent::Plugin::Output.new
# File lib/fluent/compat/output.rb, line 167
def initialize
  super
  unless self.class.ancestors.include?(Fluent::Compat::CallSuperMixin)
    self.class.prepend Fluent::Compat::CallSuperMixin
  end
end

Private Instance Methods

configure(conf) click to toggle source
Calls superclass method Fluent::Plugin::Output#configure
# File lib/fluent/compat/output.rb, line 174
def configure(conf)
  ParserUtils.convert_parser_conf(conf)
  FormatterUtils.convert_formatter_conf(conf)

  super
end
process(tag, es) click to toggle source
# File lib/fluent/compat/output.rb, line 163
def process(tag, es)
  emit(tag, es, NULL_OUTPUT_CHAIN)
end
start() click to toggle source
Calls superclass method Fluent::Plugin::Output#start
# File lib/fluent/compat/output.rb, line 181
def start
  super

  if instance_variable_defined?(:@formatter) && @inject_config
    unless @formatter.class.ancestors.include?(Fluent::Compat::HandleTagAndTimeMixin)
      if @formatter.respond_to?(:owner) && !@formatter.owner
        @formatter.owner = self
        @formatter.singleton_class.prepend FormatterUtils::InjectMixin
      end
    end
  end
end
support_in_v12_style?(feature) click to toggle source
# File lib/fluent/compat/output.rb, line 154
def support_in_v12_style?(feature)
  case feature
  when :synchronous    then true
  when :buffered       then false
  when :delayed_commit then false
  when :custom_format  then false
  end
end