class Aggregates::StorageBackend

The StorageBackend class is responsible for providing an interface for storing Domain messages such as events and commands.

Public Instance Methods

load_commands_by_aggregate_id(_aggregate_id) click to toggle source
# File lib/aggregates/storage_backend.rb, line 21
def load_commands_by_aggregate_id(_aggregate_id)
  raise NotImplementedError
end
load_events_by_aggregate_id(_aggregate_id) click to toggle source
# File lib/aggregates/storage_backend.rb, line 17
def load_events_by_aggregate_id(_aggregate_id)
  raise NotImplementedError
end
store_command(_command) click to toggle source
# File lib/aggregates/storage_backend.rb, line 13
def store_command(_command)
  raise NotImplementedError
end
store_event(_event) click to toggle source
# File lib/aggregates/storage_backend.rb, line 9
def store_event(_event)
  raise NotImplementedError
end

Protected Instance Methods

json_string_to_message(json_string) click to toggle source
# File lib/aggregates/storage_backend.rb, line 31
def json_string_to_message(json_string)
  JSON.parse json_string, create_additions: true
end
message_to_json_string(message) click to toggle source
# File lib/aggregates/storage_backend.rb, line 27
def message_to_json_string(message)
  JSON.dump message.to_json
end