Struct Worker 

struct Worker {
    ctx: ExecutionContext,
    api: AccessConnectorClient,
    key_store: KeyStore<KeySlotIds>,
    heartbeat_interval: Duration,
}

Authenticated connector state shared by the stages of the run loop.

Fields

ctx: ExecutionContext

api: AccessConnectorClient

key_store: KeyStore<KeySlotIds>

heartbeat_interval: Duration

Implementations

impl Worker

async fn start( cfg: AccessConnectorConfig, cancel: CancellationToken, ) -> Result<Self, RunExit>

Authenticates and assembles the loop state, or returns the exit for a failed startup.

async fn tick(&self, backoff: &mut Duration) -> ControlFlow<Stop>

One pass of the loop: poll, claim at most one job, and rotate it.

async fn poll(&self, backoff: &mut Duration) -> ControlFlow<Stop, Vec<JobRef>>

Fetches claimable jobs, backing off on transient errors.

async fn claim_one(&self, jobs: Vec<JobRef>) -> ControlFlow<Stop, WorkSnapshot>

Claims the first job that is still available; skips the tick when none is.

async fn rotate(&self, snap: WorkSnapshot) -> ControlFlow<Stop>

Verifies and executes a claimed job; breaks only when the credential is refused.

async fn handle_not_eligible(&self) -> Option<RunExit>

Forces a token refresh to tell a revoked credential from a connector that is not eligible. None means the 404 did not survive the refresh (or a transient error hid it); keep polling.