pub enum ReplicationError {
}Expand description
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
Implementations§
Source§impl ReplicationError
impl ReplicationError
Sourcepub fn transient_connection<S: Into<String>>(msg: S) -> Self
pub fn transient_connection<S: Into<String>>(msg: S) -> Self
Create a new transient connection error (can be retried)
Sourcepub fn permanent_connection<S: Into<String>>(msg: S) -> Self
pub fn permanent_connection<S: Into<String>>(msg: S) -> Self
Create a new permanent connection error (should not be retried)
Sourcepub fn replication_connection<S: Into<String>>(msg: S) -> Self
pub fn replication_connection<S: Into<String>>(msg: S) -> Self
Create a new replication connection error
Sourcepub fn connection<S: Into<String>>(msg: S) -> Self
pub fn connection<S: Into<String>>(msg: S) -> Self
Create a new connection error (alias for replication_connection)
Sourcepub fn authentication<S: Into<String>>(msg: S) -> Self
pub fn authentication<S: Into<String>>(msg: S) -> Self
Create a new authentication error
Sourcepub fn replication_slot<S: Into<String>>(msg: S) -> Self
pub fn replication_slot<S: Into<String>>(msg: S) -> Self
Create a new replication slot error
Sourcepub fn is_transient(&self) -> bool
pub fn is_transient(&self) -> bool
Check if the error is transient (can be retried)
Sourcepub fn is_permanent(&self) -> bool
pub fn is_permanent(&self) -> bool
Check if the error is permanent (should not be retried)
Sourcepub fn is_cancelled(&self) -> bool
pub fn is_cancelled(&self) -> bool
Check if the error is due to cancellation