# File lib/fluent/compat/output.rb, line 162 def initialize super unless self.class.ancestors.include?(Fluent::Compat::CallSuperMixin) self.class.prepend Fluent::Compat::CallSuperMixin end end
# File lib/fluent/compat/output.rb, line 169 def configure(conf) ParserUtils.convert_parser_conf(conf) FormatterUtils.convert_formatter_conf(conf) super end
# File lib/fluent/compat/output.rb, line 158 def process(tag, es) emit(tag, es, NULL_OUTPUT_CHAIN) end
# File lib/fluent/compat/output.rb, line 176 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
# File lib/fluent/compat/output.rb, line 149 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