Framework.Sequencer.Consumer behaviour (Framework v0.5.0)

Consumer behavior for cursor persistence and resume.

Implements the binding behavior per sequencer-emitter-spec.md.

Summary

Behavior callback for handling events.

Get cursor for a named consumer.

Persist cursor for a named consumer.

Resume consumption from stored cursor.

@callback handle_events(events :: [map()], state :: term()) ::
  {:ok, new_state :: term()} | {:error, reason :: term()}

Behavior callback for handling events.

All consumers must implement this callback.

Get cursor for a named consumer.

Returns the last processed sequence or 0 if no cursor exists.

Persist cursor for a named consumer.

Uses the canonical consumer_cursors table per sequencer-emitter-spec.md.

Resume consumption from stored cursor.

Implements the canonical resume behavior: > last_processed_sequence