Class: ActiveRecordStreams::Publishers::KinesisClient

Inherits:
Object
  • Object
show all
Defined in:
lib/active_record_streams/publishers/kinesis_client.rb

Instance Method Summary collapse

Instance Method Details

#publish(stream_name, partition_key, data, overrides = {}) ⇒ Object 



8
9
10
11
12
13
14
15
 
# File 'lib/active_record_streams/publishers/kinesis_client.rb', line 8

def publish(stream_name, partition_key, data, overrides = {})
  client.put_record(
    stream_name: stream_name,
    data: data,
    partition_key: partition_key,
    **overrides
  )
end