uken/fluent-plugin-elasticsearch

require 'fluent/error'

class Fluent::Plugin::ElasticsearchError
  class RetryableOperationExhaustedFailure < Fluent::UnrecoverableError; end
end