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