Enum RemoteStorageError 

pub enum RemoteStorageError {
    Io(Error),
    SegmentNotFound(RemoteLogSegmentId),
    InvalidAdd {
        id: RemoteLogSegmentId,
        reason: String,
    },
    InvalidSegmentTransition {
        id: RemoteLogSegmentId,
        from: RemoteLogSegmentState,
        to: RemoteLogSegmentState,
    },
    InvalidPartitionDeleteTransition {
        tp: TopicIdPartition,
        from: Option<RemotePartitionDeleteState>,
        to: RemotePartitionDeleteState,
    },
    InvalidArgument(String),
    Backend(String),
    NotReady {
        partition: i32,
    },
}

Errors raised by RemoteStorageManager and RemoteLogMetadataManager implementations.

Variants

Io(Error)

An I/O failure in the underlying store (filesystem, object store, …).

SegmentNotFound(RemoteLogSegmentId)

A segment was referenced that the metadata store has never seen.

InvalidAdd

add_remote_log_segment_metadata was called with a starting state other than RemoteLogSegmentState::CopySegmentStarted, or for a segment id that already exists.

Fields

id: RemoteLogSegmentId

The offending segment id.

reason: String

Why the add was rejected.

InvalidSegmentTransition

A lifecycle transition was requested that the state machine forbids.

Fields

id: RemoteLogSegmentId

The segment whose transition was rejected.

from: RemoteLogSegmentState

Current state.

to: RemoteLogSegmentState

Requested state.

InvalidPartitionDeleteTransition

A partition-delete lifecycle transition was requested that the state machine forbids.

Fields

tp: TopicIdPartition

The partition whose transition was rejected.

from: Option<RemotePartitionDeleteState>

Current state (None when the partition was never marked).

to: RemotePartitionDeleteState

Requested state.

InvalidArgument(String)

Constructor / argument validation failed.

Backend(String)

A backend (e.g. an object store) raised an error that doesn’t map cleanly to one of the structured variants above.

NotReady

The metadata partition that would answer this query is assigned to this broker but its consumer has not yet caught up to the high-water mark observed when the partition was assigned. The answer is unknown, not “no segment” — callers should retry rather than treat it as a definitive miss. Ok(None) is reserved for “caught up, no covering segment” and for partitions this broker does not consume at all.

Fields

partition: i32

The __remote_log_metadata partition that is still catching up.

Trait Implementations

impl Debug for RemoteStorageError

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

Formats the value using the given formatter.

impl Display for RemoteStorageError

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

Formats the value using the given formatter.

impl Error for RemoteStorageError

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<Error> for RemoteStorageError

fn from(source: Error) -> Self

Converts to this type from the input type.