Struct ReadEnd 

pub struct ReadEnd {
    pub count: Option<usize>,
    pub bytes: Option<usize>,
    pub until: Option<Timestamp>,
    pub wait: Option<u32>,
}

Fields

count: Option<usize>

Record count limit. Non-streaming reads are capped by the default limit of 1000 records.

bytes: Option<usize>

Metered bytes limit. Non-streaming reads are capped by the default limit of 1 MiB.

until: Option<Timestamp>

Exclusive timestamp to read until.

wait: Option<u32>

Duration in seconds to wait for new records. The default duration is 0 if there is a bound on count, bytes, or until, and otherwise infinite. Non-streaming reads are always bounded on count and bytes, so you can achieve long poll semantics by specifying a non-zero duration up to 60 seconds. In the context of an SSE or S2S streaming read, the duration will bound how much time can elapse between records throughout the lifetime of the session.

Trait Implementations

impl Clone for ReadEnd

fn clone(&self) -> ReadEnd

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadEnd

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReadEnd

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<ReadEnd> for ReadEnd

fn from(value: ReadEnd) -> Self

Converts to this type from the input type.

impl Serialize for ReadEnd

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

where __S: Serializer,

Serialize this value into the given Serde serializer.