Returns a specification to start this module under a supervisor.

See Supervisor.

@spec delete_link_values(Electric.stack_id(), Electric.shape_handle()) :: :ok

Removes the cached link values for shape_handle from the shared ETS table. Safe to call even if the table does not exist (e.g. after a stack shutdown).

Returns the current set of materialized link values for a shape. Checks the shared ETS cache first (written after each committed transaction); falls back to a synchronous GenServer call if the cache has no entry yet.

Get a stream of log entries from storage, bounded by the subscribed offset.

The subscribed_offset is the Consumer's latest_offset at the time of subscription. We only read up to this offset to avoid duplicates - any changes after this offset will be delivered via new_changes messages from the Consumer.

Callback implementation for GenServer.handle_continue/2.

Callback implementation for GenServer.init/1.

@spec init_link_values_table(stack_id :: term()) :: :ets.table() | :undefined

Creates the per-stack ETS table that caches link values for all materializers in a stack. Called by ConsumerRegistry during stack initialization. Idempotent — safe to call when the table already exists.