Struct QuarantineStore 

pub struct QuarantineStore { /* private fields */ }

In-process quarantine store.

Thread-safe via an internal Mutex. Production deployments may replace this with a persisted backend by implementing the same functional contract.

Implementations

impl QuarantineStore

pub fn new() -> QuarantineStore

pub fn admit( &self, asset_id: impl Into<String>, asset: NetworkAsset, origin_peer: impl Into<String>, ) -> bool

Admit a remote asset into quarantine (state = Pending).

If the asset is already present it is not overwritten; the existing entry is left unchanged. Returns true when a new entry was inserted.

pub fn validate_asset(&self, asset_id: &str) -> bool

Mark an asset as validated.

Returns true on success, false if the asset was not found.

pub fn fail_asset(&self, asset_id: &str, reason: impl Into<String>) -> bool

Mark an asset as failed with a reason.

Returns true on success, false if the asset was not found.

pub fn get(&self, asset_id: &str) -> Option<QuarantineEntry>

Retrieve an entry by asset id.

pub fn is_selectable(&self, asset_id: &str) -> bool

Returns true if asset_id is present and its state is Validated.

pub fn pending_entries(&self) -> Vec<QuarantineEntry>

All entries currently in Pending state.

pub fn validated_entries(&self) -> Vec<QuarantineEntry>

All entries currently in Validated state.

pub fn len(&self) -> usize

Total number of entries.

pub fn is_empty(&self) -> bool

Trait Implementations

impl Default for QuarantineStore

fn default() -> QuarantineStore

Returns the “default value” for a type.