Struct Contest 

pub struct Contest { /* private fields */ }

Fleet-shared contest handle. Cheap to clone.

Implementations

impl Contest

pub fn new(fleet: Arc<Fleet>) -> Self

pub fn reset_ring(&self) -> Result<()>

Clear the shared contest ring.

Intended for owner-controlled boot-time cleanup before peer processes publish claims. It is not a runtime coordination tool.

pub fn try_claim<T: ContestType>( &self, subject: impl Into<String>, owner: impl Into<ContestOwner>, ttl: Duration, ) -> Result<Claim>

Try to become the first active claimant for a typed subject.

The caller supplies an owner label only for observability. Orbit does not interpret it.

pub fn try_claim_at<T: ContestType>( &self, subject: impl Into<String>, owner: impl Into<ContestOwner>, ttl: Duration, now_ms: u64, ) -> Result<Claim>

Same as Self::try_claim, but with an explicit clock value. Useful for deterministic tests and embedders with their own time source.

pub fn try_claim_subject( &self, subject: ContestSubject, owner: impl Into<ContestOwner>, ttl: Duration, ) -> Result<Claim>

Try to claim a pre-built subject.

pub fn try_claim_subject_at( &self, subject: ContestSubject, owner: impl Into<ContestOwner>, ttl: Duration, now_ms: u64, ) -> Result<Claim>

Same as Self::try_claim_subject, but with an explicit clock.

pub fn guard_holder(&self, holder: Holder) -> Guard

Turn an observed holder into a drop-released guard.

This is useful for re-entrant owners: a process may observe that it already owns the active claim, continue carrying the same responsibility, and release the original claim when the guard leaves scope.

pub fn release_holder(&self, holder: &Holder) -> Result<NetId64>

Release a holder observed through a yield path.

This is useful for re-entrant owners: a process may keep probing under its own still-active claim, then release that original claim when the guarded work succeeds.

Trait Implementations

impl Clone for Contest

fn clone(&self) -> Contest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Contest

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

Formats the value using the given formatter.