Struct raftstore::store::read_queue::ReadIndexQueue

pub struct ReadIndexQueue<S> where
    S: Snapshot,  {
    reads: VecDeque<ReadIndexRequest<S>>,
    ready_cnt: usize,
    handled_cnt: usize,
    contexts: HashMap<Uuid, usize>,
    retry_countdown: usize,
}

Fields

reads: VecDeque<ReadIndexRequest<S>>

ready_cnt: usize

handled_cnt: usize

contexts: HashMap<Uuid, usize>

retry_countdown: usize

Implementations

impl<S> ReadIndexQueue<S> where
    S: Snapshot, 

pub fn check_needs_retry(&mut self, cfg: &Config) -> bool

Check it’s necessary to retry pending read requests or not. Return true if all such conditions are satisfied:

1. more than an election timeout elapsed from the last request push;
2. more than an election timeout elapsed from the last retry;
3. there are still unresolved requests in the queue.

pub fn has_unresolved(&self) -> bool

pub fn clear_all(&mut self, notify_removed: Option<u64>)

Clear all commands in the queue. if notify_removed contains an region_id, notify the request’s callback that the region is removed.

pub fn clear_uncommitted_on_role_change(&mut self, term: u64)

pub fn push_back(&mut self, read: ReadIndexRequest<S>, is_leader: bool)

pub fn back_mut(&mut self) -> Option<&mut ReadIndexRequest<S>>

pub fn last_ready(&self) -> Option<&ReadIndexRequest<S>>

pub fn advance_leader_reads<T>(&mut self, states: T) where
    T: IntoIterator<Item = (Uuid, Option<LockInfo>, u64)>, 

pub fn advance_replica_reads<T>(&mut self, states: T) where
    T: IntoIterator<Item = (Uuid, Option<LockInfo>, u64)>, 

update the read index of the requests that before the specified id.

pub fn fold(&mut self, min_changed_offset: usize, max_changed_offset: usize)

pub fn gc(&mut self)

pub fn pop_front(&mut self) -> Option<ReadIndexRequest<S>>

pub fn push_front(&mut self, read: ReadIndexRequest<S>)

Raft could have not been ready to handle the poped task. So put it back into the queue.

Trait Implementations

impl<S> Default for ReadIndexQueue<S> where
    S: Snapshot, 

fn default() -> ReadIndexQueue<S>

Returns the “default value” for a type.