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
retry_stream[R]
Public Class Methods
new(retry_stream)
click to toggle source
# File lib/fluent/plugin/out_elasticsearch2.rb, line 41 def initialize(retry_stream) @retry_stream = retry_stream end