Struct raft::Inflights

[+] Show declaration

pub struct Inflights { /* fields omitted */ }

[−] Expand description

A buffer of inflight messages.

Implementations

impl Inflights[−]

pub fn new(cap: usize) -> Inflights[−]

Creates a new buffer for inflight messages.

pub fn full(&self) -> bool[−]

Returns true if the inflights is full.

pub fn cap(&self) -> usize[−]

The buffer capacity.

pub fn add(&mut self, inflight: u64)[−]

Adds an inflight into inflights

pub fn free_to(&mut self, to: u64)[−]

Frees the inflights smaller or equal to the given to flight.

pub fn free_first_one(&mut self)[−]

Frees the first buffer entry.

pub fn reset(&mut self)[−]

Frees all inflights.

Trait Implementations

impl Clone for Inflights[+]

[+] Show hidden undocumented items

fn clone(&self) -> Self[−]

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)[−]

Performs copy-assignment from source.

impl Debug for Inflights[+]

[+] Show hidden undocumented items

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

Formats the value using the given formatter.

impl PartialEq<Inflights> for Inflights[+]

[+] Show hidden undocumented items

fn eq(&self, other: &Inflights) -> bool[−]

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Inflights) -> bool[−]

This method tests for !=.

impl StructuralPartialEq for Inflights