# # Fluentd # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # require 'fluent/formatter' require 'fluent/config' module Fluent module Test class FormatterTestDriver def initialize(klass_or_str, proc=nil, &block) if klass_or_str.is_a?(Class) if block # Create new class for test w/ overwritten methods # klass.dup is worse because its ancestors does NOT include original class name klass_or_str = Class.new(klass_or_str) klass_or_str.module_eval(&block) end @instance = klass_or_str.new elsif klass_or_str.is_a?(String) @instance = TextFormatter::TEMPLATE_REGISTRY.lookup(klass_or_str).call else @instance = klass_or_str end @config = Config.new end attr_reader :instance, :config def configure(conf) case conf when Fluent::Config::Element @config = conf when String @config = Config.parse(conf, 'fluent.conf') when Hash @config = Config::Element.new('ROOT', '', conf, []) else raise "Unknown type... #{conf}" end @instance.configure(@config) self end def format(tag, time, record) @instance.format(tag, time, record) end end end end