class LogStashLogger::Device::Kinesis

Public Instance Methods

get_response_records(resp) click to toggle source
# File lib/logstash-logger/device/kinesis.rb, line 38
def get_response_records(resp)
  resp.records
end
is_successful_response(resp) click to toggle source
# File lib/logstash-logger/device/kinesis.rb, line 34
def is_successful_response(resp)
  resp.failed_record_count == 0
end
put_records(records) click to toggle source
# File lib/logstash-logger/device/kinesis.rb, line 27
def put_records(records)
  @io.put_records({
    records: records,
    stream_name: @stream
  })
end
transform_message(message) click to toggle source
# File lib/logstash-logger/device/kinesis.rb, line 20
def transform_message(message)
  {
    data: message,
    partition_key: SecureRandom.uuid
  }
end