Struct WindowGrant 

pub struct WindowGrant { /* private fields */ }

A contiguous block of count timestamps starting at (physical_ms, logical_start), all sharing one leadership epoch.

Fields are private and the only public constructor is try_new, which validates that every timestamp the grant covers fits the packed 46-bit physical / 18-bit logical layout. A value of this type is therefore proof that first and last can pack without panicking — the in-range invariant is guaranteed by the type, not by the constructors that happen to build it. The crate-internal back door new_unchecked skips the validation but documents the same invariant as a caller obligation.

Implementations

impl WindowGrant

pub fn try_new( physical_ms: u64, logical_start: u32, count: u32, epoch: Epoch, ) -> Result<Self, CoreError>

Construct a grant, checking that every timestamp it covers packs cleanly. This is the only validating constructor; the crate-internal new_unchecked skips the checks but requires the caller to have established the invariant some other way. Either way, a constructed value witnesses that first/last are infallible.

Rejects count == 0 (a grant covers at least one timestamp, and last’s logical_start + count - 1 would underflow). The range check defers to Timestamp::try_pack on the last logical the grant emits: it is the single source of truth for the bit layout, and since logical_start <= last_logical <= LOGICAL_MAX validating the last boundary validates the first by implication.

pub fn physical_ms(&self) -> u64

pub fn logical_start(&self) -> u32

pub fn count(&self) -> u32

pub fn epoch(&self) -> Epoch

pub fn first(&self) -> Timestamp

The first timestamp in the grant. Infallible: try_new validated (physical_ms, logical_start) is in range, so pack cannot trip its assert!.

pub fn last(&self) -> Timestamp

The last timestamp in the grant. Infallible: try_new validated (physical_ms, logical_start + count - 1) is in range (and count >= 1, so the subtraction cannot underflow), so pack cannot trip its assert!.

Trait Implementations

impl Clone for WindowGrant

fn clone(&self) -> WindowGrant

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for WindowGrant

impl Debug for WindowGrant

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

Formats the value using the given formatter.

impl Eq for WindowGrant

impl PartialEq for WindowGrant

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