Class: LogStashLogger::Device::Firehose
- Inherits:
-
AwsStream
- Object
- Base
- Connectable
- AwsStream
- LogStashLogger::Device::Firehose
- Defined in:
- lib/logstash-logger/device/firehose.rb
Constant Summary
Constants inherited from AwsStream
Instance Attribute Summary
Attributes inherited from AwsStream
Attributes inherited from Connectable
Attributes inherited from Base
Instance Method Summary collapse
- #get_response_records(resp) ⇒ Object
- #is_successful_response(resp) ⇒ Object
- #put_records(records) ⇒ Object
- #transform_message(message) ⇒ Object
Methods inherited from AwsStream
#close!, #connect, #initialize, #with_connection, #write_batch, #write_one
Methods inherited from Connectable
#close, #connect, #connected?, #flush, #initialize, #on_full_buffer_receive, #reconnect, #reset, #to_io, #with_connection, #write, #write_batch, #write_one
Methods included from Buffer
#buffer_flush, #buffer_full?, #buffer_initialize, #buffer_receive, #reset_buffer
Methods inherited from Base
#close, #close!, #flush, #initialize, #reset, #to_io, #unrecoverable_error?, #write, #write_batch, #write_one
Constructor Details
This class inherits a constructor from LogStashLogger::Device::AwsStream
Instance Method Details
#get_response_records(resp) ⇒ Object
36 37 38 |
# File 'lib/logstash-logger/device/firehose.rb', line 36 def get_response_records(resp) resp.request_responses end |
#is_successful_response(resp) ⇒ Object
32 33 34 |
# File 'lib/logstash-logger/device/firehose.rb', line 32 def is_successful_response(resp) resp.failed_put_count == 0 end |
#put_records(records) ⇒ Object
25 26 27 28 29 30 |
# 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) ⇒ Object
19 20 21 22 23 |
# File 'lib/logstash-logger/device/firehose.rb', line 19 def () { data: } end |