class Sequent::Core::EventStream

Attributes

aggregate_id[RW]
aggregate_type[RW]
snapshot_threshold[RW]
stream_record_id[RW]

Public Class Methods

new(aggregate_type:, aggregate_id:, snapshot_threshold: nil, stream_record_id: nil) click to toggle source
# File lib/sequent/core/stream_record.rb, line 10
def initialize(aggregate_type:, aggregate_id:, snapshot_threshold: nil, stream_record_id: nil)
  @aggregate_type = aggregate_type
  @aggregate_id = aggregate_id
  @snapshot_threshold = snapshot_threshold
  @stream_record_id = stream_record_id
end