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 |