Struct EdgeCacheRegistry 

pub struct EdgeCacheRegistry { /* private fields */ }

Tracks which nodes are eligible for edge caching and propagates that state via gossip labels.

Construction is cheap; the registry is Clone (it’s an Arc-wrapped pair of state + gossip handle) so it can be plumbed into Axum handlers behind with_state.

Implementations

impl EdgeCacheRegistry

pub fn new() -> Self

Create a registry with no gossip pool attached.

Eligibility decisions are still tracked locally and returned by Self::list_eligible, but no labels are pushed to peers. Used by tests and by standalone-mode daemons that don’t participate in the worker-tier gossip pool.

pub fn with_gossip(gossip: Arc<GossipPool>, self_info: PeerInfo) -> Self

Create a registry that pushes eligibility labels into the supplied gossip pool.

self_info is the PeerInfo template the registry will mutate (label keys are added on enable and removed on disable) and then re-broadcast via GossipPool::announce_self.

pub async fn enable( &self, node_id: u64, capacity: NodeCapacity, ) -> Result<(), EdgeCacheError>

Mark node_id as eligible for edge caching with capacity.

Inserts a new EdgeCacheNode into the registry (overwriting any prior entry for the same node_id) and, when a gossip pool is attached, pushes the standard label set into the local node’s gossip self-info and re-announces it.

Errors

Returns EdgeCacheError::Gossip if the gossip pool rejects the re-announcement (serialization error inside chitchat).

pub async fn disable(&self, node_id: u64) -> Result<(), EdgeCacheError>

Remove node_id from the eligibility registry.

When a gossip pool is attached, clears the edge-cache label set from the local node’s gossip self-info and re-announces.

Errors

• EdgeCacheError::NodeNotFound if node_id was not registered.
• EdgeCacheError::Gossip if the gossip re-announcement fails.

pub async fn list_eligible(&self) -> Vec<EdgeCacheNode>

Snapshot of every currently-eligible node.

pub async fn is_enabled(&self, node_id: u64) -> bool

Whether node_id is currently registered as edge-cache-eligible.

pub async fn stats(&self, _node_id: u64) -> EdgeCacheStats

Return placeholder hit/miss counters for node_id.

Documented stub: always returns (0, 0) regardless of node_id. The real counters land in the follow-on cache subsystem (see module docs). This stays callable so upstream integration tests can rely on the endpoint existing today. The async shape is preserved so a future implementation can read shared cache state without a breaking API churn.

Trait Implementations

impl Clone for EdgeCacheRegistry

fn clone(&self) -> EdgeCacheRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EdgeCacheRegistry

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

Formats the value using the given formatter.

impl Default for EdgeCacheRegistry

fn default() -> Self

Returns the “default value” for a type.