Enum mz_adapter::command::ExecuteResponse
source · pub enum ExecuteResponse {
Show 51 variants
AlteredDefaultPrivileges,
AlteredObject(ObjectType),
AlteredRole,
AlteredSystemConfiguration,
ClosedCursor,
Comment,
Copied(usize),
CopyTo {
format: CopyFormat,
resp: Box<ExecuteResponse>,
},
CopyFrom {
id: GlobalId,
columns: Vec<usize>,
params: CopyFormatParams<'static>,
ctx_extra: ExecuteContextExtra,
},
CreatedConnection,
CreatedDatabase,
CreatedSchema,
CreatedRole,
CreatedCluster,
CreatedClusterReplica,
CreatedIndex,
CreatedIntrospectionSubscribe,
CreatedSecret,
CreatedSink,
CreatedSource,
CreatedTable,
CreatedView,
CreatedViews,
CreatedMaterializedView,
CreatedType,
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.
CopyFrom
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.
CreatedType
The requested type was created.
Deallocate
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.
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
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.
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
TransactionRolledBack
The active transaction rolled back.
Fields
Updated(usize)
The specified number of rows were updated in the requested table.
ValidatedConnection
A connection was validated.
Implementations§
source§impl ExecuteResponse
impl ExecuteResponse
pub fn tag(&self) -> Option<String>
sourcepub fn generated_from(plan: &PlanKind) -> &'static [ExecuteResponseKind]
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
impl Debug for ExecuteResponse
source§impl<'__enum_kinds1> From<&'__enum_kinds1 ExecuteResponse> for ExecuteResponseKind
impl<'__enum_kinds1> From<&'__enum_kinds1 ExecuteResponse> for ExecuteResponseKind
source§fn from(_value: &'__enum_kinds1 ExecuteResponse) -> Self
fn from(_value: &'__enum_kinds1 ExecuteResponse) -> Self
source§impl From<&ExecuteResponse> for StatementEndedExecutionReason
impl From<&ExecuteResponse> for StatementEndedExecutionReason
source§fn from(value: &ExecuteResponse) -> StatementEndedExecutionReason
fn from(value: &ExecuteResponse) -> StatementEndedExecutionReason
source§impl<'__enum_kinds1> From<ExecuteResponse> for ExecuteResponseKind
impl<'__enum_kinds1> From<ExecuteResponse> for ExecuteResponseKind
source§fn from(value: ExecuteResponse) -> Self
fn from(value: ExecuteResponse) -> Self
source§impl From<PendingTxnResponse> for ExecuteResponse
impl From<PendingTxnResponse> for ExecuteResponse
source§fn from(value: PendingTxnResponse) -> Self
fn from(value: PendingTxnResponse) -> Self
source§impl From<UpdatePrivilegeVariant> for ExecuteResponse
impl From<UpdatePrivilegeVariant> for ExecuteResponse
source§fn from(variant: UpdatePrivilegeVariant) -> Self
fn from(variant: UpdatePrivilegeVariant) -> Self
source§impl Transmittable for ExecuteResponse
impl Transmittable for ExecuteResponse
This implementation is meant to ensure that we maintain updated information
about which types of ExecuteResponse
s are permitted to be sent, which will
be a function of which plan we’re executing.
§type Allowed = ExecuteResponseKind
type Allowed = ExecuteResponseKind
source§fn to_allowed(&self) -> Self::Allowed
fn to_allowed(&self) -> Self::Allowed
source§impl TryInto<ExecuteResponse> for ExecuteResponseKind
impl TryInto<ExecuteResponse> for ExecuteResponseKind
Auto Trait Implementations§
impl Freeze for ExecuteResponse
impl !RefUnwindSafe for ExecuteResponse
impl Send for ExecuteResponse
impl !Sync for ExecuteResponse
impl Unpin for ExecuteResponse
impl !UnwindSafe for ExecuteResponse
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<T> FmtForward for T
impl<T> FmtForward for T
source§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
self
to use its Binary
implementation when Debug
-formatted.source§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
self
to use its Display
implementation when
Debug
-formatted.source§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
self
to use its LowerExp
implementation when
Debug
-formatted.source§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
self
to use its LowerHex
implementation when
Debug
-formatted.source§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
self
to use its Octal
implementation when Debug
-formatted.source§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
self
to use its Pointer
implementation when
Debug
-formatted.source§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
self
to use its UpperExp
implementation when
Debug
-formatted.source§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
self
to use its UpperHex
implementation when
Debug
-formatted.source§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, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
source§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
source§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
source§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moresource§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
self
and passes that borrow into the pipe function. Read moresource§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
source§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
source§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
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
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
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
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
self
, then passes self.deref()
into the pipe function.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
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
std::ops::AddAssign
, for types that do not implement AddAssign
.source§impl<T> Tap for T
impl<T> Tap for T
source§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Borrow<B>
of a value. Read moresource§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
BorrowMut<B>
of a value. Read moresource§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
AsRef<R>
view of a value. Read moresource§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
AsMut<R>
view of a value. Read moresource§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Deref::Target
of a value. Read moresource§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Deref::Target
of a value. Read moresource§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
.tap()
only in debug builds, and is erased in release builds.source§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
.tap_mut()
only in debug builds, and is erased in release
builds.source§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
.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
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
.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
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
.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
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
.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
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
.tap_deref()
only in debug builds, and is erased in release
builds.