Struct Gate 

pub(super) struct Gate<'a> {
    pub(super) session: &'a SessionManager,
    pub(super) execute_by: Instant,
    pub(super) offline_grace: Duration,
    pub(super) last_ok: &'a (dyn Fn() -> Instant + Send + Sync),
    pub(super) cancel: &'a CancellationToken,
}

Decides, before each target-side try, whether the attempt may proceed; see Gate::check.

Fields

session: &'a SessionManager

execute_by: Instant

offline_grace: Duration

last_ok: &'a (dyn Fn() -> Instant + Send + Sync)

cancel: &'a CancellationToken

Implementations

impl Gate<'_>

pub(super) async fn check(&self) -> Result<(), AbortReason>

Waits until the attempt may start its next target-side try, or returns why it must abort.

Runs before every try (via with_retries_gated), so it never interrupts a call in flight. Each pass checks, in order:

1. The lease and cancellation: past execute_by aborts as AbortReason::LeaseExpired, a cancelled run as AbortReason::Cancelled.
2. The session phase. Revoked or Closed aborts as AbortReason::SessionLost. Expired or Authenticating renews the token via bearer, bounded by execute_by, then re-checks; renewal that keeps failing until the deadline counts as lease expiry.
3. Connectivity: an Active session with no server contact for longer than offline_grace waits for it to recover (see wait_for_connectivity), then re-checks.

Only an Active, connected session within its lease returns Ok.