class Replay::Rails::ActiveRecordEventStore
Public Class Methods
archive(stream_id)
click to toggle source
# File lib/replay/rails.rb, line 62 def self.archive(stream_id) live_events = Arel::Table.new(:domain_events) end
event_stream(stream_id)
click to toggle source
# File lib/replay/rails.rb, line 70 def self.event_stream(stream_id) Event.event_stream(stream_id) end
published(envelope)
click to toggle source
# File lib/replay/rails.rb, line 66 def self.published(envelope) Event.create(stream_id: envelope.stream_id, event_type: envelope.type, data: envelope.event.to_json, envelope_data: envelope.metadata.to_json) end