class Fluent::Compat::Output
def configure(conf)
def configure(conf) ParserUtils.convert_parser_conf(conf) FormatterUtils.convert_formatter_conf(conf) super end
def initialize
def initialize super unless self.class.ancestors.include?(Fluent::Compat::CallSuperMixin) self.class.prepend Fluent::Compat::CallSuperMixin end end
def process(tag, es)
def process(tag, es) emit(tag, es, NULL_OUTPUT_CHAIN) end
def start
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
def support_in_v12_style?(feature)
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