Sha256: a12469fc9c5f5c6d918d125eab672744ebfcf6b2780bd7253f1bd6b39c3df07e
Contents?: true
Size: 1.95 KB
Versions: 289
Compression:
Stored size: 1.95 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'
require 'fluent/plugin'
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_name = klass_or_str.name
klass_or_str = Class.new(klass_or_str)
klass_or_str.define_singleton_method("name") { klass_name }
klass_or_str.module_eval(&block)
end
@instance = klass_or_str.new
elsif klass_or_str.is_a?(String)
@instance = Fluent::Plugin.new_formatter(klass_or_str)
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
289 entries across 289 versions & 8 rubygems