Sha256: 0f9f660e806b7bcb95c7b4b29f70845c0c305f995287417d87a5f013b3ec1203
Contents?: true
Size: 1.83 KB
Versions: 25
Compression:
Stored size: 1.83 KB
Contents
#
# 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
Version data entries
25 entries across 25 versions & 2 rubygems