class

Aquamarine::Client

Inherits Reference < Object

Constructors

new(repository : Aquamarine::InMemoryRepository)
Source

Instance methods

append(events : Array(Aquamarine::Event), stream_name : String | Nil = GLOBAL_STREAM)
Source
append(event : Aquamarine::Event, stream_name : String | Nil = GLOBAL_STREAM)
Source
delete_stream(name)
Source
link(event_ids, stream_name)
Source
mapper
Source
publish(event : Aquamarine::Event)
Source
read
Source
read_event(event_id : UUID)
Source