View Source MessageStore (message_store v3.2.0)

A module for interactions with message store

Link to this section Summary

Link to this section Functions

@spec category(String.t() | nil) :: String.t()
Link to this function

expected_version(message_store, stream_uuid)

View Source
@spec expected_version(atom(), String.t()) :: Result.t(term(), integer())
Link to this function

fetch(conn, stream_name, projection, opts)

View Source
@spec fetch(
  conn,
  String.t(),
  m,
  read:
    (conn, String.t(), list() ->
       Result.t(reason, [EventStore.RecordedEvent.t()])),
  project: ([EventStore.RecordedEvent.t()], m -> projection)
) :: Result.t(reason, projection)
when conn: module(), m: module(), reason: term(), projection: any()
Link to this function

project(messages, projection)

View Source
@spec project([EventStore.RecordedEvent.t()], module()) :: any()
Link to this function

stream_name_to_id(stream_name)

View Source
@spec stream_name_to_id(String.t()) :: String.t() | nil
@spec to_result(:ok | {:error, err}, value) :: Result.t(err, value)
when err: any(), value: any()