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