Struct ProviderLeaseTracker 

pub struct ProviderLeaseTracker { /* private fields */ }

In-memory tracker for signed provider leases and local observations.

Implementations

impl ProviderLeaseTracker

pub fn with_max_failures_per_provider(max_failures_per_provider: usize) -> Self

Create an empty tracker with a bounded failure history.

pub const fn max_failures_per_provider(&self) -> usize

Return the failure-detail cap for each (hash, provider) pair.

pub fn set_max_failures_per_provider( &mut self, max_failures_per_provider: usize, )

Set the failure-detail cap and evict oldest details if necessary.

pub fn track(&mut self, lease: ProviderLease) -> Result<LeaseUpdate>

Track an active, signed lease using the current time.

Errors

Returns an error if the lease signature or expiry is invalid.

pub fn track_at( &mut self, lease: ProviderLease, now: u64, ) -> Result<LeaseUpdate>

Track an active, signed lease at an explicit time.

Older sequence numbers from the same provider are ignored. A new sequence replaces the provider’s previous lease for this blob.

Errors

Returns an error if the lease signature or expiry is invalid.

pub fn record_lease(&mut self, lease: ProviderLease) -> Result<LeaseUpdate>

Alias for Self::track.

Errors

Returns an error if the lease signature or expiry is invalid.

pub fn add_lease(&mut self, lease: ProviderLease) -> Result<LeaseUpdate>

Alias for Self::track.

Errors

Returns an error if the lease signature or expiry is invalid.

pub fn invalidate_lease(&mut self, hash: Hash, provider: PublicKey) -> bool

Remove a provider’s lease for a blob and record an automated, hash-scoped ban.

pub fn invalidate_lease_at( &mut self, hash: Hash, provider: PublicKey, now: u64, ) -> bool

Remove a provider’s lease and record an automated ban at an explicit time.

pub fn is_banned(&self, provider: PublicKey, hash: &Hash, now: u64) -> bool

Return whether a provider is covered by an active global or hash-scoped ban.

pub fn ban_provider( &mut self, provider: PublicKey, scope: Option<Hash>, reason: impl Into<String>, source: BanSource, duration: Option<Duration>, now: u64, ) -> BanRecord

Add or update a global or hash-scoped provider ban.

pub fn apply_ban_record(&mut self, record: BanRecord)

Apply a persisted ban record to in-memory state.

Used when hydrating bans from the database on construction.

pub fn unban_provider( &mut self, provider: PublicKey, scope: Option<Hash>, ) -> bool

Remove a global or hash-scoped ban.

pub fn banned_providers(&self, hash: &Hash, now: u64) -> Vec<PublicKey>

Return active provider identities covered by global and hash-scoped bans for a blob.

pub fn ban_records(&self, hash: &Hash, now: u64) -> Vec<BanRecord>

Return active ban records applying to a blob.

pub fn retroactive_invalidate( &mut self, hash: Hash, successful_provider: PublicKey, now: u64, ) -> Vec<PublicKey>

Invalidate all providers with definitive failures for a blob except the provider that successfully supplied it.

pub fn record_failure( &mut self, hash: Hash, provider: PublicKey, failure: FetchFailure, )

Record a provider failure using the current epoch time.

pub fn record_failure_at( &mut self, hash: Hash, provider: PublicKey, failure: FetchFailure, now: u64, )

Record a provider failure at an explicit time.

Failure details are capped per provider, while aggregate counts remain available through Self::failure_count.

pub fn failure_record( &self, hash: &Hash, provider: &PublicKey, ) -> Option<&FailureRecord>

Return the bounded failure details for a provider and blob.

pub fn failure_count(&self, hash: &Hash, provider: &PublicKey) -> usize

Return the aggregate failure count for a provider and blob.

pub fn consecutive_failures(&self, hash: &Hash, provider: &PublicKey) -> u32

Return the current consecutive definitive-failure count.

pub fn is_definitively_failed(&self, hash: &Hash, provider: &PublicKey) -> bool

Return whether a provider has crossed the definitive-failure threshold.

pub fn clear_failures_for_provider(&mut self, hash: &Hash, provider: &PublicKey)

Clear all failure history for a provider after a successful fetch.

pub fn purge_stale_failures(&mut self, now: u64, ttl: Duration)

Remove failure records whose last observation is outside ttl.

pub fn observe_provider(&mut self, hash: Hash, provider: PublicKey)

Record that a provider was observed serving a blob locally.

pub fn observe_provider_at( &mut self, hash: Hash, provider: PublicKey, observed_at: u64, )

Record a provider observation at an explicit time.

pub fn leases(&self, hash: &Hash) -> Vec<ProviderLease>

Return active leases for a blob.

pub fn leases_at(&self, hash: &Hash, now: u64) -> Vec<ProviderLease>

Return active leases for a blob at an explicit time.

pub fn providers(&self, hash: &Hash) -> Vec<PublicKey>

Return active provider identities for a blob.

pub fn verified_count(&self, hash: &Hash) -> usize

Return the number of active, previously verified leases.

pub fn list_providers(&self) -> Vec<PublicKey>

Return all providers that have an active lease for any blob.

pub fn blobs_for_provider(&self, provider: &PublicKey) -> Vec<Hash>

Return all blob hashes for which the given provider has an active lease.

pub fn health( &self, hash: &Hash, observation_ttl: Duration, ) -> AvailabilityHealth

Build a verified-vs-local availability report.

pub fn health_at( &self, hash: &Hash, now: u64, observation_ttl: Duration, ) -> AvailabilityHealth

Build an availability report at an explicit time.

pub fn purge(&mut self, now: u64, observation_ttl: Duration)

Remove expired leases and stale local observations.

Trait Implementations

impl Clone for ProviderLeaseTracker

fn clone(&self) -> ProviderLeaseTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProviderLeaseTracker

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

Formats the value using the given formatter.

impl Default for ProviderLeaseTracker

fn default() -> Self

Returns the “default value” for a type.