Enum mz_adapter::error::AdapterError

pub enum AdapterError {
    AbsurdSubscribeBounds {
        as_of: Timestamp,
        up_to: Timestamp,
    },
    AmbiguousSystemColumnReference,
    Catalog(Error),
    ChangedPlan(String),
    DuplicateCursor(String),
    Eval(EvalError),
    Explain(ExplainError),
    IdExhaustionError,
    Internal(String),
    IntrospectionDisabled {
        log_names: Vec<String>,
    },
    InvalidLogDependency {
        object_type: String,
        log_names: Vec<String>,
    },
    InvalidClusterReplicaAz {
        az: String,
        expected: Vec<String>,
    },
    InvalidSetIsolationLevel,
    InvalidSetCluster,
    InvalidStorageClusterSize {
        size: String,
        expected: Vec<String>,
    },
    SourceOrSinkSizeRequired {
        expected: Vec<String>,
    },
    InvalidTableMutationSelection,
    ConstraintViolation(NotNullViolation),
    ConcurrentClusterDrop,
    NoClusterReplicasAvailable {
        name: String,
        is_managed: bool,
    },
    OperationProhibitsTransaction(String),
    OperationRequiresTransaction(String),
    PlanError(PlanError),
    PreparedStatementExists(String),
    ParseError(ParserStatementError),
    ReadOnlyTransaction,
    ReadWriteUnavailable,
    RecursionLimit(RecursionLimitError),
    RelationOutsideTimeDomain {
        relations: Vec<String>,
        names: Vec<String>,
    },
    ResourceExhaustion {
        resource_type: String,
        limit_name: String,
        desired: String,
        limit: String,
        current: String,
    },
    ResultSize(String),
    SafeModeViolation(String),
    WrongSetOfLocks,
    StatementTimeout,
    Canceled,
    IdleInTransactionSessionTimeout,
    SubscribeOnlyTransaction,
    Optimizer(OptimizerError),
    UnallowedOnCluster {
        depends_on: SmallVec<[String; 2]>,
        cluster: String,
    },
    Unauthorized(UnauthorizedError),
    UnknownCursor(String),
    UnknownLoginRole(String),
    UnknownPreparedStatement(String),
    UnknownClusterReplica {
        cluster_name: String,
        replica_name: String,
    },
    UnrecognizedConfigurationParam(String),
    Unstructured(Error),
    Unsupported(&'static str),
    UntargetedLogRead {
        log_names: Vec<String>,
    },
    WriteOnlyTransaction,
    SingleStatementTransaction,
    DDLOnlyTransaction,
    DDLTransactionRace,
    TransactionDryRun {
        new_ops: Vec<Op>,
        new_state: CatalogState,
    },
    Storage(StorageError<Timestamp>),
    Compute(Error),
    Orchestrator(Error),
    DependentObject(BTreeMap<String, Vec<String>>),
    InvalidAlter(&'static str, PlanError),
    ConnectionValidation(ConnectionValidationError),
    MaterializedViewWouldNeverRefresh(Timestamp, Timestamp),
    InputNotReadableAtRefreshAtTime(Timestamp, Antichain<Timestamp>),
    RtrTimeout(String),
    RtrDropFailure(String),
    UnreadableSinkCollection,
    UserSessionsDisallowed,
    NetworkPolicyDenied(NetworkPolicyError),
    ReadOnly,
    AlterClusterTimeout,
}

Errors that can occur in the coordinator.

Variants

AbsurdSubscribeBounds

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

Fields

as_of: Timestamp

up_to: Timestamp

AmbiguousSystemColumnReference

Attempted to use a potentially ambiguous column reference expression with a system table.

Catalog(Error)

An error occurred in a catalog operation.

ChangedPlan(String)

The cached plan or descriptor changed.

DuplicateCursor(String)

The cursor already exists.

Eval(EvalError)

An error while evaluating an expression.

Explain(ExplainError)

An error occurred while planning the statement.

IdExhaustionError

The ID allocator exhausted all valid IDs.

Internal(String)

Unexpected internal state was encountered.

IntrospectionDisabled

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

Fields

log_names: Vec<String>

InvalidLogDependency

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

Fields

object_type: String

log_names: Vec<String>

InvalidClusterReplicaAz

No such cluster replica size has been configured.

Fields

az: String

expected: Vec<String>

InvalidSetIsolationLevel

SET TRANSACTION ISOLATION LEVEL was called in the middle of a transaction.

InvalidSetCluster

SET cluster was called in the middle of a transaction.

InvalidStorageClusterSize

No such storage instance size has been configured.

Fields

size: String

expected: Vec<String>

SourceOrSinkSizeRequired

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

Fields

expected: Vec<String>

InvalidTableMutationSelection

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

ConstraintViolation(NotNullViolation)

Expression violated a column’s constraint

ConcurrentClusterDrop

Transaction cluster was dropped in the middle of a transaction.

NoClusterReplicasAvailable

Target cluster has no replicas to service query.

Fields

name: String

is_managed: bool

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(ParserStatementError)

Wrapper around parsing error

ReadOnlyTransaction

The transaction is in read-only mode.

ReadWriteUnavailable

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

RecursionLimit(RecursionLimitError)

The recursion limit of some operation was exceeded.

RelationOutsideTimeDomain

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

Fields

relations: Vec<String>

names: Vec<String>

ResourceExhaustion

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

Fields

resource_type: String

limit_name: String

desired: String

limit: String

current: String

ResultSize(String)

Result size of a query is too large.

SafeModeViolation(String)

The specified feature is not permitted in safe mode.

WrongSetOfLocks

The current transaction had the wrong set of write locks.

StatementTimeout

Waiting on a query timed out.

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

Canceled

The user canceled the query

IdleInTransactionSessionTimeout

An idle session in a transaction has timed out.

SubscribeOnlyTransaction

The transaction is in single-subscribe mode.

Optimizer(OptimizerError)

An error occurred in the optimizer.

UnallowedOnCluster

A query depends on items which are not allowed to be referenced from the current cluster.

Fields

depends_on: SmallVec<[String; 2]>

cluster: String

Unauthorized(UnauthorizedError)

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

UnknownCursor(String)

The named cursor does not exist.

UnknownLoginRole(String)

The named role does not exist.

UnknownPreparedStatement(String)

UnknownClusterReplica

The named cluster replica does not exist.

Fields

cluster_name: String

replica_name: String

UnrecognizedConfigurationParam(String)

The named setting does not exist.

Unstructured(Error)

A generic error occurred.

Unsupported(&'static str)

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

UntargetedLogRead

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

Fields

log_names: Vec<String>

WriteOnlyTransaction

The transaction is in write-only mode.

SingleStatementTransaction

The transaction can only execute a single statement.

DDLOnlyTransaction

The transaction can only execute simple DDL.

DDLTransactionRace

Another session modified the Catalog while this transaction was open.

TransactionDryRun

Used to prevent us from durably committing state while a DDL transaction is open, should never be returned to the user.

Fields

new_ops: Vec<Op>

New operations that were run in the transaction.

new_state: CatalogState

New resulting CatalogState.

Storage(StorageError<Timestamp>)

An error occurred in the storage layer

Compute(Error)

An error occurred in the compute layer

Orchestrator(Error)

An error in the orchestrator layer

DependentObject(BTreeMap<String, Vec<String>>)

A statement tried to drop a role that had dependent objects.

The map keys are role names and values are detailed error messages.

InvalidAlter(&'static str, PlanError)

When performing an ALTER of some variety, re-planning the statement errored.

ConnectionValidation(ConnectionValidationError)

An error occurred while validating a connection.

MaterializedViewWouldNeverRefresh(Timestamp, Timestamp)

We refuse to create the materialized view, because it would never be refreshed, so it would never be queryable. This can happen when the only specified refreshes are further back in the past than the initial compaction window of the materialized view.

InputNotReadableAtRefreshAtTime(Timestamp, Antichain<Timestamp>)

A CREATE MATERIALIZED VIEW statement tried to acquire a read hold at a REFRESH AT time, but was unable to get a precise read hold.

RtrTimeout(String)

A humanized version of StorageError::RtrTimeout.

RtrDropFailure(String)

A humanized version of StorageError::RtrDropFailure.

UnreadableSinkCollection

The collection requested to be sinked cannot be read at any timestamp

UserSessionsDisallowed

User sessions have been blocked.

NetworkPolicyDenied(NetworkPolicyError)

This use session has been deneid by a NetworkPolicy.

ReadOnly

Something attempted a write (to catalog, storage, tables, etc.) while in read-only mode.

AlterClusterTimeout

Implementations

impl AdapterError

pub fn into_response(self, severity: Severity) -> ErrorResponse

pub fn position(&self) -> Option<usize>

pub fn detail(&self) -> Option<String>

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

pub fn hint(&self) -> Option<String>

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

pub fn code(&self) -> SqlState

pub fn internal<E: Display>(context: &str, e: E) -> AdapterError

Trait Implementations

impl Debug for AdapterError

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

Formats the value using the given formatter.

impl Display for AdapterError

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

Formats the value using the given formatter.

impl Error for AdapterError

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<CatalogError> for AdapterError

fn from(e: CatalogError) -> Self

Converts to this type from the input type.

impl From<CatalogError> for AdapterError

fn from(e: CatalogError) -> AdapterError

Converts to this type from the input type.

impl From<ConnectionError> for AdapterError

fn from(value: ConnectionError) -> Self

Converts to this type from the input type.

impl From<ConnectionValidationError> for AdapterError

fn from(e: ConnectionValidationError) -> AdapterError

Converts to this type from the input type.

impl From<DurableCatalogError> for AdapterError

fn from(e: DurableCatalogError) -> Self

Converts to this type from the input type.

impl From<Error> for AdapterError

fn from(e: Error) -> AdapterError

Converts to this type from the input type.

impl From<Error> for AdapterError

fn from(e: Error) -> AdapterError

Converts to this type from the input type.

impl From<EvalError> for AdapterError

fn from(e: EvalError) -> AdapterError

Converts to this type from the input type.

impl From<ExplainError> for AdapterError

fn from(e: ExplainError) -> AdapterError

Converts to this type from the input type.

impl From<IdentError> for AdapterError

fn from(value: IdentError) -> Self

Converts to this type from the input type.

impl From<InstanceExists> for AdapterError

fn from(e: InstanceExists) -> Self

Converts to this type from the input type.

impl From<NetworkPolicyError> for AdapterError

fn from(value: NetworkPolicyError) -> Self

Converts to this type from the input type.

impl From<NotNullViolation> for AdapterError

fn from(e: NotNullViolation) -> AdapterError

Converts to this type from the input type.

impl From<OptimizerError> for AdapterError

fn from(e: OptimizerError) -> AdapterError

Converts to this type from the input type.

impl From<ParserStatementError> for AdapterError

fn from(e: ParserStatementError) -> Self

Converts to this type from the input type.

impl From<PlanError> for AdapterError

fn from(e: PlanError) -> AdapterError

Converts to this type from the input type.

impl From<RecursionLimitError> for AdapterError

fn from(e: RecursionLimitError) -> AdapterError

Converts to this type from the input type.

impl From<RecvError> for AdapterError

fn from(e: RecvError) -> AdapterError

Converts to this type from the input type.

impl From<StorageError<Timestamp>> for AdapterError

fn from(e: StorageError<Timestamp>) -> Self

Converts to this type from the input type.

impl From<TimeoutType> for AdapterError

fn from(timeout: TimeoutType) -> Self

Converts to this type from the input type.

impl From<TimestampError> for AdapterError

fn from(e: TimestampError) -> Self

Converts to this type from the input type.

impl From<TryFromDecimalError> for AdapterError

fn from(e: TryFromDecimalError) -> AdapterError

Converts to this type from the input type.

impl From<TryFromIntError> for AdapterError

fn from(e: TryFromIntError) -> AdapterError

Converts to this type from the input type.

impl From<UnauthorizedError> for AdapterError

fn from(e: UnauthorizedError) -> Self

Converts to this type from the input type.

impl From<VarError> for AdapterError

fn from(e: VarError) -> Self

Converts to this type from the input type.

impl ShouldTerminateGracefully for AdapterError

fn should_terminate_gracefully(&self) -> bool

Reports whether the error should terminate the process gracefully rather than panic.