Chronicle.FailedPartitions (cratis_chronicle v2.2.0)

Idiomatic API for working with Chronicle failed partitions.

A partition (an event source, within an observer's subscription) is marked failed when a reactor, reducer, or other observer's handling of an event raises or returns an error. Failed partitions stop advancing until they are retried or the observer is replayed.

Mirrors the C# and Kotlin clients' IFailedPartitions.

Options

:client — the client name (default: Chronicle.Client)
:namespace — accepted for consistency with other APIs and ignored here

Summary

Functions

get_all(opts \\ [])

Gets all failed partitions for any observer (reactor, reducer, ++) on the current event store.

get_for(observer_id, opts \\ [])

Gets all failed partitions for a specific observer.

Functions

get_all(opts \\ [])

@spec get_all(keyword()) ::
  {:ok, [Chronicle.FailedPartitions.FailedPartition.t()]} | {:error, term()}

Gets all failed partitions for any observer (reactor, reducer, ++) on the current event store.

get_for(observer_id, opts \\ [])

@spec get_for(
  String.t(),
  keyword()
) :: {:ok, [Chronicle.FailedPartitions.FailedPartition.t()]} | {:error, term()}

Gets all failed partitions for a specific observer.