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