Struct mz_storage::source::types::DecodeResult

pub struct DecodeResult<FromTime> {
    pub key: Option<Result<Row, DecodeError>>,
    pub value: Option<Result<Row, DecodeError>>,
    pub metadata: Row,
    pub from_time: FromTime,
}

The output of the decoding operator

Fields

key: Option<Result<Row, DecodeError>>

The decoded key

value: Option<Result<Row, DecodeError>>

The decoded value, as well as the the differential diff value for this value, if the value is present and not and error.

metadata: Row

Additional metadata requested by the user

from_time: FromTime

The original timestamp of this message

Trait Implementations

impl<FromTime: Clone> Clone for DecodeResult<FromTime>

fn clone(&self) -> DecodeResult<FromTime>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<FromTime: Debug> Debug for DecodeResult<FromTime>

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

Formats the value using the given formatter.

impl<'de, FromTime> Deserialize<'de> for DecodeResult<FromTime>

where FromTime: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<FromTime: Hash> Hash for DecodeResult<FromTime>

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<FromTime: PartialEq> PartialEq for DecodeResult<FromTime>

fn eq(&self, other: &DecodeResult<FromTime>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<FromTime> Serialize for DecodeResult<FromTime>

where FromTime: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<FromTime: Eq> Eq for DecodeResult<FromTime>

impl<FromTime> StructuralPartialEq for DecodeResult<FromTime>