Struct ChainOriginDirectory 

pub struct ChainOriginDirectory { /* private fields */ }

Chain-backed origin directory: a lazy TTL cache over getOrigins, resolving operators to active NodeIds against the shared capacity-bond reverse projection. No background watcher and no whole-directory mirror — a single getOrigins(ns) RPC fires only on a cold-namespace miss, and chain reads therefore scale with the namespaces this node is actually asked to serve, not the permissionless global namespace count.

Implementations

impl ChainOriginDirectory

pub fn new<P>( provider: P, origin_assignment_addr: Address, operator_to_node: Arc<RwLock<HashMap<Address, NodeId>>>, staker_set: Arc<dyn StakerSet>, content_deny: Arc<ContentDenylist>, cache_capacity: usize, positive_ttl: Duration, negative_ttl: Duration, metrics: Arc<Metrics>, ) -> Self

where P: Provider + Clone + Send + Sync + 'static,

Build a directory over the given OriginAssignment contract. No RPC: the cache is lazy and populates on the first lookup miss for each namespace.

Trait Implementations

impl Debug for ChainOriginDirectory

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

Formats the value using the given formatter.

impl OriginDirectory for ChainOriginDirectory

fn lookup_origins<'life0, 'async_trait>( &'life0 self, namespace_id: U256, ) -> Pin<Box<dyn Future<Output = Vec<NodeId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return the operator NodeIds authorised as origins for namespace_id, already filtered to only currently-active stakers (the active == true filter from CapacityBond.nodeIdOf per ADR 022 §FIND_VALUE Flow “Origin discovery”).