Struct LeaseClient 

pub struct LeaseClient { /* private fields */ }

Shared lease-acquisition client for app-owned pull receivers.

Holds the fully-qualified …/commands/leases endpoint, the bearer token, and a pooled HTTP client. The endpoint is built once at construction via LeaseClient::from_base, so a base URL that cannot be a hierarchical (HTTP(S)) URL fails at startup rather than being re-derived — and misclassified as a transient error — on every poll.

LeaseClient::acquire returns this crate’s Result; each caller maps it to its own error enum at the boundary.

Implementations

impl LeaseClient

pub fn from_base(base: &Url, token: String) -> Option<Self>

Build a lease client for a command-server base URL, appending the commands/leases path segments once.

Returns None if base cannot be a hierarchical (HTTP(S)) URL — callers surface that as their own startup config error so the permanent misconfiguration fails fast instead of being retried on every poll.

pub fn endpoint(&self) -> &Url

The fully-qualified lease endpoint this client POSTs to.

pub async fn acquire(&self, request: &LeaseRequest) -> Result<Vec<LeaseInfo>>

Acquire leases: POST request with the bearer token and parse the LeaseResponse. Transport, 408, 429, and 5xx failures are retryable; other non-success statuses are permanent request rejections.

pub async fn acquire_with_token( &self, request: &LeaseRequest, token: &str, ) -> Result<Vec<LeaseInfo>>

Acquire leases with a caller-supplied token. Receivers use this for file-backed token rotation; Self::acquire uses the configured token.

pub async fn release_with_token( &self, lease_id: &str, token: &str, ) -> Result<()>

Release a lease during graceful shutdown or duplicate suppression. Conflict/gone responses mean the lease is already no longer owned and are therefore successful idempotent outcomes.

Trait Implementations

impl Clone for LeaseClient

fn clone(&self) -> LeaseClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeaseClient

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

Formats the value using the given formatter.