class Sequent::Core::StreamRecord
Public Instance Methods
Source
# File lib/sequent/core/stream_record.rb, line 39 def event_stream EventStream.new( aggregate_type:, aggregate_id:, events_partition_key:, unique_keys: aggregate_unique_keys.to_h { |key| [key.scope.to_sym, key.key] }, ) end
Source
# File lib/sequent/core/stream_record.rb, line 48 def event_stream=(data) self.aggregate_type = data.aggregate_type self.aggregate_id = data.aggregate_id self.events_partition_key = data.events_partition_key end