Enum SinkError 

pub enum SinkError {
    TransactionAlreadyActive(String),
    NoActiveTransaction,
    TransactionIdMismatch {
        expected: String,
        actual: String,
    },
    CommitFailed(String),
    RollbackFailed(String),
    WriteFailed(String),
    FlushFailed(String),
    CheckpointError(String),
    DeduplicationError(String),
    NotConnected,
    ConnectionError(String),
    ConfigurationError(String),
    Timeout(u64),
    NotSupported(String),
    Internal(String),
}

Errors that can occur in exactly-once sinks

Variants

TransactionAlreadyActive(String)

Transaction has already started

NoActiveTransaction

No active transaction

TransactionIdMismatch

Transaction ID mismatch

Fields

expected: String

Expected transaction ID

actual: String

Actual transaction ID

CommitFailed(String)

Transaction commit failed

RollbackFailed(String)

Transaction rollback failed

WriteFailed(String)

Write operation failed

FlushFailed(String)

Flush operation failed

CheckpointError(String)

Checkpoint serialization/deserialization failed

DeduplicationError(String)

Deduplication store error

NotConnected

Sink is not connected

ConnectionError(String)

Sink connection error

ConfigurationError(String)

Configuration error

Timeout(u64)

Timeout occurred

NotSupported(String)

Sink does not support the requested operation

Internal(String)

Internal error

Trait Implementations

impl Debug for SinkError

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

Formats the value using the given formatter.

impl Display for SinkError

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

Formats the value using the given formatter.

impl Error for SinkError

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 From<SinkError> for Error

fn from(source: SinkError) -> Self

Converts to this type from the input type.

impl From<SinkError> for SinkError

fn from(err: SinkError) -> Self

Converts to this type from the input type.

impl From<SinkError> for SinkError

fn from(err: ReactorSinkError) -> Self

Converts to this type from the input type.