Exception: Fluent::Plugin::ElasticsearchOutput::RetryStreamError

Inherits:
StandardError
  • Object
show all
Defined in:
lib/fluent/plugin/out_elasticsearch.rb

Overview

RetryStreamError privides a stream to be put back in the pipeline for cases where a bulk request failed (e.g some records succeed while others failed)

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#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

Instance Attribute Details

#retry_streamObject (readonly)

Returns the value of attribute retry_stream.



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

def retry_stream
  @retry_stream
end