Struct OperatorPoll 

pub struct OperatorPoll {
    handle: JoinHandle<()>,
    stop: Arc<Notify>,
}

A running operator poll, stopped by OperatorPoll::stop or by dropping it.

Fields

handle: JoinHandle<()>

stop: Arc<Notify>

Implementations

impl OperatorPoll

pub fn spawn( relation: Arc<OperatorRelation>, estop: Arc<Estop>, lifecycle: Arc<ServerLifecycle>, registry: Arc<dyn Registry>, client: Client, private: PrivateAddresses, schedule: PollSchedule, nudge: Arc<PollNudge>, policies: Option<Arc<PolicyPoll>>, records_read: Arc<OperatorRecords>, operator_handle: Option<Arc<OperatorHandle>>, ) -> Self

Starts polling relation against the real network on schedule, driving estop’s self latch from what it finds, admitting the reservations registry holds that the operator has vouched for, and reporting to lifecycle whether a claim currently stands. Each tick that reads the operator’s DID document also starts a check of the handle it claims, into operator_handle, which the tick does not wait for.

The first tick fires immediately, not after one interval: a server that waited a full interval before its first chance to find an already-existing claim would refuse writes for no reason a fresh restart should ever cause.

nudge lets a caller ask for a poll sooner than the schedule’s interval, bounded by its floor. A nudge arriving less than the floor since the last poll waits out the remainder rather than polling, and every further nudge inside that window coalesces into the same single poll. So an unbounded burst of nudges costs this server one extra outbound request, not one per nudge — see PollNudge.

pub async fn stop(self)

Stops the poll and waits for the task to finish.