Exception: Fluent::Plugin::OpenSearchOutput::RetryStreamError

Inherits:

StandardError

Object
StandardError
Fluent::Plugin::OpenSearchOutput::RetryStreamError

Defined in:: lib/fluent/plugin/out_opensearch.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.



76
77
78

# File 'lib/fluent/plugin/out_opensearch.rb', line 76

def initialize(retry_stream)
  @retry_stream = retry_stream
end

Instance Attribute Details

#retry_stream ⇒ `Object` (readonly)

Returns the value of attribute retry_stream.



75
76
77

# File 'lib/fluent/plugin/out_opensearch.rb', line 75

def retry_stream
  @retry_stream
end