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

Inherits:
StandardError
  • Object
show all
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

Instance Method Summary collapse

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_streamObject (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