Struct mz_storage::render::upsert::UpsertSourceData
source · struct UpsertSourceData {
value: Option<Result<Row, UpsertError>>,
position: MzOffset,
upstream_time_millis: Option<i64>,
metadata: Row,
}
Fields§
§value: Option<Result<Row, UpsertError>>
The actual value
position: MzOffset
The source’s reported position for this record
upstream_time_millis: Option<i64>
The time that the upstream source believes that the message was created Currently only applies to Kafka
metadata: Row
Metadata for this row
Trait Implementations§
source§impl Clone for UpsertSourceData
impl Clone for UpsertSourceData
source§fn clone(&self) -> UpsertSourceData
fn clone(&self) -> UpsertSourceData
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for UpsertSourceData
impl Debug for UpsertSourceData
source§impl Default for UpsertSourceData
impl Default for UpsertSourceData
source§fn default() -> UpsertSourceData
fn default() -> UpsertSourceData
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for UpsertSourceData
impl<'de> Deserialize<'de> for UpsertSourceData
source§fn 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
source§impl Hash for UpsertSourceData
impl Hash for UpsertSourceData
source§impl PartialEq<UpsertSourceData> for UpsertSourceData
impl PartialEq<UpsertSourceData> for UpsertSourceData
source§fn eq(&self, other: &UpsertSourceData) -> bool
fn eq(&self, other: &UpsertSourceData) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl Serialize for UpsertSourceData
impl Serialize for UpsertSourceData
impl Eq for UpsertSourceData
impl StructuralEq for UpsertSourceData
impl StructuralPartialEq for UpsertSourceData
Auto Trait Implementations§
impl RefUnwindSafe for UpsertSourceData
impl Send for UpsertSourceData
impl Sync for UpsertSourceData
impl Unpin for UpsertSourceData
impl UnwindSafe for UpsertSourceData
Blanket Implementations§
source§impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.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
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
.