pub enum AdapterError {
Show 58 variants AbsurdSubscribeBounds { as_of: Timestamp, up_to: Timestamp, }, Catalog(Error), ChangedPlan, ConstrainedParameter { parameter: &'static (dyn Var + Send + Sync), value: String, valid_values: Option<Vec<&'static str>>, }, DuplicateCursor(String), Eval(EvalError), Explain(ExplainError), FixedValueParameter(&'static (dyn Var + Send + Sync)), IdExhaustionError, Internal(String), IntrospectionDisabled { log_names: Vec<String>, }, InvalidLogDependency { object_type: String, log_names: Vec<String>, }, InvalidParameterType(&'static (dyn Var + Send + Sync)), InvalidParameterValue { parameter: &'static (dyn Var + Send + Sync), value: String, reason: String, }, InvalidClusterReplicaAz { az: String, expected: Vec<String>, }, InvalidClusterReplicaSize { size: String, expected: Vec<String>, }, InvalidStorageClusterSize { size: String, expected: Vec<String>, }, SourceOrSinkSizeRequired { expected: Vec<String>, }, InvalidTableMutationSelection, ModifyLinkedCluster { cluster_name: String, linked_object_name: String, }, BadItemInStorageCluster { cluster_name: String, }, ConstraintViolation(NotNullViolation), NoClusterReplicasAvailable(String), OperationProhibitsTransaction(String), OperationRequiresTransaction(String), PlanError(PlanError), PreparedStatementExists(String), ParseError(ParserError), ReadOnlyTransaction, ReadOnlyParameter(&'static (dyn Var + Send + Sync)), ReadWriteUnavailable, RecursionLimit(RecursionLimitError), RelationOutsideTimeDomain { relations: Vec<String>, names: Vec<String>, }, ResourceExhaustion { resource_type: String, limit: u32, current_amount: usize, new_instances: i32, }, ResultSize(String), SafeModeViolation(String), StatementTimeout, IdleInTransactionSessionTimeout, SqlCatalog(CatalogError), SubscribeOnlyTransaction, Transform(TransformError), Unauthorized(String), UncallableFunction { func: UnmaterializableFunc, context: &'static str, }, UnknownCursor(String), UnknownLoginRole(String), UnknownParameter(String), UnknownPreparedStatement(String), UnknownClusterReplica { cluster_name: String, replica_name: String, }, Unstructured(Error), Unsupported(&'static str), UnmaterializableFunction(UnmaterializableFunc), UnstableDependency { object_type: String, unstable_dependencies: Vec<String>, }, UntargetedLogRead { log_names: Vec<String>, }, WriteOnlyTransaction, MultiTableWriteTransaction, Storage(StorageError), Compute(Error), Orchestrator(Error),
}
Expand description

Errors that can occur in the coordinator.

Variants§

§

AbsurdSubscribeBounds

Fields

§as_of: Timestamp
§up_to: Timestamp

A SUBSCRIBE was requested whose UP TO bound precedes its as_of timestamp

§

Catalog(Error)

An error occurred in a catalog operation.

§

ChangedPlan

The cached plan or descriptor changed.

§

ConstrainedParameter

Fields

§parameter: &'static (dyn Var + Send + Sync)
§value: String
§valid_values: Option<Vec<&'static str>>

The specified session parameter is constrained to a finite set of values.

§

DuplicateCursor(String)

The cursor already exists.

§

Eval(EvalError)

An error while evaluating an expression.

§

Explain(ExplainError)

An error occurred while planning the statement.

§

FixedValueParameter(&'static (dyn Var + Send + Sync))

The specified parameter is fixed to a single specific value.

§

IdExhaustionError

The ID allocator exhausted all valid IDs.

§

Internal(String)

Unexpected internal state was encountered.

§

IntrospectionDisabled

Fields

§log_names: Vec<String>

Attempted to read from log sources of a replica with disabled introspection.

§

InvalidLogDependency

Fields

§object_type: String
§log_names: Vec<String>

Attempted to create an object dependent on log sources that doesn’t support log dependencies.

§

InvalidParameterType(&'static (dyn Var + Send + Sync))

The value for the specified parameter does not have the right type.

§

InvalidParameterValue

Fields

§parameter: &'static (dyn Var + Send + Sync)
§value: String
§reason: String

The value of the specified parameter is incorrect

§

InvalidClusterReplicaAz

Fields

§expected: Vec<String>

No such cluster replica size has been configured.

§

InvalidClusterReplicaSize

Fields

§size: String
§expected: Vec<String>

No such cluster replica size has been configured.

§

InvalidStorageClusterSize

Fields

§size: String
§expected: Vec<String>

No such storage instance size has been configured.

§

SourceOrSinkSizeRequired

Fields

§expected: Vec<String>

Creating a source or sink without specifying its size is forbidden.

§

InvalidTableMutationSelection

The selection value for a table mutation operation refers to an invalid object.

§

ModifyLinkedCluster

Fields

§cluster_name: String
§linked_object_name: String

An operation attempted to modify a linked cluster.

§

BadItemInStorageCluster

Fields

§cluster_name: String

An operation attempted to create an illegal item in a storage-only cluster

§

ConstraintViolation(NotNullViolation)

Expression violated a column’s constraint

§

NoClusterReplicasAvailable(String)

Target cluster has no replicas to service query.

§

OperationProhibitsTransaction(String)

The named operation cannot be run in a transaction.

§

OperationRequiresTransaction(String)

The named operation requires an active transaction.

§

PlanError(PlanError)

An error occurred while planning the statement.

§

PreparedStatementExists(String)

The named prepared statement already exists.

§

ParseError(ParserError)

Wrapper around parsing error

§

ReadOnlyTransaction

The transaction is in read-only mode.

§

ReadOnlyParameter(&'static (dyn Var + Send + Sync))

The specified session parameter is read-only.

§

ReadWriteUnavailable

The transaction in in read-only mode and a read already occurred.

§

RecursionLimit(RecursionLimitError)

The recursion limit of some operation was exceeded.

§

RelationOutsideTimeDomain

Fields

§relations: Vec<String>
§names: Vec<String>

A query in a transaction referenced a relation outside the first query’s time domain.

§

ResourceExhaustion

Fields

§resource_type: String
§limit: u32
§current_amount: usize
§new_instances: i32

A query tried to create more resources than is allowed in the system configuration.

§

ResultSize(String)

Result size of a query is too large.

§

SafeModeViolation(String)

The specified feature is not permitted in safe mode.

§

StatementTimeout

Waiting on a query timed out.

Note this differs slightly from PG’s implementation/semantics.

§

IdleInTransactionSessionTimeout

An idle session in a transaction has timed out.

§

SqlCatalog(CatalogError)

An error occurred in a SQL catalog operation.

§

SubscribeOnlyTransaction

The transaction is in single-subscribe mode.

§

Transform(TransformError)

An error occurred in the MIR stage of the optimizer.

§

Unauthorized(String)

A user tried to perform an action that they were unauthorized to do.

§

UncallableFunction

Fields

§context: &'static str

The specified function cannot be called

§

UnknownCursor(String)

The named cursor does not exist.

§

UnknownLoginRole(String)

The named role does not exist.

§

UnknownParameter(String)

The named parameter is unknown to the system.

§

UnknownPreparedStatement(String)

§

UnknownClusterReplica

Fields

§cluster_name: String
§replica_name: String

The named cluster replica does not exist.

§

Unstructured(Error)

A generic error occurred.

§

Unsupported(&'static str)

The named feature is not supported and will (probably) not be.

§

UnmaterializableFunction(UnmaterializableFunc)

The specified function cannot be materialized.

§

UnstableDependency

Fields

§object_type: String
§unstable_dependencies: Vec<String>

Attempted to create an object that has unstable dependencies.

§

UntargetedLogRead

Fields

§log_names: Vec<String>

Attempted to read from log sources without selecting a target replica.

§

WriteOnlyTransaction

The transaction is in write-only mode.

§

MultiTableWriteTransaction

The transaction only supports single table writes

§

Storage(StorageError)

An error occurred in the storage layer

§

Compute(Error)

An error occurred in the compute layer

§

Orchestrator(Error)

An error in the orchestrator layer

Implementations§

Reports additional details about the error, if any are available.

Reports a hint for the user about how the error could be fixed.

Trait Implementations§

Formats the value using the given formatter. Read more
Formats the value using the given formatter. Read more
The lower-level source of this error, if any. Read more
👎Deprecated since 1.42.0: use the Display impl or to_string()
👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting
🔬This is a nightly-only experimental API. (error_generic_member_access)
Provides type based access to context intended for error reports. Read more
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Converts to this type from the input type.
Reports whether the error should halt rather than panic the process.

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more
Immutably borrows from an owned value. Read more
Mutably borrows from an owned value. Read more
Formats an object with the “alternative” format ({:#}) and returns it.

Returns the argument unchanged.

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Attaches the current Context to this type, returning a WithContext wrapper. Read more
Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request
The alignment of pointer.
The type for initializers.
Initializes a with the given initializer. Read more
Dereferences the given pointer. Read more
Mutably dereferences the given pointer. Read more
Drops the object pointed to by the given pointer. Read more
🔬This is a nightly-only experimental API. (provide_any)
Data providers should implement this method to provide all values they are able to provide by using demand. Read more
Should always be Self
Converts the given value to a String. Read more
The type returned in the event of a conversion error.
Performs the conversion.
The type returned in the event of a conversion error.
Performs the conversion.
Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more