ExESDB.SnapshotsWriter (ex_esdb v0.1.0)

The API for interacting with ExESDB Snapshots Writers. It functions as an API for SnapshotsWriterWorkers, by requesting a worker from the Cluster. If no worker is available for the specific combination of store, source_uuid, and stream_uuid, then a new worker is started.

Summary

Functions

cluster_id(store, source_uuid, stream_uuid)

delete_snapshot(store, source_uuid, stream_uuid, version)

hr_snapshots_writer_name(store_id, source_uuid, stream_uuid)

record_snapshot(store, source_uuid, stream_uuid, version, snapshot_record)

Functions

cluster_id(store, source_uuid, stream_uuid)

delete_snapshot(store, source_uuid, stream_uuid, version)

@spec delete_snapshot(
  store :: atom(),
  source_uuid :: binary(),
  stream_uuid :: binary(),
  version :: integer()
) :: :ok

hr_snapshots_writer_name(store_id, source_uuid, stream_uuid)

record_snapshot(store, source_uuid, stream_uuid, version, snapshot_record)

@spec record_snapshot(
  store :: atom(),
  source_uuid :: binary(),
  stream_uuid :: binary(),
  version :: integer(),
  snapshot_record :: map()
) :: :ok