Class: Steno::Sink::Fluentd
Overview
and fluent-logger at github.com/fluent/fluent-logger-ruby
Instance Attribute Summary
Attributes inherited from Base
Instance Method Summary collapse
- #add_record(record) ⇒ Object
- #flush ⇒ Object
-
#initialize(opts = {}) ⇒ Fluentd
constructor
A new instance of Fluentd.
Constructor Details
#initialize(opts = {}) ⇒ Fluentd
Returns a new instance of Fluentd.
13 14 15 16 17 18 19 20 21 |
# File 'lib/steno/sink/fluentd.rb', line 13 def initialize(opts = {}) super @fluentd = Fluent::Logger::FluentLogger.new(opts[:tag_prefix] || 'steno', host: opts[:host] || '127.0.0.1', port: opts[:port] || 24_224, buffer_limit: opts[:buffer_limit] || Fluent::Logger::FluentLogger::BUFFER_LIMIT) @io_lock = Mutex.new end |