Struct AppendRecord 

pub struct AppendRecord {
    pub timestamp: Option<Timestamp>,
    pub headers: Vec<Header>,
    pub body: String,
}

Record to be appended to a stream.

Fields

timestamp: Option<Timestamp>

Timestamp for this record. The service will always ensure monotonicity by adjusting it up if necessary to the maximum observed timestamp. Refer to stream timestamping configuration for the finer semantics around whether a client-specified timestamp is required, and whether it will be capped at the arrival time.

headers: Vec<Header>

Series of name-value pairs for this record.

body: String

Body of the record.

Implementations

impl AppendRecord

pub fn decode(self, format: Format) -> Result<AppendRecord, ValidationError>

Trait Implementations

impl Clone for AppendRecord

fn clone(&self) -> AppendRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AppendRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AppendRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AppendRecord

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

where __S: Serializer,

Serialize this value into the given Serde serializer.