Struct mz_dataflow_types::client::Peek
source · [−]pub struct Peek<T = Timestamp> {
pub id: GlobalId,
pub key: Option<Row>,
pub uuid: Uuid,
pub timestamp: T,
pub finishing: RowSetFinishing,
pub map_filter_project: SafeMfpPlan,
pub target_replica: Option<ReplicaId>,
pub otel_ctx: OpenTelemetryContext,
}
Expand description
Peek at an arrangement.
This request elicits data from the worker, by naming an arrangement and some actions to apply to the results before returning them.
The timestamp
member must be valid for the arrangement that
is referenced by id
. This means that AllowCompaction
for
this arrangement should not pass timestamp
before this command.
Subsequent commands may arbitrarily compact the arrangements;
the dataflow runners are responsible for ensuring that they can
correctly answer the Peek
.
Fields
id: GlobalId
The identifier of the arrangement.
key: Option<Row>
An optional key that should be used for the arrangement.
uuid: Uuid
The identifier of this peek request.
Used in responses and cancellation requests.
timestamp: T
The logical timestamp at which the arrangement is queried.
finishing: RowSetFinishing
Actions to apply to the result set before returning them.
map_filter_project: SafeMfpPlan
Linear operation to apply in-line on each result.
target_replica: Option<ReplicaId>
Target replica of this peek.
If Some
, the peek is only handled by the given replica.
If None
, the peek is handled by all replicas.
otel_ctx: OpenTelemetryContext
An OpenTelemetryContext
to forward trace information along
to the compute worker to allow associating traces between
the compute controller and the compute worker.
Trait Implementations
sourceimpl<T: Arbitrary> Arbitrary for Peek<T>
impl<T: Arbitrary> Arbitrary for Peek<T>
type Parameters = (<GlobalId as Arbitrary>::Parameters, <Option<Row> as Arbitrary>::Parameters, <T as Arbitrary>::Parameters, <RowSetFinishing as Arbitrary>::Parameters, <SafeMfpPlan as Arbitrary>::Parameters, <Option<ReplicaId> as Arbitrary>::Parameters)
type Parameters = (<GlobalId as Arbitrary>::Parameters, <Option<Row> as Arbitrary>::Parameters, <T as Arbitrary>::Parameters, <RowSetFinishing as Arbitrary>::Parameters, <SafeMfpPlan as Arbitrary>::Parameters, <Option<ReplicaId> as Arbitrary>::Parameters)
The type of parameters that arbitrary_with
accepts for configuration
of the generated Strategy
. Parameters must implement Default
. Read more
type Strategy = Map<(<GlobalId as Arbitrary>::Strategy, <Option<Row> as Arbitrary>::Strategy, BoxedStrategy<Uuid>, <T as Arbitrary>::Strategy, <RowSetFinishing as Arbitrary>::Strategy, <SafeMfpPlan as Arbitrary>::Strategy, <Option<ReplicaId> as Arbitrary>::Strategy, BoxedStrategy<OpenTelemetryContext>), fn(_: (GlobalId, Option<Row>, Uuid, T, RowSetFinishing, SafeMfpPlan, Option<ReplicaId>, OpenTelemetryContext)) -> Self>
type Strategy = Map<(<GlobalId as Arbitrary>::Strategy, <Option<Row> as Arbitrary>::Strategy, BoxedStrategy<Uuid>, <T as Arbitrary>::Strategy, <RowSetFinishing as Arbitrary>::Strategy, <SafeMfpPlan as Arbitrary>::Strategy, <Option<ReplicaId> as Arbitrary>::Strategy, BoxedStrategy<OpenTelemetryContext>), fn(_: (GlobalId, Option<Row>, Uuid, T, RowSetFinishing, SafeMfpPlan, Option<ReplicaId>, OpenTelemetryContext)) -> Self>
sourcefn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy
sourceimpl<'de, T> Deserialize<'de> for Peek<T> where
T: Deserialize<'de>,
impl<'de, T> Deserialize<'de> for Peek<T> where
T: Deserialize<'de>,
sourcefn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
sourceimpl RustType<ProtoPeek> for Peek
impl RustType<ProtoPeek> for Peek
sourcefn into_proto(&self) -> ProtoPeek
fn into_proto(&self) -> ProtoPeek
Convert a Self
into a Proto
value.
sourcefn from_proto(x: ProtoPeek) -> Result<Self, TryFromProtoError>
fn from_proto(x: ProtoPeek) -> Result<Self, TryFromProtoError>
Consume and convert a Proto
back into a Self
value. Read more
impl<T> StructuralPartialEq for Peek<T>
Auto Trait Implementations
impl<T> RefUnwindSafe for Peek<T> where
T: RefUnwindSafe,
impl<T> Send for Peek<T> where
T: Send,
impl<T> Sync for Peek<T> where
T: Sync,
impl<T> Unpin for Peek<T> where
T: Unpin,
impl<T> UnwindSafe for Peek<T> where
T: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> FutureExt for T
impl<T> FutureExt for T
sourcefn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
sourcefn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T
in a tonic::Request
sourceimpl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
impl<T> ProgressEventTimestamp for T where
T: Data + Debug + Any,
sourceimpl<P, R> ProtoType<R> for P where
R: RustType<P>,
impl<P, R> ProtoType<R> for P where
R: RustType<P>,
sourcefn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See RustType::from_proto
.
sourcefn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See RustType::into_proto
.
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more