class Fluent::Plugin::ElasticsearchOutput::RetryStreamError
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)
Attributes
Public Class Methods
Source
# File lib/fluent/plugin/out_elasticsearch.rb, line 52 def initialize(retry_stream) @retry_stream = retry_stream end