Struct BatchedRecord 

pub struct BatchedRecord {
    pub compression_type: i32,
    pub publish_time: Option<Timestamp>,
    pub batch_size: u32,
    pub payload: Vec<u8>,
}

Fields

compression_type: i32

publish_time: Option<Timestamp>

Required. The time at which the message was published, populated by the server.

batch_size: u32

Required batchSize records the number of compressed HStreamRecords in the current batch. This field allows the server to build the RecordId correctly without decompression after reading the data from the store.

payload: Vec<u8>

serialized BatchHStreamRecords

Implementations

impl BatchedRecord

pub fn compression_type(&self) -> CompressionType

Returns the enum value of compression_type, or the default if the field is set to an invalid enum value.

pub fn set_compression_type(&mut self, value: CompressionType)

Sets compression_type to the provided enum value.

Trait Implementations

impl Clone for BatchedRecord

fn clone(&self) -> BatchedRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchedRecord

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

Formats the value using the given formatter.

impl Default for BatchedRecord

fn default() -> Self

Returns the “default value” for a type.

impl Message for BatchedRecord

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>

where B: BufMut, Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>

where B: BufMut, Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for BatchedRecord

fn eq(&self, other: &BatchedRecord) -> 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 StructuralPartialEq for BatchedRecord