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),
    ObjectExists {
        key: String,
    },
    PreconditionFailed {
        key: String,
        reason: String,
    },
    RecordTooLarge {
        size: usize,
        limit: usize,
    },
    Worm(WormError),
    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

A caller gave add_remote_log_segment_metadata a starting state other than RemoteLogSegmentState::CopySegmentStarted, or a segment id that already exists.

Fields

id: RemoteLogSegmentId

The offending segment id.

reason: String

Why the add was rejected.

InvalidSegmentTransition

A caller requested a lifecycle transition that the state machine forbids.

Fields

id: RemoteLogSegmentId

The segment whose transition was rejected.

from: RemoteLogSegmentState

Current state.

to: RemoteLogSegmentState

Requested state.

InvalidPartitionDeleteTransition

A caller requested a partition-delete lifecycle transition 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.

ObjectExists

A conditional create found an object already at the key.

A write-once archive turns on PutMode::Create for every object it writes, so this is how it learns that a key is already taken rather than silently replacing what is there.

Fields

key: String

Object-store key that already holds an object.

PreconditionFailed

A conditional write’s precondition did not hold, for example an ETag that no longer matches.

Fields

key: String

Object-store key whose precondition was evaluated.

reason: String

Why the backend rejected the write.

RecordTooLarge

A scan of a remote segment’s records met a compressed batch with a record whose body is larger than the caller’s limit. This is Kafka trunk’s max.decompressed.message.bytes, which DefaultRecord.readFrom enforces with an InvalidRecordException.

The segment is fine and the answer is known: the lookup fails, and it fails the same way on every retry until the limit is raised.

Fields

size: usize

The record’s body size in bytes, Kafka’s sizeOfBodyInBytes.

limit: usize

The configured maximum.

Worm(WormError)

The write-once (WORM) archive layer refused or could not complete the operation.

Backend(String)

A backend, for example an object store, raised an error. The error does not map cleanly to one of the structured variants above.

NotReady

This broker holds the metadata partition that would answer this query, but its consumer has not yet caught up to the high-water mark that the broker observed when it took the assignment. 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.

impl From<ObjectStoreError> for RemoteStorageError

fn from(err: ObjectStoreError) -> Self

Converts to this type from the input type.

impl From<WormError> for RemoteStorageError

fn from(source: WormError) -> Self

Converts to this type from the input type.