Enum ReplicationError 

pub enum ReplicationError {
    Protocol(String),
    Buffer(String),
    TransientConnection(String),
    PermanentConnection(String),
    ReplicationConnection(String),
    Authentication(String),
    ReplicationSlot(String),
    Timeout(String),
    Cancelled(String),
    Config(String),
    Io(Error),
    StringConversion(NulError),
    Generic(String),
    Deserialize(String),
}

Comprehensive error types for replication operations

Variants

Protocol(String)

Protocol parsing errors

Buffer(String)

Buffer operation errors

TransientConnection(String)

Connection errors that can be retried (transient)

PermanentConnection(String)

Connection errors that should not be retried (permanent)

ReplicationConnection(String)

Replication connection errors

Authentication(String)

Authentication errors

ReplicationSlot(String)

Replication slot errors

Timeout(String)

Timeout errors

Cancelled(String)

Operation cancelled errors

Config(String)

Configuration errors

Io(Error)

IO errors

StringConversion(NulError)

String conversion errors (from CString operations)

Generic(String)

Generic replication errors

Deserialize(String)

Deserialization errors (when converting RowData to user types)

Implementations

impl ReplicationError

pub fn protocol<S: Into<String>>(msg: S) -> Self

Create a new protocol error

pub fn buffer<S: Into<String>>(msg: S) -> Self

Create a new buffer error

pub fn transient_connection<S: Into<String>>(msg: S) -> Self

Create a new transient connection error (can be retried)

pub fn permanent_connection<S: Into<String>>(msg: S) -> Self

Create a new permanent connection error (should not be retried)

pub fn replication_connection<S: Into<String>>(msg: S) -> Self

Create a new replication connection error

pub fn connection<S: Into<String>>(msg: S) -> Self

Create a new connection error (alias for replication_connection)

pub fn authentication<S: Into<String>>(msg: S) -> Self

Create a new authentication error

pub fn replication_slot<S: Into<String>>(msg: S) -> Self

Create a new replication slot error

pub fn timeout<S: Into<String>>(msg: S) -> Self

Create a new timeout error

pub fn cancelled<S: Into<String>>(msg: S) -> Self

Create a new cancellation error

pub fn config<S: Into<String>>(msg: S) -> Self

Create a new configuration error

pub fn generic<S: Into<String>>(msg: S) -> Self

Create a new generic error

pub fn deserialize<S: Into<String>>(msg: S) -> Self

Create a new deserialization error

pub fn is_transient(&self) -> bool

Check if the error is transient (can be retried)

pub fn is_permanent(&self) -> bool

Check if the error is permanent (should not be retried)

pub fn is_cancelled(&self) -> bool

Check if the error is due to cancellation

Trait Implementations

impl Debug for ReplicationError

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

Formats the value using the given formatter.

impl Display for ReplicationError

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

Formats the value using the given formatter.

impl Error for ReplicationError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl Error for ReplicationError

fn custom<T: Display>(msg: T) -> Self

Raised when there is general error when deserializing a type.

fn invalid_type(unexp: Unexpected<'_>, exp: &dyn Expected) -> Self

Raised when a Deserialize receives a type different from what it was expecting.

fn invalid_value(unexp: Unexpected<'_>, exp: &dyn Expected) -> Self

Raised when a Deserialize receives a value of the right type but that is wrong for some other reason.

fn invalid_length(len: usize, exp: &dyn Expected) -> Self

Raised when deserializing a sequence or map and the input data contains too many or too few elements.

fn unknown_variant(variant: &str, expected: &'static [&'static str]) -> Self

Raised when a Deserialize enum type received a variant with an unrecognized name.

fn unknown_field(field: &str, expected: &'static [&'static str]) -> Self

Raised when a Deserialize struct type received a field with an unrecognized name.

fn missing_field(field: &'static str) -> Self

Raised when a Deserialize struct type expected to receive a required field with a particular name but that field was not present in the input.

fn duplicate_field(field: &'static str) -> Self

Raised when a Deserialize struct type received more than one of the same field.

impl From<Error> for ReplicationError

fn from(err: Error) -> Self

Converts to this type from the input type.

impl From<NulError> for ReplicationError

fn from(err: NulError) -> Self

Converts to this type from the input type.