class Aquamarine::Client

Defined in:

aquamarine/client.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(repository : Aquamarine::InMemoryRepository) #

[View source]

Instance Method Detail

def append(events : Array(Aquamarine::Event), stream_name : String | Nil = GLOBAL_STREAM) #

[View source]
def append(event : Aquamarine::Event, stream_name : String | Nil = GLOBAL_STREAM) #

[View source]
def delete_stream(name) #

[View source]
def link(event_ids, stream_name) #

[View source]

[View source]
def publish(event : Aquamarine::Event) #

[View source]
def read #

[View source]
def read_event(event_id : UUID) #

[View source]