Immich.Sync.EventStream behaviour (ex_immich v0.1.1)

Behaviour for fetching sync events and acknowledging processed chunks.

Summary

opts()

Options passed through to sync_stream/3 and sync_ack/3.

t()

Acknowledges event ack tokens after successful processing.

Returns a stream of raw event payload maps for the requested event types.

@type opts() :: keyword()

Options passed through to sync_stream/3 and sync_ack/3.

@type t() :: module()

@callback sync_ack(Immich.API.Session.t(), [String.t()], opts()) ::
  {:ok, map() | term()} | {:error, term()}

Acknowledges event ack tokens after successful processing.

@callback sync_stream(Immich.API.Session.t(), [String.t()], opts()) ::
  {:ok, Enumerable.t(map())} | {:error, term()}

Returns a stream of raw event payload maps for the requested event types.