workflow v0.2.0 Workflow.Storage

Proxy API layer to provide a Facade for different data storages, with optimization logic, like snapshots, batch reading, etc… The ideia is to read from the config file what is the choosen storage, and route the call to the specifc implementation. http://elixir-lang.org/docs/stable/elixir/typespecs

Summary

Types

event()

events()

result()

stream()

Functions

append_to_stream(stream_id, expected_version, events)

Recieve internal event data to append. message building is an adapter task

read_stream_forward(stream_id, start_version, read_event_batch_size \\ 100)

Read pure events from stream

Types

event()

event() :: struct

events()

events() :: [struct]

position()

position() :: integer

result()

result() :: {position, String.t}

stream()

stream() :: String.t

Functions

append_to_stream(stream_id, expected_version, events)

Recieve internal event data to append. message building is an adapter task.

read_stream_forward(stream_id, start_version, read_event_batch_size \\ 100)

Read pure events from stream