Struct OffsetSpan 

pub struct OffsetSpan {
    pub topic: String,
    pub partition: i32,
    pub start: i64,
    pub end: i64,
}

A half-open range of source positions [start, end) on one topic partition.

Half-open so adjacency is exact: [0, 10) then [10, 20) are contiguous and union-merge to [0, 20) with no off-by-one. end == start is the empty span.

Fields

topic: String

Source topic / stream name.

partition: i32

Source partition (0 where the source is unpartitioned).

start: i64

First position covered (inclusive).

end: i64

One past the last position covered (exclusive).

Implementations

impl OffsetSpan

pub fn new( topic: impl Into<String>, partition: i32, start: i64, end: i64, ) -> Self

Construct a span; end should be ≥ start.

pub fn len(&self) -> i64

Number of positions covered.

pub fn is_empty(&self) -> bool

Whether the span covers no positions.

Trait Implementations

impl Clone for OffsetSpan

fn clone(&self) -> OffsetSpan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OffsetSpan

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

Formats the value using the given formatter.

impl PartialEq for OffsetSpan

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

impl StructuralPartialEq for OffsetSpan