class Aquamarine::InMemoryRepository

• Aquamarine::InMemoryRepository
• Reference
• Object

Defined in:

aquamarine/in_memory_repository.cr

Constructors

• .new

Instance Method Summary

• #add_to_stream(event, stream, include_global)
• #append(event, stream, include_global)
• #append(event, include_global)
• #append_to_stream(events : Array(Aquamarine::SerializedRecord), stream)
• #append_to_stream(event, stream)
• #delete_stream(stream)
• #global : Array(Aquamarine::SerializedRecord)
• #link_to_stream(event_ids : Array(UUID), stream)
• #normalize_to_array(event)
• #read(query)
• #read_event(event_id : UUID)
• #stream_of(name)
• #streams : Hash(String | Symbol | UUID, Array(Aquamarine::Event | Aquamarine::SerializedRecord))

Constructor Detail

Instance Method Detail