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

Inherits:

StandardError

Object
StandardError
Fluent::Plugin::ElasticsearchOutput::RetryStreamError

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

#retry_stream ⇒ Object readonly

Returns the value of attribute retry_stream.

Instance Method Summary collapse

#initialize(retry_stream) ⇒ RetryStreamError constructor

A new instance of RetryStreamError.

Constructor Details

#initialize(retry_stream) ⇒ `RetryStreamError`

Returns a new instance of RetryStreamError.



51
52
53

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

def initialize(retry_stream)
  @retry_stream = retry_stream
end

Instance Attribute Details

#retry_stream ⇒ `Object` (readonly)

Returns the value of attribute retry_stream.



50
51
52

# File 'lib/fluent/plugin/out_elasticsearch.rb', line 50

def retry_stream
  @retry_stream
end