Enum mz_coord::ExecuteResponse

source · [−]

pub enum ExecuteResponse {
Show 50 variants    TransactionExited {
        was_implicit: bool,
        tag: &'static str,
    },
    AlteredObject(ObjectType),
    AlteredIndexLogicalCompaction,
    Canceled,
    ClosedCursor,
    CopyTo {
        format: CopyFormat,
        resp: Box<ExecuteResponse>,
    },
    CopyFrom {
        id: GlobalId,
        columns: Vec<usize>,
        params: CopyFormatParams<'static>,
    },
    CreatedConnection {
        existed: bool,
    },
    CreatedDatabase {
        existed: bool,
    },
    CreatedSchema {
        existed: bool,
    },
    CreatedRole,
    CreatedComputeInstance {
        existed: bool,
    },
    CreatedComputeInstanceReplica {
        existed: bool,
    },
    CreatedIndex {
        existed: bool,
    },
    CreatedSecret {
        existed: bool,
    },
    CreatedSink {
        existed: bool,
    },
    CreatedSource {
        existed: bool,
    },
    CreatedSources,
    CreatedTable {
        existed: bool,
    },
    CreatedView {
        existed: bool,
    },
    CreatedType,
    Deallocate {
        all: bool,
    },
    DeclaredCursor,
    Deleted(usize),
    DiscardedTemp,
    DiscardedAll,
    DroppedConnection,
    DroppedComputeInstance,
    DroppedComputeInstanceReplicas,
    DroppedDatabase,
    DroppedRole,
    DroppedSchema,
    DroppedSource,
    DroppedTable,
    DroppedView,
    DroppedRecordedView,
    DroppedIndex,
    DroppedSink,
    DroppedType,
    DroppedSecret,
    EmptyQuery,
    Fetch {
        name: String,
        count: Option<FetchDirection>,
        timeout: ExecuteTimeout,
    },
    Inserted(usize),
    Prepare,
    SendingRows {
        future: RowsFuture,
        span: Span,
    },
    SetVariable {
        name: String,
        tag: &'static str,
    },
    StartedTransaction {
        duplicated: bool,
    },
    Tailing {
        rx: RowBatchStream,
    },
    Updated(usize),
    Raise {
        severity: NoticeSeverity,
    },
}

Expand description

The response to SessionClient::execute.

Variants

`TransactionExited`

Fields

was_implicit: bool

tag: &'static str

The active transaction was exited.

`AlteredObject(ObjectType)`

`AlteredIndexLogicalCompaction`

`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`

Fields

existed: bool

The requested connection was created.

`CreatedDatabase`

Fields

existed: bool

The requested database was created.

`CreatedSchema`

Fields

existed: bool

The requested schema was created.

`CreatedRole`

The requested role was created.

`CreatedComputeInstance`

Fields

existed: bool

The requested compute instance was created.

`CreatedComputeInstanceReplica`

Fields

existed: bool

The requested compute instance replica was created.

`CreatedIndex`

Fields

existed: bool

The requested index was created.

`CreatedSecret`

Fields

existed: bool

The requested secret was created.

`CreatedSink`

Fields

existed: bool

The requested sink was created.

`CreatedSource`

Fields

existed: bool

The requested source was created.

`CreatedSources`

The requested sources were created.

`CreatedTable`

Fields

existed: bool

The requested table was created.

`CreatedView`

Fields

existed: bool

The requested 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

`DroppedComputeInstance`

The requested compute instance was dropped.

`DroppedComputeInstanceReplicas`

The requested compute instance replicas were 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.

`DroppedRecordedView`

The requested recorded 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.

`SendingRows`

Fields

future: RowsFuture

span: Span

Rows will be delivered via the specified future.

`SetVariable`

Fields

name: String

tag: &'static str

The specified variable was set to a new value.

`StartedTransaction`

Fields

duplicated: bool

A new transaction was started.

`Tailing`

Fields

rx: RowBatchStream

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

`Updated(usize)`

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

`Raise`

Fields

severity: NoticeSeverity

Raise a warning.

Trait Implementations

source

impl Debug for ExecuteResponse

source

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

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> Any for T where
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

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

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

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

const: unstable · source

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

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · 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 for T where
U: From<T>,

const: unstable · 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<T> Same<T> for T

type Output = T

Should always be Self

source

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

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

source

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

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::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