Struct Coordinator 

pub struct Coordinator { /* private fields */ }

Coordinator handler. One instance is bound to one in-flight query; finalising the FSM produces a SearchResponse.

Implementations

impl Coordinator

pub fn new( request: SearchRequest, peers: Vec<String>, probe: PeerProbe, deadline: Duration, ) -> (Self, Arc<Mutex<Option<SearchResponse>>>)

Build a new coordinator. peers is the list of peer identifiers the request will fan out to; probe is invoked synchronously per peer to fetch hits.

The coordinator’s peers_consulted field on the eventual response counts the number of peers that returned hits (errors are logged through tracing::warn! and otherwise dropped).

Trait Implementations

impl FsmHandler for Coordinator

type State = State

The set of states this FSM can be in. Typically a Copy enum with no payload; the per-state context lives in self.

type Event = Event

Events the FSM accepts. Includes both external events and any internal follow-ups posted via crate::Action::post_internal.

type Reply = ()

Reply type for Call events.

type Stop = String

Reason this FSM stopped. Returned to the caller through crate::FsmDriver::join.

fn initial(&self) -> Self::State

The state the FSM starts in. Called once during driver startup, before any events.

fn handle( &mut self, state: Self::State, _event_type: EventType, event: Self::Event, ) -> Transition<Self>

Handle one event in the given state. Return a Transition describing where to go next and which side effects to apply.

fn on_timeout( &mut self, state: Self::State, _kind: TimeoutKind, ) -> Transition<Self>

Called when a timer fires. Default impl returns Transition::Keep(vec![]) (no-op).

fn on_enter(&mut self, state: Self::State) -> Transition<Self>

Called once per transition into a state, before any mailbox events for the new state. Default impl returns Transition::Keep(vec![]) (no-op).