Class: Sequent::Core::EventStream

Inherits:
Object
  • Object
show all
Defined in:
lib/sequent/core/stream_record.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(aggregate_type:, aggregate_id:, snapshot_threshold: nil, stream_record_id: nil) ⇒ EventStream

Returns a new instance of EventStream.



10
11
12
13
14
15
 
# 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

Instance Attribute Details

#aggregate_id ⇒ Object

Returns the value of attribute aggregate_id.



8
9
10
 
# File 'lib/sequent/core/stream_record.rb', line 8

def aggregate_id
  @aggregate_id
end

#aggregate_type ⇒ Object

Returns the value of attribute aggregate_type.



8
9
10
 
# File 'lib/sequent/core/stream_record.rb', line 8

def aggregate_type
  @aggregate_type
end

#snapshot_threshold ⇒ Object

Returns the value of attribute snapshot_threshold.



8
9
10
 
# File 'lib/sequent/core/stream_record.rb', line 8

def snapshot_threshold
  @snapshot_threshold
end

#stream_record_id ⇒ Object

Returns the value of attribute stream_record_id.



8
9
10
 
# File 'lib/sequent/core/stream_record.rb', line 8

def stream_record_id
  @stream_record_id
end