Exception: Fluent::ElasticsearchOutput::RetryStreamError

Inherits:

StandardError

Object
StandardError
Fluent::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`



26
27
28

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

def initialize(retry_stream)
  @retry_stream = retry_stream
end

Instance Attribute Details

#retry_stream ⇒ `Object` (readonly)

Returns the value of attribute retry_stream.



25
26
27

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

def retry_stream
  @retry_stream
end