workflow

v0.2.0

workflow v0.2.0 Workflow.Extreme.Adapter

Interface with the Extreme EventStore driver to save and read to EVENTSTORE. Note that the Engine supervisor starts the driver naming it as ‘EventStore’.

Summary

Types

aggregate_uuid()
batch()
batch_size()
read_event_batch_size()
reason()
start_version()

Functions

append_to_stream(stream_id, expected_version, pending_events)

Save a list of events to the stream

read_stream_forward(stream_id, start_version, read_event_batch_size)

Read stream, transforming messages in an event list ready for replay

Types

aggregate_uuid() 
aggregate_uuid() :: String.t
batch() 
batch() :: list
batch_size() 
batch_size() :: integer
read_event_batch_size() 
read_event_batch_size() :: integer
reason() 
reason() :: atom
start_version() 
start_version() :: String.t

Functions

append_to_stream(stream_id, expected_version, pending_events)

Save a list of events to the stream.

read_stream_forward(stream_id, start_version, read_event_batch_size)

Read stream, transforming messages in an event list ready for replay