Struct ProviderReputationStore 

pub struct ProviderReputationStore { /* private fields */ }

Local provider reputation database.

Implementations

impl ProviderReputationStore

pub fn new(config: ReputationConfig) -> Self

pub fn with_database( database: IndexingDatabase, config: ReputationConfig, ) -> Result<Self>

Create a store backed by an indexing database.

Reputations and signal sequences are hydrated from the database on construction. Mutations are persisted through the database.

Errors

Returns an error if the database cannot be read.

pub fn with_policy(config: ReputationConfig, policy: TrustPolicy) -> Self

pub const fn config(&self) -> &ReputationConfig

pub fn set_policy(&mut self, policy: TrustPolicy)

pub const fn set_reporter(&mut self, reporter: PublicKey)

Configure the reporter identity used for reputation transitions.

pub fn trust_reporter(&mut self, reporter: &PublicKey) -> Result<()>

Errors

Returns an error when the reporter identity is not a valid Ed25519 key.

pub fn reputation(&self, provider: PublicKey) -> ProviderReputation

pub fn score(&self, provider: PublicKey, now: u64) -> f64

pub fn record_fetch_result( &mut self, provider: PublicKey, success: bool, kind: FetchFailureKind, now: u64, )

pub fn record_success(&mut self, provider: PublicKey, now: u64)

pub fn record_failure( &mut self, provider: PublicKey, kind: FetchFailureKind, now: u64, )

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

pub fn auto_ban_until(&self, provider: PublicKey) -> Option<u64>

pub fn auto_ban_count(&self, provider: PublicKey) -> u32

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

Clear the active timeout while retaining its backoff history.

pub fn should_skip_provider( &self, provider: PublicKey, now: u64, threshold: f64, ) -> bool

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

Return all known providers, ranked by score and then hash distance.

pub fn rank_provider_list( &self, now: u64, hash: Hash, providers: &[PublicKey], ) -> Vec<PublicKey>

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

pub fn queue_trust_signal( &mut self, signal: ProviderTrustSignal, ) -> Result<bool>

Queue one observation, coalescing identical observations in the batch.

Errors

Returns an error when the signal structure is invalid.

pub fn pending_trust_signals(&self) -> &[ProviderTrustSignal]

pub fn take_pending_trust_signals(&mut self) -> Vec<ProviderTrustSignal>

pub fn set_max_signal_batch(&mut self, max_signal_batch: usize)

pub fn ingest_trust_signal( &mut self, signal: ProviderTrustSignal, ) -> Result<bool>

Accept a signed observation from a locally trusted reporter.

Errors

Returns an error when the signal is malformed, expired, or unsigned.

pub async fn publish_signal( &self, gossip: &GossipService, sender: &GossipSender, signal: &ProviderTrustSignal, ) -> Result<()>

Publish a signed signal to the provider-trust stream.

Errors

Returns an error when the signal is invalid or gossip rejects the publication.

pub async fn subscribe_trust_stream( &self, gossip: &GossipService, bootstrap: Vec<PublicKey>, ) -> Result<GossipTopic>

Subscribe to the provider-trust stream.

Errors

Returns an error when the gossip subscription cannot be created.

Trait Implementations

impl Clone for ProviderReputationStore

fn clone(&self) -> ProviderReputationStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProviderReputationStore

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

Formats the value using the given formatter.

impl Default for ProviderReputationStore

fn default() -> Self

Returns the “default value” for a type.