pub enum StorageError {
Show 16 variants
SourceIdReused(GlobalId),
SinkIdReused(GlobalId),
IdentifierMissing(GlobalId),
IdentifierInvalid(GlobalId),
UpdateBeyondUpper(GlobalId),
ReadBeforeSince(GlobalId),
InvalidUppers(Vec<GlobalId>),
IOError(StashError),
IngestionInstanceMissing {
storage_instance_id: StorageInstanceId,
ingestion_id: GlobalId,
},
ExportInstanceMissing {
storage_instance_id: StorageInstanceId,
export_id: GlobalId,
},
DataflowError(DataflowError),
InvalidAlterSource {
id: GlobalId,
},
InvalidUsage(String),
ResourceExhausted(&'static str),
ShuttingDown(&'static str),
Generic(Error),
}
Variants§
SourceIdReused(GlobalId)
The source identifier was re-created after having been dropped, or installed with a different description.
SinkIdReused(GlobalId)
The sink identifier was re-created after having been dropped, or installed with a different description.
IdentifierMissing(GlobalId)
The source identifier is not present.
IdentifierInvalid(GlobalId)
The provided identifier was invalid, maybe missing, wrong type, not registered, etc.
UpdateBeyondUpper(GlobalId)
The update contained in the appended batch was at a timestamp equal or beyond the batch’s upper
ReadBeforeSince(GlobalId)
The read was at a timestamp before the collection’s since
InvalidUppers(Vec<GlobalId>)
The expected upper of one or more appends was different from the actual upper of the collection
IOError(StashError)
An operation failed to read or write state
IngestionInstanceMissing
The (client for) the requested cluster instance is missing.
ExportInstanceMissing
The (client for) the requested cluster instance is missing.
DataflowError(DataflowError)
Dataflow was not able to process a request
InvalidAlterSource
Response to an invalid/unsupported ALTER SOURCE
command.
InvalidUsage(String)
The controller API was used in some invalid way. This usually indicates a bug.
ResourceExhausted(&'static str)
The specified resource was exhausted, and is not currently accepting more requests.
ShuttingDown(&'static str)
The specified component is shutting down.
Generic(Error)
A generic error that happens during operations of the storage controller.
Trait Implementations§
source§impl Debug for StorageError
impl Debug for StorageError
source§impl Display for StorageError
impl Display for StorageError
source§impl Error for StorageError
impl Error for StorageError
source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
1.0.0 · source§fn description(&self) -> &str
fn description(&self) -> &str
source§impl From<DataflowError> for StorageError
impl From<DataflowError> for StorageError
source§fn from(error: DataflowError) -> Self
fn from(error: DataflowError) -> Self
source§impl From<StashError> for StorageError
impl From<StashError> for StorageError
source§fn from(error: StashError) -> Self
fn from(error: StashError) -> Self
Auto Trait Implementations§
impl !RefUnwindSafe for StorageError
impl Send for StorageError
impl Sync for StorageError
impl Unpin for StorageError
impl !UnwindSafe for StorageError
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<E> ErrorExt for Ewhere
E: Error + ?Sized,
impl<E> ErrorExt for Ewhere E: Error + ?Sized,
source§fn display_with_causes(&self) -> ErrorChainFormatter<&Self>
fn display_with_causes(&self) -> ErrorChainFormatter<&Self>
source§fn to_string_with_causes(&self) -> String
fn to_string_with_causes(&self) -> String
self
to a string String
, along with the chain of source errors or
causes, if there are any. Read moresource§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.