Struct DistributedInferenceSession 

pub struct DistributedInferenceSession {
    pub session_id: String,
    pub goal: String,
    pub local_results: Vec<String>,
    pub remote_results: Vec<RemoteResult>,
    pub pending_peers: HashSet<String>,
    pub completed_peers: HashSet<String>,
    pub started_at: Instant,
    pub timeout: Duration,
}

Tracks a single distributed inference run from start to finish.

Fields

session_id: String

Unique identifier for this session (UUID v4).

goal: String

The goal being proved (Datalog string).

local_results: Vec<String>

Bindings resolved locally.

remote_results: Vec<RemoteResult>

Results contributed by remote peers.

pending_peers: HashSet<String>

Peers that have been queried but have not yet replied.

completed_peers: HashSet<String>

Peers that have already replied (or been declared timed-out).

started_at: Instant

Wall-clock instant at which the session was created.

timeout: Duration

How long to wait for all peers before declaring the session timed-out.

Implementations

impl DistributedInferenceSession

pub fn new(goal: &str, timeout: Duration) -> Self

Construct a new session for goal with the given timeout.

pub fn is_complete(&self) -> bool

Returns true once all registered peers have replied or the timeout has elapsed.

A session that has had no peers registered is not considered complete (there is no outstanding work to declare done). It becomes complete either when every registered peer has replied or when the timeout fires.

pub fn is_expired(&self) -> bool

Returns true when the session has exceeded its timeout.

Trait Implementations

impl Debug for DistributedInferenceSession

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

Formats the value using the given formatter.