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.
14 15 16 17 18 19 20 21 22 |
# File 'lib/steno/sink/fluentd.rb', line 14 def initialize(opts = {}) super @fluentd = Fluent::Logger::FluentLogger.new(opts[:tag_prefix] || "steno", :host => opts[:host] || "127.0.0.1", :port => opts[:port] || 24224, :buffer_limit => opts[:buffer_limit] || Fluent::Logger::FluentLogger::BUFFER_LIMIT) @io_lock = Mutex.new end |