Enum mz_adapter::ExecuteResponse

source · 
pub enum ExecuteResponse {

Show 53 variants    AlteredDefaultPrivileges,
    AlteredObject(ObjectType),
    AlteredRole,
    AlteredSystemConfiguration,
    ClosedCursor,
    Comment,
    Copied(usize),
    CopyTo {
        format: CopyFormat,
        resp: Box<ExecuteResponse>,
    },
    CopyFrom {
        id: CatalogItemId,
        columns: Vec<usize>,
        params: CopyFormatParams<'static>,
        ctx_extra: ExecuteContextExtra,
    },
    CreatedConnection,
    CreatedDatabase,
    CreatedSchema,
    CreatedRole,
    CreatedCluster,
    CreatedClusterReplica,
    CreatedIndex,
    CreatedIntrospectionSubscribe,
    CreatedSecret,
    CreatedSink,
    CreatedSource,
    CreatedTable,
    CreatedView,
    CreatedViews,
    CreatedMaterializedView,
    CreatedContinualTask,
    CreatedType,
    CreatedNetworkPolicy,
    Deallocate {
        all: bool,
    },
    DeclaredCursor,
    Deleted(usize),
    DiscardedTemp,
    DiscardedAll,
    DroppedObject(ObjectType),
    DroppedOwned,
    EmptyQuery,
    Fetch {
        name: String,
        count: Option<FetchDirection>,
        timeout: ExecuteTimeout,
        ctx_extra: ExecuteContextExtra,
    },
    GrantedPrivilege,
    GrantedRole,
    Inserted(usize),
    Prepare,
    Raised,
    ReassignOwned,
    RevokedPrivilege,
    RevokedRole,
    SendingRows {
        future: RowsFuture,
        instance_id: ComputeInstanceId,
        strategy: StatementExecutionStrategy,
    },
    SendingRowsImmediate {
        rows: Box<dyn RowIterator + Send + Sync>,
    },
    SetVariable {
        name: String,
        reset: bool,
    },
    StartedTransaction,
    Subscribing {
        rx: RowBatchStream,
        ctx_extra: ExecuteContextExtra,
        instance_id: ComputeInstanceId,
    },
    TransactionCommitted {
        params: BTreeMap<&'static str, String>,
    },
    TransactionRolledBack {
        params: BTreeMap<&'static str, String>,
    },
    Updated(usize),
    ValidatedConnection,

}
Expand description

The response to SessionClient::execute.

Variants§

§

AlteredDefaultPrivileges

The default privileges were altered.

§

AlteredObject(ObjectType)

The requested object was altered.

§

AlteredRole

The role was altered.

§

AlteredSystemConfiguration

The system configuration was altered.

§

ClosedCursor

The requested cursor was closed.

§

Comment

The provided comment was created.

§

Copied(usize)

The specified number of rows were copied into the requested output.

§

CopyTo

The response for a COPY TO STDOUT query.

Fields

§format: CopyFormat
§resp: Box<ExecuteResponse>
§

CopyFrom

Fields

§id: CatalogItemId
§columns: Vec<usize>
§params: CopyFormatParams<'static>
§ctx_extra: ExecuteContextExtra
§

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.

§

CreatedIntrospectionSubscribe

The requested introspection subscribe was created.

§

CreatedSecret

The requested secret was created.

§

CreatedSink

The requested sink was created.

§

CreatedSource

The requested source was 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.

§

CreatedContinualTask

The requested continual task was created.

§

CreatedType

The requested type was created.

§

CreatedNetworkPolicy

The requested network policy was created.

§

Deallocate

The requested prepared statement was removed.

Fields

§all: bool
§

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.

§

DroppedObject(ObjectType)

The requested object was dropped.

§

DroppedOwned

The requested objects were dropped.

§

EmptyQuery

The provided query was empty.

§

Fetch

Fetch results from a cursor.

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.

§ctx_extra: ExecuteContextExtra
§

GrantedPrivilege

The requested privilege was granted.

§

GrantedRole

The requested role was granted.

§

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.

§

ReassignOwned

The requested objects were reassigned.

§

RevokedPrivilege

The requested privilege was revoked.

§

RevokedRole

The requested role was revoked.

§

SendingRows

Rows will be delivered via the specified future.

§

SendingRowsImmediate

Like SendingRows, but the rows are known to be available immediately, and thus the execution is considered ended in the coordinator.

Fields

§rows: Box<dyn RowIterator + Send + Sync>
§

SetVariable

The specified variable was set to a new value.

Fields

§name: String
§reset: bool

Whether the operation was a RESET rather than a set.

§

StartedTransaction

A new transaction was started.

§

Subscribing

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

§

TransactionCommitted

The active transaction committed.

Fields

§params: BTreeMap<&'static str, String>

Session parameters that changed because the transaction ended.

§

TransactionRolledBack

The active transaction rolled back.

Fields

§params: BTreeMap<&'static str, String>

Session parameters that changed because the transaction ended.

§

Updated(usize)

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

§

ValidatedConnection

A connection was validated.

Implementations§

source§

impl ExecuteResponse

source

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

source

pub fn generated_from(plan: &PlanKind) -> &'static [ExecuteResponseKind]

Expresses which PlanKind generate which set of ExecuteResponseKind. ExecuteResponseKind::Canceled could be generated at any point as well, but that is excluded from this function.

Trait Implementations§

source§

impl Debug for ExecuteResponse

source§

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

Formats the value using the given formatter. Read more
source§

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

source§

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

Converts to this type from the input type.
source§

impl From<&ExecuteResponse> for StatementEndedExecutionReason

source§

fn from(value: &ExecuteResponse) -> StatementEndedExecutionReason

Converts to this type from the input type.
source§

impl<'__enum_kinds1> From<ExecuteResponse> for ExecuteResponseKind

source§

fn from(value: ExecuteResponse) -> Self

Converts to this type from the input type.
source§

impl From<PendingTxnResponse> for ExecuteResponse

source§

fn from(value: PendingTxnResponse) -> Self

Converts to this type from the input type.
source§

impl From<UpdatePrivilegeVariant> for ExecuteResponse

source§

fn from(variant: UpdatePrivilegeVariant) -> Self

Converts to this type from the input type.
source§

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.
source§

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

The conversion from the ClientTransmitter’s type to Allowed. Read more
source§

impl TryFrom<&Statement<Raw>> for ExecuteResponse

source§

fn try_from(stmt: &Statement<Raw>) -> Result<Self, Self::Error>

Returns Ok if this Statement always produces a single, trivial ExecuteResponse.

§

type Error = ()

The type returned in the event of a conversion error.
source§

impl TryInto<ExecuteResponse> for ExecuteResponseKind

source§

fn try_into(self) -> Result<ExecuteResponse, Self::Error>

Attempts to convert into an ExecuteResponse. Returns an error if not possible without actually executing a statement.

§

type Error = ()

The type returned in the event of a conversion error.

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> AsAny for T
where T: Any,

source§

fn as_any(&self) -> &(dyn Any + 'static)

source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T, U> CastInto<U> for T
where U: CastFrom<T>,

source§

fn cast_into(self) -> U

Performs the cast.
source§

impl<T> Conv for T

source§

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more
source§

impl<T> CopyAs<T> for T

source§

fn copy_as(self) -> T

source§

impl<T> FmtForward for T

source§

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.
source§

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.
source§

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.
source§

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.
source§

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.
source§

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.
source§

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.
source§

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.
source§

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> FutureExt for T

source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

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

source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T, U> OverrideFrom<Option<&T>> for U
where U: OverrideFrom<T>,

source§

fn override_from(self, layer: &Option<&T>) -> U

Override the configuration represented by Self with values from the given layer.
source§

impl<T> Pipe for T
where T: ?Sized,

source§

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more
source§

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more
source§

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more
source§

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more
source§

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more
source§

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.
source§

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.
source§

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.
source§

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.
source§

impl<T> Pointable for T

source§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<P, R> ProtoType<R> for P
where R: RustType<P>,

source§

fn into_rust(self) -> Result<R, TryFromProtoError>

See RustType::from_proto.
source§

fn from_rust(rust: &R) -> P

See RustType::into_proto.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<'a, S, T> Semigroup<&'a S> for T
where T: Semigroup<S>,

source§

fn plus_equals(&mut self, rhs: &&'a S)

The method of std::ops::AddAssign, for types that do not implement AddAssign.
source§

impl<T> Tap for T

source§

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more
source§

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more
source§

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more
source§

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more
source§

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more
source§

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more
source§

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more
source§

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more
source§

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.
source§

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.
source§

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.
source§

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.
source§

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.
source§

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.
source§

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.
source§

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.
source§

impl<T> TryConv for T

source§

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more