Struct MockElectionCore 

pub struct MockElectionCore<T>
where
    T: TypeConfig,
{ /* private fields */ }

Implementations

impl<T> MockElectionCore<T>

where T: TypeConfig,

pub fn checkpoint(&mut self)

Validate that all current expectations for all methods have been satisfied, and discard them.

pub fn new() -> Self

Create a new mock object with no expectations.

This method will not be generated if the real struct already has a new method. However, it will be generated if the struct implements a trait with a new method. The trait’s new method can still be called like <MockX as TraitY>::new

impl<T> MockElectionCore<T>

where T: TypeConfig,

pub fn expect_broadcast_vote_requests(&mut self) -> &mut Expectation<T>

Create an Expectation for mocking the broadcast_vote_requests method

pub fn expect_handle_vote_request(&mut self) -> &mut Expectation<T>

Create an Expectation for mocking the handle_vote_request method

pub fn expect_check_vote_request_is_legal(&mut self) -> &mut Expectation<T>

Create an Expectation for mocking the check_vote_request_is_legal method

Trait Implementations

impl Clone for MockElectionCore<MockTypeConfig>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for MockElectionCore<T>

where T: TypeConfig,

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

Formats the value using the given formatter.

impl<T> Default for MockElectionCore<T>

where T: TypeConfig,

fn default() -> Self

Returns the “default value” for a type.

impl<T> ElectionCore<T> for MockElectionCore<T>

where T: TypeConfig,

fn broadcast_vote_requests<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, term: u64, membership: Arc<MOF<T>>, raft_log: &'life1 Arc<ROF<T>>, transport: &'life2 Arc<TROF<T>>, settings: &'life3 Arc<RaftNodeConfig>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Sends vote requests to all voting members. Returns Ok() if majority votes are received, otherwise returns Err. Initiates RPC calls via transport and evaluates collected responses.

A vote can be granted only if all the following conditions are met:

• The requests term is greater than the current_term.
• The candidates log is sufficiently up-to-date.
• The current node has not voted in the current term or has already voted for the candidate.

fn handle_vote_request<'life0, 'life1, 'async_trait>( &'life0 self, request: VoteRequest, current_term: u64, voted_for_option: Option<VotedFor>, raft_log: &'life1 Arc<ROF<T>>, ) -> Pin<Box<dyn Future<Output = Result<StateUpdate>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Processes incoming vote requests: validates request legality via check_vote_request_is_legal, updates node state if valid, triggers role transition to Follower when granting vote.

If there is a state update, we delegate the update to the parent RoleState instead of updating it within this function.

fn check_vote_request_is_legal( &self, request: &VoteRequest, current_term: u64, last_log_index: u64, last_log_term: u64, voted_for_option: Option<VotedFor>, ) -> bool

Validates vote request against Raft rules:

1. Requester’s term must be ≥ current term
2. Requester’s log must be at least as recent as local log
3. Node hasn’t voted for another candidate in current term