Struct StreamPending 

pub struct StreamPending {
    pub idle_time: u64,
    pub with_time: bool,
    pub start_id: StreamId,
    pub end_id: StreamId,
    pub exclude_start: bool,
    pub exclude_end: bool,
    pub count: Option<usize>,
    pub consumer: Option<String>,
}

Domain operation (aligned with Apache Kvrocks StreamPendingOpt). XPENDING 配置选项（对标 Apache Kvrocks StreamPendingOpt）

Fields

idle_time: u64

with_time: bool

start_id: StreamId

end_id: StreamId

exclude_start: bool

exclude_end: bool

count: Option<usize>

consumer: Option<String>

Implementations

impl StreamPending

pub fn summary() -> Self

pub fn range(start_id: StreamId, end_id: StreamId, count: usize) -> Self

pub fn idle(self, idle_time: u64) -> Self

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

pub fn exclude_start(self, exclude: bool) -> Self

pub fn exclude_end(self, exclude: bool) -> Self

Trait Implementations

impl Clone for StreamPending

fn clone(&self) -> StreamPending

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamPending

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

Formats the value using the given formatter.

impl<'__de> Decode<'__de> for StreamPending

where '__de:,

impl Default for StreamPending

fn default() -> Self

Returns the “default value” for a type.

impl Encode for StreamPending

impl Eq for StreamPending

impl PartialEq for StreamPending

fn eq(&self, other: &StreamPending) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StreamPending