Enum WriteError 

pub enum WriteError {
    AllReplicasFailed,
    BufferEvicted,
    BufferFull,
    CircuitBreakerOpen {
        estimated_recovery_time: Option<Duration>,
    },
    ConfirmationFailed(String),
    ReplicationConfirmationFailed(String),
    DatabaseOperationFailed(String),
    InsufficientHealthyReplicas {
        available: u8,
        required: u8,
    },
    InvalidSender,
    StaleWrite,
    MissingExpectedPartitionSequence,
    PartitionNotOwned {
        partition_id: PartitionId,
    },
    ReplicationQuorumFailed {
        confirmed: u8,
        required: u8,
    },
    RequestTimeout,
    MaximumForwardsExceeded {
        max: u8,
    },
    RemoteOperationFailed(String),
    SequenceConflict,
    WrongExpectedSequence {
        partition_id: PartitionId,
        current: CurrentVersion,
        expected: ExpectedVersion,
    },
    WrongExpectedVersion {
        partition_key: Uuid,
        stream_id: StreamId,
        current: CurrentVersion,
        expected: ExpectedVersion,
    },
}

Variants

AllReplicasFailed

BufferEvicted

BufferFull

CircuitBreakerOpen

Fields

estimated_recovery_time: Option<Duration>

ConfirmationFailed(String)

ReplicationConfirmationFailed(String)

DatabaseOperationFailed(String)

InsufficientHealthyReplicas

Fields

available: u8

required: u8

InvalidSender

StaleWrite

MissingExpectedPartitionSequence

PartitionNotOwned

Fields

partition_id: PartitionId

ReplicationQuorumFailed

Fields

confirmed: u8

required: u8

RequestTimeout

MaximumForwardsExceeded

Fields

max: u8

RemoteOperationFailed(String)

SequenceConflict

WrongExpectedSequence

Fields

partition_id: PartitionId

current: CurrentVersion

expected: ExpectedVersion

WrongExpectedVersion

Fields

partition_key: Uuid

stream_id: StreamId

current: CurrentVersion

expected: ExpectedVersion

Implementations

impl WriteError

pub fn code(&self) -> &'static str

Trait Implementations

impl Clone for WriteError

fn clone(&self) -> WriteError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriteError

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WriteError

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for WriteError

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

Formats the value using the given formatter.

impl Error for WriteError

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<RemoteSendError<WriteError>> for WriteError

fn from(err: RemoteSendError<WriteError>) -> Self

Converts to this type from the input type.

impl From<WriteError> for WriteError

fn from(err: WriteError) -> Self

Converts to this type from the input type.

impl Serialize for WriteError

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

where __S: Serializer,

Serialize this value into the given Serde serializer.