Franklin
v0.1.0

View Source Franklin.EventStore (Franklin v0.1.0)

Link to this section Summary

Functions

ack(subscription, ack)

Callback implementation for EventStore.ack/2.

append_to_stream(stream_uuid, expected_version, events, opts \\ [])

Callback implementation for EventStore.append_to_stream/4.

child_spec(opts)
config(opts \\ [])
delete_all_streams_subscription(subscription_name, opts \\ [])

Callback implementation for EventStore.delete_all_streams_subscription/2.

delete_snapshot(source_uuid, opts \\ [])

Callback implementation for EventStore.delete_snapshot/2.

delete_stream(stream_uuid, expected_version, type \\ :soft, opts \\ [])

Callback implementation for EventStore.delete_stream/4.

delete_subscription(stream_uuid, subscription_name, opts \\ [])

Callback implementation for EventStore.delete_subscription/3.

link_to_stream(stream_uuid, expected_version, events_or_event_ids, opts \\ [])

Callback implementation for EventStore.link_to_stream/4.

paginate_streams(opts \\ [])

Callback implementation for EventStore.paginate_streams/1.

read_all_streams_backward(start_version \\ -1, count \\ 1000, opts \\ [])

Callback implementation for EventStore.read_all_streams_backward/3.

read_all_streams_forward(start_version \\ 0, count \\ 1000, opts \\ [])

Callback implementation for EventStore.read_all_streams_forward/3.

read_snapshot(source_uuid, opts \\ [])

Callback implementation for EventStore.read_snapshot/2.

read_stream_backward(stream_uuid, start_version \\ -1, count \\ 1000, opts \\ [])

Callback implementation for EventStore.read_stream_backward/4.

read_stream_forward(stream_uuid, start_version \\ 0, count \\ 1000, opts \\ [])

Callback implementation for EventStore.read_stream_forward/4.

record_snapshot(snapshot, opts \\ [])

Callback implementation for EventStore.record_snapshot/2.

start_link(opts \\ [])

Callback implementation for EventStore.start_link/1.

stop(supervisor, timeout \\ 5000)

Callback implementation for EventStore.stop/2.

stream_all_backward(start_version \\ -1, opts \\ [])

Callback implementation for EventStore.stream_all_backward/2.

stream_all_forward(start_version \\ 0, opts \\ [])

Callback implementation for EventStore.stream_all_forward/2.

stream_backward(stream_uuid, start_version \\ -1, opts \\ [])

Callback implementation for EventStore.stream_backward/3.

stream_forward(stream_uuid, start_version \\ 0, opts \\ [])

Callback implementation for EventStore.stream_forward/3.

stream_info(stream_uuid, opts \\ [])

Callback implementation for EventStore.stream_info/2.

subscribe(stream_uuid, opts \\ [])

Callback implementation for EventStore.subscribe/2.

subscribe_to_all_streams(subscription_name, subscriber, opts \\ [])

Callback implementation for EventStore.subscribe_to_all_streams/3.

subscribe_to_stream(stream_uuid, subscription_name, subscriber, opts \\ [])

Callback implementation for EventStore.subscribe_to_stream/4.

unsubscribe_from_all_streams(subscription_name, opts \\ [])

Callback implementation for EventStore.unsubscribe_from_all_streams/2.

unsubscribe_from_stream(stream_uuid, subscription_name, opts \\ [])

Callback implementation for EventStore.unsubscribe_from_stream/3.

Link to this section Functions

Link to this function

ack(subscription, ack)

View Source

Callback implementation for EventStore.ack/2.

Link to this function

append_to_stream(stream_uuid, expected_version, events, opts \\ [])

View Source

Callback implementation for EventStore.append_to_stream/4.

Link to this function

child_spec(opts)

View Source
Link to this function

config(opts \\ [])

View Source
Link to this function

delete_all_streams_subscription(subscription_name, opts \\ [])

View Source

Callback implementation for EventStore.delete_all_streams_subscription/2.

Link to this function

delete_snapshot(source_uuid, opts \\ [])

View Source

Callback implementation for EventStore.delete_snapshot/2.

Link to this function

delete_stream(stream_uuid, expected_version, type \\ :soft, opts \\ [])

View Source

Callback implementation for EventStore.delete_stream/4.

Link to this function

delete_subscription(stream_uuid, subscription_name, opts \\ [])

View Source

Callback implementation for EventStore.delete_subscription/3.

Link to this function

paginate_streams(opts \\ [])

View Source

Callback implementation for EventStore.paginate_streams/1.

Link to this function

read_all_streams_backward(start_version \\ -1, count \\ 1000, opts \\ [])

View Source

Callback implementation for EventStore.read_all_streams_backward/3.

Link to this function

read_all_streams_forward(start_version \\ 0, count \\ 1000, opts \\ [])

View Source

Callback implementation for EventStore.read_all_streams_forward/3.

Link to this function

read_snapshot(source_uuid, opts \\ [])

View Source

Callback implementation for EventStore.read_snapshot/2.

Link to this function

read_stream_backward(stream_uuid, start_version \\ -1, count \\ 1000, opts \\ [])

View Source

Callback implementation for EventStore.read_stream_backward/4.

Link to this function

read_stream_forward(stream_uuid, start_version \\ 0, count \\ 1000, opts \\ [])

View Source

Callback implementation for EventStore.read_stream_forward/4.

Link to this function

record_snapshot(snapshot, opts \\ [])

View Source

Callback implementation for EventStore.record_snapshot/2.

Link to this function

start_link(opts \\ [])

View Source

Callback implementation for EventStore.start_link/1.

Link to this function

stop(supervisor, timeout \\ 5000)

View Source

Callback implementation for EventStore.stop/2.

Link to this function

stream_all_backward(start_version \\ -1, opts \\ [])

View Source

Callback implementation for EventStore.stream_all_backward/2.

Link to this function

stream_all_forward(start_version \\ 0, opts \\ [])

View Source

Callback implementation for EventStore.stream_all_forward/2.

Link to this function

stream_backward(stream_uuid, start_version \\ -1, opts \\ [])

View Source

Callback implementation for EventStore.stream_backward/3.

Link to this function

stream_forward(stream_uuid, start_version \\ 0, opts \\ [])

View Source

Callback implementation for EventStore.stream_forward/3.

Link to this function

stream_info(stream_uuid, opts \\ [])

View Source

Callback implementation for EventStore.stream_info/2.

Link to this function

subscribe(stream_uuid, opts \\ [])

View Source

Callback implementation for EventStore.subscribe/2.

Link to this function

subscribe_to_all_streams(subscription_name, subscriber, opts \\ [])

View Source

Callback implementation for EventStore.subscribe_to_all_streams/3.

Link to this function

subscribe_to_stream(stream_uuid, subscription_name, subscriber, opts \\ [])

View Source

Callback implementation for EventStore.subscribe_to_stream/4.

Link to this function

unsubscribe_from_all_streams(subscription_name, opts \\ [])

View Source

Callback implementation for EventStore.unsubscribe_from_all_streams/2.

Link to this function

unsubscribe_from_stream(stream_uuid, subscription_name, opts \\ [])

View Source

Callback implementation for EventStore.unsubscribe_from_stream/3.