Exception: Fluent::Plugin::KinesisOutput::SkipRecordError

Inherits:

StandardError

• Object
• StandardError
• Fluent::Plugin::KinesisOutput::SkipRecordError

Defined in:

lib/fluent/plugin/kinesis.rb

Direct Known Subclasses

ExceedMaxRecordSizeError, InvalidRecordError, KeyNotFoundError

Instance Method Summary

• #initialize(message, record) ⇒ SkipRecordError constructor

  A new instance of SkipRecordError.

• #to_s ⇒ Object

Constructor Details

#initialize(message, record) ⇒ SkipRecordError

Returns a new instance of SkipRecordError.

# File 'lib/fluent/plugin/kinesis.rb', line 29

def initialize(message, record)
  super message
  @record_message = if record.is_a? Array
                      record.reverse.map(&:to_s).join(', ')
                    else
                      record.to_s
                    end
end

Instance Method Details

#to_s ⇒ Object

# File 'lib/fluent/plugin/kinesis.rb', line 38

def to_s
  super + ": " + @record_message
end