Struct nats::jetstream::RangeTree [−][src]
Records ranges of acknowledged messages for low-memory deduplication.
Implementations
impl RangeTree
[src]
pub fn mark_processed(&mut self, id: u64) -> bool
[src]
Mark this ID as being processed. Returns true
if this ID was not already marked as processed.
pub fn already_processed(&self, id: u64) -> bool
[src]
Returns true
if this ID has already been processed.
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for RangeTree
impl Send for RangeTree
impl Sync for RangeTree
impl Unpin for RangeTree
impl UnwindSafe for RangeTree
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,