Summary

Types

stack_ref()

Returns the ETS table name used to store LSN info for the given stack ID.

@type stack_ref() :: Electric.stack_id() | atom()

@spec get_last_processed_lsn(Electric.stack_id()) :: Electric.Postgres.Lsn.t()

@spec initialize(stack_ref()) :: :ok

@spec initialize_last_processed_lsn(stack_ref(), Electric.Postgres.Lsn.t()) :: :ok

@spec set_last_processed_lsn(
  stack_ref(),
  Electric.Postgres.Lsn.t() | non_neg_integer()
) :: :ok

@spec stack_ref(Electric.stack_id()) :: atom()

Returns the ETS table name used to store LSN info for the given stack ID.