Class: Journaled::DeliveryJob::KinesisRecord

Inherits:

Struct

Object
Struct
Journaled::DeliveryJob::KinesisRecord

show all

Defined in:: app/jobs/journaled/delivery_job.rb

Instance Method Summary collapse

#initialize(serialized_event:, partition_key:, stream_name:) ⇒ KinesisRecord constructor

A new instance of KinesisRecord.
#to_h ⇒ Object

Constructor Details

#initialize(serialized_event:, partition_key:, stream_name:) ⇒ `KinesisRecord`

Returns a new instance of KinesisRecord.



37
38
39

# File 'app/jobs/journaled/delivery_job.rb', line 37

def initialize(serialized_event:, partition_key:, stream_name:)
  super(serialized_event: serialized_event, partition_key: partition_key, stream_name: stream_name)
end

Instance Method Details

#to_h ⇒ `Object`



41
42
43

# File 'app/jobs/journaled/delivery_job.rb', line 41

def to_h
  { stream_name: stream_name, data: serialized_event, partition_key: partition_key }
end