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