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