Struct ConsumeRequest 

pub struct ConsumeRequest {
    pub from_id: Option<String>,
    pub limit: usize,
    pub filter: Option<Filter>,
    pub ordering: Ordering,
    pub shards: Option<Vec<u16>>,
}

Request for consuming events.

Fields

from_id: Option<String>

Start cursor (opaque to caller). None means from the beginning.

limit: usize

Maximum number of events to return.

filter: Option<Filter>

Optional filter to apply.

ordering: Ordering

Ordering mode.

shards: Option<Vec<u16>>

Specific shards to poll. None means all shards.

Implementations

impl ConsumeRequest

pub fn new(limit: usize) -> Self

Create a new consume request.

pub fn from(self, cursor: impl Into<String>) -> Self

Set the starting cursor.

pub fn filter(self, filter: Filter) -> Self

Set the filter.

pub fn ordering(self, ordering: Ordering) -> Self

Set the ordering mode.

pub fn shards(self, shards: Vec<u16>) -> Self

Set specific shards to poll.

Trait Implementations

impl Clone for ConsumeRequest

fn clone(&self) -> ConsumeRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumeRequest

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

Formats the value using the given formatter.

impl Default for ConsumeRequest

fn default() -> ConsumeRequest

Returns the “default value” for a type.