Replicant.Error exception (Replicant v0.1.0)

A typed, value-free error.

reason is a stable atom; table, lsn, and shape carry structure only. No row value, parameter, or decoded byte ever reaches this struct — the decode boundary (Replicant.Decoder.decode/1) and the identifier validator (Replicant.Identifier) are the enforcement points. message/1 and the derived Inspect render only structural fields (Critical Rule 1).

Summary

Types

reason()

t()

Functions

decode_failure(exception)

Build a value-free :decode_failure from any exception the vendored parser raised. The original message (which may embed raw bytes) is discarded; only the exception's module name is kept on :shape for triage.

Types

reason()

@type reason() ::
  :decode_failure
  | :unsupported_message
  | :invalid_identifier
  | :sink_failed
  | :schema_change_destructive
  | :slot_invalidated
  | :config_invalid
  | :too_many_streams
  | :spill_io_failed
  | :spill_exhausted
  | :snapshot_failed
  | :checkpoint_store_failed
  | :checkpoint_store_schema_mismatch

t()

@type t() :: %Replicant.Error{
  __exception__: true,
  lsn: Replicant.lsn() | nil,
  message: String.t() | nil,
  reason: reason(),
  shape: String.t() | nil,
  table: String.t() | nil
}

Functions

decode_failure(exception)

@spec decode_failure(Exception.t()) :: t()