Struct GroupStateMachine 

pub struct GroupStateMachine { /* private fields */ }

State machine for managing group steward epoch flow.

Implementations

impl GroupStateMachine

pub fn new_as_member() -> Self

Create a new group state machine (not steward) with default config.

pub fn new_as_member_with_config(config: GroupConfig) -> Self

Create a new group state machine (not steward) with custom config.

pub fn new_as_steward() -> Self

Create a new group state machine as steward with default config.

pub fn new_as_steward_with_config(config: GroupConfig) -> Self

Create a new group state machine as steward with custom config.

pub fn new_as_pending_join() -> Self

Create a new group state machine in PendingJoin state with default config.

pub fn new_as_pending_join_with_config(config: GroupConfig) -> Self

Create a new group state machine in PendingJoin state with custom config.

pub fn current_state(&self) -> GroupState

Get the current state.

pub fn is_steward(&self) -> bool

Check if this is a steward state machine.

pub fn set_steward(&mut self, is_steward: bool)

Set steward status.

pub fn start_working(&mut self)

Start working state.

pub fn start_waiting(&mut self)

Start waiting state.

pub fn start_leaving(&mut self)

Transition to Leaving state.

Caller must ensure valid state transition (typically from Working or Waiting). The User::leave_group method handles PendingJoin and Leaving states separately.

pub fn is_pending_join_expired(&self) -> bool

Check if the pending join has expired (time-based).

Expiration happens when ~2 epoch durations have passed since join attempt. If the member hasn’t received a welcome by then, assume rejection.

pub fn is_commit_timed_out(&self) -> bool

Check if the commit has timed out while in Waiting state.

Returns true if the member has been in Waiting for longer than epoch_duration / 2 without receiving a commit from the steward.

pub fn sync_epoch_boundary(&mut self)

Sync the epoch boundary to now. Called when a commit or welcome (for joining) is received. This is the synchronization point between steward and member epochs.

pub fn check_epoch_boundary(&mut self, approved_proposals_count: usize) -> bool

Check if we’ve reached the expected epoch boundary and should enter Waiting.

Called by the member epoch timer. Returns true if entering Waiting state (meaning a commit timeout should be started).

Arguments

• approved_proposals_count - Number of approved proposals waiting for commit

Returns

true if transitioned to Waiting state, false otherwise.

pub fn time_until_next_boundary(&self) -> Option<Duration>

Get the time until the next expected epoch boundary. Returns None if no epoch boundary has been set yet.

pub fn start_steward_epoch(&mut self) -> Result<(), StateMachineError>

Start steward epoch with state validation.

Errors

• If not in Working state
• If not a steward

Trait Implementations

impl Clone for GroupStateMachine

fn clone(&self) -> GroupStateMachine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GroupStateMachine

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

Formats the value using the given formatter.

impl Default for GroupStateMachine

fn default() -> Self

Returns the “default value” for a type.