Enum mz_adapter::coord::Message
source · pub enum Message<T = Timestamp> {
Show 32 variants
Command(OpenTelemetryContext, Command),
ControllerReady,
PurifiedStatementReady(BackgroundWorkResult<PurifiedStatement>),
CreateConnectionValidationReady(ValidationReady<CreateConnectionPlan>),
AlterConnectionValidationReady(ValidationReady<Connection>),
WriteLockGrant(OwnedMutexGuard<()>),
GroupCommitInitiate(Span, Option<GroupCommitPermit>),
GroupCommitApply(T, Vec<CompletedClientTransmitter>, Option<OwnedMutexGuard<()>>, Option<GroupCommitPermit>),
DeferredStatementReady,
AdvanceTimelines,
ClusterEvent(ClusterEvent),
CancelPendingPeeks {
conn_id: ConnectionId,
},
LinearizeReads,
StorageUsageSchedule,
StorageUsageFetch,
StorageUsageUpdate(ShardsUsageReferenced),
StorageUsagePrune(Vec<BuiltinTableUpdate>),
RetireExecute {
data: ExecuteContextExtra,
otel_ctx: OpenTelemetryContext,
reason: StatementEndedExecutionReason,
},
ExecuteSingleStatementTransaction {
ctx: ExecuteContext,
otel_ctx: OpenTelemetryContext,
stmt: Arc<Statement<Raw>>,
params: Params,
},
PeekStageReady {
ctx: ExecuteContext,
span: Span,
stage: PeekStage,
},
CreateIndexStageReady {
ctx: ExecuteContext,
span: Span,
stage: CreateIndexStage,
},
CreateViewStageReady {
ctx: ExecuteContext,
span: Span,
stage: CreateViewStage,
},
CreateMaterializedViewStageReady {
ctx: ExecuteContext,
span: Span,
stage: CreateMaterializedViewStage,
},
SubscribeStageReady {
ctx: ExecuteContext,
span: Span,
stage: SubscribeStage,
},
IntrospectionSubscribeStageReady {
span: Span,
stage: IntrospectionSubscribeStage,
},
SecretStageReady {
ctx: ExecuteContext,
span: Span,
stage: SecretStage,
},
ClusterStageReady {
ctx: ExecuteContext,
span: Span,
stage: ClusterStage,
},
ExplainTimestampStageReady {
ctx: ExecuteContext,
span: Span,
stage: ExplainTimestampStage,
},
DrainStatementLog,
PrivateLinkVpcEndpointEvents(Vec<VpcEndpointEvent>),
CheckSchedulingPolicies,
SchedulingDecisions(Vec<(&'static str, Vec<(ClusterId, SchedulingDecision)>)>),
}
Variants§
Command(OpenTelemetryContext, Command)
ControllerReady
PurifiedStatementReady(BackgroundWorkResult<PurifiedStatement>)
CreateConnectionValidationReady(ValidationReady<CreateConnectionPlan>)
AlterConnectionValidationReady(ValidationReady<Connection>)
WriteLockGrant(OwnedMutexGuard<()>)
GroupCommitInitiate(Span, Option<GroupCommitPermit>)
Initiates a group commit.
GroupCommitApply(T, Vec<CompletedClientTransmitter>, Option<OwnedMutexGuard<()>>, Option<GroupCommitPermit>)
Makes a group commit visible to all clients.
Tuple Fields
§
0: T
Timestamp of the writes in the group commit.
§
1: Vec<CompletedClientTransmitter>
Clients waiting on responses from the group commit.
§
2: Option<OwnedMutexGuard<()>>
Optional lock if the group commit contained writes to user tables.
§
3: Option<GroupCommitPermit>
Permit which limits how many group commits we run at once.
DeferredStatementReady
AdvanceTimelines
ClusterEvent(ClusterEvent)
CancelPendingPeeks
Fields
§
conn_id: ConnectionId
LinearizeReads
StorageUsageSchedule
StorageUsageFetch
StorageUsageUpdate(ShardsUsageReferenced)
StorageUsagePrune(Vec<BuiltinTableUpdate>)
RetireExecute
Performs any cleanup and logging actions necessary for finalizing a statement execution.
Fields
§
data: ExecuteContextExtra
§
otel_ctx: OpenTelemetryContext
§
reason: StatementEndedExecutionReason
ExecuteSingleStatementTransaction
PeekStageReady
CreateIndexStageReady
CreateViewStageReady
CreateMaterializedViewStageReady
SubscribeStageReady
IntrospectionSubscribeStageReady
SecretStageReady
ClusterStageReady
ExplainTimestampStageReady
DrainStatementLog
PrivateLinkVpcEndpointEvents(Vec<VpcEndpointEvent>)
CheckSchedulingPolicies
SchedulingDecisions(Vec<(&'static str, Vec<(ClusterId, SchedulingDecision)>)>)
Scheduling policy decisions about turning clusters On/Off.
Vec<(policy name, Vec of decisions by the policy)>
A cluster will be On if and only if there is at least one On decision for it.
Scheduling decisions for clusters that have SCHEDULE = MANUAL
are ignored.
Implementations§
Trait Implementations§
Auto Trait Implementations§
impl<T = Timestamp> !Freeze for Message<T>
impl<T = Timestamp> !RefUnwindSafe for Message<T>
impl<T> Send for Message<T>where
T: Send,
impl<T> Sync for Message<T>where
T: Sync,
impl<T> Unpin for Message<T>where
T: Unpin,
impl<T = Timestamp> !UnwindSafe for Message<T>
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
Mutably borrows from an owned value. Read more
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,
Causes
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,
Causes
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,
Causes
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,
Causes
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,
Causes
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,
Causes
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,
Causes
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,
Causes
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>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
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,
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) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
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,
Mutably borrows
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
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
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
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
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
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>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
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)
The method of
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
Immutable access to the
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
Mutable access to the
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
Immutable access to the
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
Mutable access to the
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
Immutable access to the
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
Mutable access to the
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
Calls
.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
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
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
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
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
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
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
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
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
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
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref()
only in debug builds, and is erased in release
builds.