class LogStashLogger::Device::Firehose
Public Instance Methods
get_response_records(resp)
click to toggle source
# File lib/logstash-logger/device/firehose.rb, line 36 def get_response_records(resp) resp.request_responses end
is_successful_response(resp)
click to toggle source
# File lib/logstash-logger/device/firehose.rb, line 32 def is_successful_response(resp) resp.failed_put_count == 0 end
put_records(records)
click to toggle source
# File lib/logstash-logger/device/firehose.rb, line 25 def put_records(records) @io.put_record_batch({ records: records, delivery_stream_name: @stream }) end
transform_message(message)
click to toggle source
# File lib/logstash-logger/device/firehose.rb, line 19 def transform_message(message) { data: message } end