Struct Follower 

pub struct Follower<L: SharedUnlockDriver>(Arc<InnerFollower<L>>);

Tracks local state and follows authoritative lock updates from a leader.

Tuple Fields

0: Arc<InnerFollower<L>>

Implementations

impl<L: SharedUnlockDriver + Send + Sync + 'static> Follower<L>

pub fn create(driver: L, ipc_client: Arc<dyn IpcClient>) -> Self

Creates a follower instance and starts sessions for all currently known users.

During startup, a StartSession message is sent per user so the leader can reconcile initial lock state.

pub(crate) async fn start_sessions(&self)

pub async fn start( &self, cancellation_token: Option<CancellationToken>, ) -> Result<(), FollowerStartError>

Starts background tasks for IPC message handling and heartbeat timers.

pub async fn receive_message( &self, incoming_message: TypedIncomingMessage<LeaderMessage>, ) -> Result<(), ()>

Handles an authoritative message from the leader.

Lock state updates overwrite local state to keep follower and leader in sync. Heartbeat responses are forwarded to the heartbeat response handler.

pub async fn handle_device_event(&self, event: DeviceEvent) -> Result<(), ()>

Handles local device events and forwards them to the discovered leader.

Manual lock/unlock events are sent as lock state updates. Timer events send per-user heartbeats to keep the shared session active.

async fn send_message(&self, message: FollowerMessage, recipient: Endpoint)

Trait Implementations

impl<L: SharedUnlockDriver> Clone for Follower<L>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.