Struct Row 

pub struct Row {
    pub headers: BTreeMap<String, String>,
    pub metadata: BTreeMap<String, String>,
    pub partition: Option<u32>,
    pub offset: Option<u64>,
    pub stream: Option<u32>,
    pub topic: Option<u32>,
    pub payload: Option<Vec<u8>>,
    pub score: Option<f32>,
}

One materialized row: indexed fields, metadata, log position, and optional payload/score.

Fields

headers: BTreeMap<String, String>

metadata: BTreeMap<String, String>

partition: Option<u32>

offset: Option<u64>

stream: Option<u32>

topic: Option<u32>

payload: Option<Vec<u8>>

score: Option<f32>

Implementations

impl Row

pub fn decode_json<T: DeserializeOwned>(&self) -> Result<T, DecodeError>

Decodes the row’s payload as JSON into T. Errors if no payload was returned (publisher did not inline it, or the query did not request it), or if the bytes fail to deserialize.

pub fn decode_msgpack<T: DeserializeOwned>(&self) -> Result<T, DecodeError>

Decodes the row’s payload as MessagePack into T. Same prerequisites as decode_json.

pub fn decode_with<C, T>(&self) -> Result<T, DecodeError>

where C: Decoder<T>,

Decode the row’s payload with any Decoder (Json, Msgpack, or your own). decode_json and decode_msgpack are sugar for the built-ins. Reach for this with a custom codec. Same prerequisites: the publisher inlined the payload and the query requested it.

Trait Implementations

impl Clone for Row

fn clone(&self) -> Row

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Row

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

Formats the value using the given formatter.

impl Default for Row

fn default() -> Row

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Row

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Row

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

where __S: Serializer,

Serialize this value into the given Serde serializer.