Enum SyncError 

pub enum SyncError {
    IncompatiblePeer,
    TransportFailed(String),
    TransportTimeout(String),
    HttpStatus(u16),
    EmptyHttpResponse,
    EmptyRequestBody,
    RequestBodyTooLarge {
        size: usize,
        max: usize,
    },
    ResponseTooLarge {
        max: usize,
    },
    TooManyEvents {
        count: usize,
        max: usize,
    },
    InvalidSequence(u64),
    SequenceConflict(u64),
    SnapshotUnsupported,
    InvalidSnapshot(&'static str),
    InvalidPeerId,
    InvalidPeerAddress,
    UnsupportedPeerScheme,
    DnsResolutionFailed(String),
    TlsFailed(String),
    LogIndexOutOfBounds {
        index: usize,
        len: usize,
    },
    LockPoisoned(&'static str),
    InvalidSyncMessage(&'static str),
    OutboxOperationUnsupported(&'static str),
    InvalidEventHex,
    CorruptReplicationLog {
        line: usize,
        reason: &'static str,
    },
    CorruptOutbox {
        line: usize,
    },
    ElectionFailed(String),
    ReplicationFailed(String),
    PeerNotFound(String),
}

Sync-local typed errors.

Variants

IncompatiblePeer

The remote peer does not share the local application sync identity.

TransportFailed(String)

A transport operation failed for the supplied reason.

TransportTimeout(String)

A transport operation exceeded its configured deadline.

HttpStatus(u16)

The remote HTTP endpoint returned a non-success status.

EmptyHttpResponse

The remote endpoint closed the connection without a response.

EmptyRequestBody

A sync request did not contain a body.

RequestBodyTooLarge

An outbound request exceeded the configured byte limit.

Fields

size: usize

Actual encoded body size in bytes.

max: usize

Maximum accepted body size in bytes.

ResponseTooLarge

An inbound response exceeded the configured byte limit.

Fields

max: usize

Maximum accepted response size in bytes.

TooManyEvents

A batch contained more events than the receiver accepts.

Fields

count: usize

Number of events found in the batch.

max: usize

Maximum accepted event count.

InvalidSequence(u64)

A sequence does not continue or validly overlap the checkpoint.

SequenceConflict(u64)

A sequence already exists with different payload bytes.

SnapshotUnsupported

The selected replication log does not implement snapshots.

InvalidSnapshot(&'static str)

A snapshot failed integrity or structural validation.

InvalidPeerId

A peer identifier is empty or contains unsupported characters.

InvalidPeerAddress

A peer seed cannot be parsed as a supported host and port.

UnsupportedPeerScheme

A peer seed uses a transport scheme unsupported by sync.

DnsResolutionFailed(String)

A DNS seed could not be resolved.

TlsFailed(String)

TLS setup or negotiation failed.

LogIndexOutOfBounds

A replication-log read started beyond the current log length.

Fields

index: usize

Requested zero-based offset.

len: usize

Current log length.

LockPoisoned(&'static str)

A synchronization primitive was poisoned.

InvalidSyncMessage(&'static str)

A wire message violated a sync invariant.

OutboxOperationUnsupported(&'static str)

An additive outbox operation is unavailable on this provider.

InvalidEventHex

An event payload is not valid hexadecimal data.

CorruptReplicationLog

A durable replication-log record is malformed.

Fields

line: usize

One-based line containing the invalid record.

reason: &'static str

Stable description of the violated record format.

CorruptOutbox

A durable outbox record is malformed.

Fields

line: usize

One-based line containing the invalid record.

ElectionFailed(String)

Leader-election state could not be advanced.

ReplicationFailed(String)

Replication persistence or application failed.

PeerNotFound(String)

A requested peer is absent from the current directory.

Trait Implementations

impl Clone for SyncError

fn clone(&self) -> SyncError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncError

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

Formats the value using the given formatter.

impl Eq for SyncError

impl PartialEq for SyncError

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SyncError