Exception: Fluent::KinesisOutput::SkipRecordError
- Inherits:
-
StandardError
- Object
- StandardError
- Fluent::KinesisOutput::SkipRecordError
- Defined in:
- lib/fluent/plugin/kinesis.rb
Direct Known Subclasses
ExceedMaxRecordSizeError, InvalidRecordError, KeyNotFoundError
Instance Method Summary collapse
-
#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.
32 33 34 35 36 37 38 39 |
# File 'lib/fluent/plugin/kinesis.rb', line 32 def initialize(, record) super @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
41 42 43 |
# File 'lib/fluent/plugin/kinesis.rb', line 41 def to_s super + ": " + @record_message end |