Struct StreamRange 

pub struct StreamRange {
    pub start: StreamId,
    pub end: StreamId,
    pub count: Option<usize>,
    pub reverse: bool,
    pub exclude_start: bool,
    pub exclude_end: bool,
}

XRANGE / XREVRANGE configuration structure (aligned with Kvrocks StreamRangeOpt). XRANGE / XREVRANGE 配置选项（对标 Apache Kvrocks StreamRangeOpt）

Fields

start: StreamId

end: StreamId

count: Option<usize>

reverse: bool

exclude_start: bool

exclude_end: bool

Implementations

impl StreamRange

pub fn new(start: StreamId, end: StreamId) -> Self

pub fn reverse(start: StreamId, end: StreamId) -> Self

pub fn with_count(self, count: usize) -> Self

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

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

pub fn from_options( start: StreamId, end: StreamId, options: impl IntoIterator<Item = XRange>, ) -> Self

Trait Implementations

impl Clone for StreamRange

fn clone(&self) -> StreamRange

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StreamRange

impl Debug for StreamRange

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

Formats the value using the given formatter.

impl<'__de> Decode<'__de> for StreamRange

where '__de:,

impl Default for StreamRange

fn default() -> Self

Returns the “default value” for a type.

impl Encode for StreamRange

impl Eq for StreamRange

impl From<&StreamRange> for StreamRange

fn from(opt: &StreamRange) -> Self

Converts to this type from the input type.

impl From<(Bound<StreamId>, Bound<StreamId>)> for StreamRange

fn from((start, end): (Bound<StreamId>, Bound<StreamId>)) -> Self

Converts to this type from the input type.

impl From<(StreamId, StreamId)> for StreamRange

fn from((start, end): (StreamId, StreamId)) -> Self

Converts to this type from the input type.

impl From<(StreamId, StreamId, Option<usize>)> for StreamRange

fn from((start, end, count): (StreamId, StreamId, Option<usize>)) -> Self

Converts to this type from the input type.

impl From<(StreamId, StreamId, usize)> for StreamRange

fn from((start, end, count): (StreamId, StreamId, usize)) -> Self

Converts to this type from the input type.

impl From<Range<StreamId>> for StreamRange

fn from(r: Range<StreamId>) -> Self

Converts to this type from the input type.

impl From<RangeFrom<StreamId>> for StreamRange

fn from(r: RangeFrom<StreamId>) -> Self

Converts to this type from the input type.

impl From<RangeFull> for StreamRange

fn from(_: RangeFull) -> Self

Converts to this type from the input type.

impl From<RangeInclusive<StreamId>> for StreamRange

fn from(r: RangeInclusive<StreamId>) -> Self

Converts to this type from the input type.

impl From<RangeTo<StreamId>> for StreamRange

fn from(r: RangeTo<StreamId>) -> Self

Converts to this type from the input type.

impl From<RangeToInclusive<StreamId>> for StreamRange

fn from(r: RangeToInclusive<StreamId>) -> Self

Converts to this type from the input type.

impl PartialEq for StreamRange

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamRange