Method: Fluent::Plugin::ElasticsearchOutput::RetryStreamError#initialize

Defined in:
lib/fluent/plugin/out_elasticsearch.rb

#initialize(retry_stream) ⇒ RetryStreamError

Returns a new instance of RetryStreamError.



52
53
54
 
# File 'lib/fluent/plugin/out_elasticsearch.rb', line 52

def initialize(retry_stream)
  @retry_stream = retry_stream
end