Enum ErrorKind 

pub enum ErrorKind {
    Transient,
    Config,
    Preflight,
    Unsupported,
    ResyncRequired,
    Resource,
    Consistency,
    Internal,
    Cancelled,
}

How the engine should react to an error.

Variants

Transient

Network, timeout, or server restart. Retry with backoff.

Config

Configuration problem. Stop; operator fixes config.

Preflight

Source does not meet prerequisites (wal_level, privileges, missing publication…).

Unsupported

A change cannot be applied safely (unsupported type/operation, missing key, DDL). Stop without acknowledging. Operator intervention required.

ResyncRequired

Replication continuity cannot be proven (slot missing, WAL lost, identity changed). Job must be resynchronised from a new snapshot.

Resource

Memory or resource budget exceeded. Stop without acknowledging; may be recoverable after raising limits.

Consistency

Source and target have diverged (e.g. an UPDATE matched no row). Stop.

Internal

Protocol violation or internal invariant failure. Stop.

Cancelled

Operation cancelled by shutdown request.

Implementations

impl ErrorKind

pub fn is_retryable(self) -> bool

Trait Implementations

impl Clone for ErrorKind

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for ErrorKind

impl Debug for ErrorKind

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for ErrorKind

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for ErrorKind

impl Hash for ErrorKind

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ErrorKind

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for ErrorKind

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ErrorKind