Enum mz_adapter::ExecuteResponse

pub enum ExecuteResponse {
    AlteredObject(ObjectType),
    AlteredIndexLogicalCompaction,
    AlteredSystemConfiguration,
    Canceled,
    ClosedCursor,
    CopyTo {
        format: CopyFormat,
        resp: Box<ExecuteResponse>,
    },
    CopyFrom {
        id: GlobalId,
        columns: Vec<usize>,
        params: CopyFormatParams<'static>,
    },
    CreatedConnection,
    CreatedDatabase,
    CreatedSchema,
    CreatedRole,
    CreatedCluster,
    CreatedClusterReplica,
    CreatedIndex,
    CreatedSecret,
    CreatedSink,
    CreatedSource,
    CreatedSources,
    CreatedTable,
    CreatedView,
    CreatedViews,
    CreatedMaterializedView,
    CreatedType,
    Deallocate {
        all: bool,
    },
    DeclaredCursor,
    Deleted(usize),
    DiscardedTemp,
    DiscardedAll,
    DroppedConnection,
    DroppedCluster,
    DroppedClusterReplica,
    DroppedDatabase,
    DroppedRole,
    DroppedSchema,
    DroppedSource,
    DroppedTable,
    DroppedView,
    DroppedMaterializedView,
    DroppedIndex,
    DroppedSink,
    DroppedType,
    DroppedSecret,
    EmptyQuery,
    Fetch {
        name: String,
        count: Option<FetchDirection>,
        timeout: ExecuteTimeout,
    },
    Inserted(usize),
    Prepare,
    Raised,
    SendingRows {
        future: RowsFuture,
        span: Span,
    },
    SetVariable {
        name: String,
        reset: bool,
    },
    StartedTransaction,
    Subscribing {
        rx: RowBatchStream,
    },
    TransactionCommitted,
    TransactionRolledBack,
    Updated(usize),
}

The response to SessionClient::execute.

Variants

AlteredObject(ObjectType)

The requested object was altered.

AlteredIndexLogicalCompaction

The index was altered.

AlteredSystemConfiguration

The system configuration was altered.

Canceled

The query was canceled.

ClosedCursor

The requested cursor was closed.

CopyTo

Fields

format: CopyFormat

resp: Box<ExecuteResponse>

CopyFrom

Fields

id: GlobalId

columns: Vec<usize>

params: CopyFormatParams<'static>

CreatedConnection

The requested connection was created.

CreatedDatabase

The requested database was created.

CreatedSchema

The requested schema was created.

CreatedRole

The requested role was created.

CreatedCluster

The requested cluster was created.

CreatedClusterReplica

The requested cluster replica was created.

CreatedIndex

The requested index was created.

CreatedSecret

The requested secret was created.

CreatedSink

The requested sink was created.

CreatedSource

The requested source was created.

CreatedSources

The requested sources were created.

CreatedTable

The requested table was created.

CreatedView

The requested view was created.

CreatedViews

The requested views were created.

CreatedMaterializedView

The requested materialized view was created.

CreatedType

The requested type was created.

Deallocate

Fields

all: bool

The requested prepared statement was removed.

DeclaredCursor

The requested cursor was declared.

Deleted(usize)

The specified number of rows were deleted from the requested table.

DiscardedTemp

The temporary objects associated with the session have been discarded.

DiscardedAll

All state associated with the session has been discarded.

DroppedConnection

The requested connection was dropped

DroppedCluster

The requested cluster was dropped.

DroppedClusterReplica

The requested cluster replica was dropped.

DroppedDatabase

The requested database was dropped.

DroppedRole

The requested role was dropped.

DroppedSchema

The requested schema was dropped.

DroppedSource

The requested source was dropped.

DroppedTable

The requested table was dropped.

DroppedView

The requested view was dropped.

DroppedMaterializedView

The requested materialized view was dropped.

DroppedIndex

The requested index was dropped.

DroppedSink

The requested sink was dropped.

DroppedType

The requested type was dropped.

DroppedSecret

The requested secret was dropped.

EmptyQuery

The provided query was empty.

Fetch

Fields

name: String

The name of the cursor from which to fetch results.

count: Option<FetchDirection>

The number of results to fetch.

timeout: ExecuteTimeout

How long to wait for results to arrive.

Fetch results from a cursor.

Inserted(usize)

The specified number of rows were inserted into the requested table.

Prepare

The specified prepared statement was created.

Raised

A user-requested warning was raised.

SendingRows

Fields

future: RowsFuture

span: Span

Rows will be delivered via the specified future.

SetVariable

Fields

name: String

reset: bool

Whether the operation was a RESET rather than a set.

The specified variable was set to a new value.

StartedTransaction

A new transaction was started.

Subscribing

Fields

rx: RowBatchStream

Updates to the requested source or view will be streamed to the contained receiver.

TransactionCommitted

The active transaction committed.

TransactionRolledBack

The active transaction rolled back.

Updated(usize)

The specified number of rows were updated in the requested table.

Implementations

impl ExecuteResponse

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

pub fn generated_from(plan: PlanKind) -> Vec<ExecuteResponseKind>

Expresses which PlanKind generate which set of ExecuteResponseKind.

Trait Implementations

impl Debug for ExecuteResponse

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

Formats the value using the given formatter.

impl<'__enum_kinds1> From<&'__enum_kinds1 ExecuteResponse> for ExecuteResponseKind

fn from(_value: &'__enum_kinds1 ExecuteResponse) -> Self

Converts to this type from the input type.

impl<'__enum_kinds1> From<ExecuteResponse> for ExecuteResponseKind

fn from(value: ExecuteResponse) -> Self

Converts to this type from the input type.

impl Transmittable for ExecuteResponse

This implementation is meant to ensure that we maintain updated information about which types of ExecuteResponses are permitted to be sent, which will be a function of which plan we’re executing.

type Allowed = ExecuteResponseKind

The type of values used to express which set of values are allowed.

fn to_allowed(&self) -> Self::Allowed

The conversion from the ClientTransmitter’s type to Allowed.