class Fluent::Plugin::KinesisOutput::SkipRecordError
Public Class Methods
new(message, record)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/kinesis.rb, line 30 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
Public Instance Methods
to_s()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/kinesis.rb, line 39 def to_s super + ": " + @record_message end