Struct CompositeDiscovery 

pub struct CompositeDiscovery { /* private fields */ }

Wrapper that runs multiple DiscoveryProtocol implementations in parallel.

Namespace safety

CompositeDiscovery::new returns an error if any two protocols claim overlapping name prefixes (one is a prefix of the other). Each protocol must use a distinct sub-tree of /ndn/local/.

Inbound routing

When a raw packet arrives, CompositeDiscovery tries to parse its top-level NDN name and routes it to the first protocol whose claimed_prefixes contains a matching prefix. If the name cannot be parsed or no protocol matches, the packet is not consumed (returns false).

Tick delivery

All protocols receive every on_tick call. Order is not guaranteed.

Implementations

impl CompositeDiscovery

pub fn new(protocols: Vec<Arc<dyn DiscoveryProtocol>>) -> Result<Self, String>

Construct a composite from a list of protocols.

Returns Err with a human-readable message if any two protocols claim overlapping prefixes.

pub fn len(&self) -> usize

Number of contained protocols.

pub fn is_empty(&self) -> bool

pub fn all_claimed_prefixes(&self) -> Vec<Name>

Collect all prefixes claimed by any child protocol.

Unlike claimed_prefixes() (which returns the composite’s own top-level claims), this method flattens the claims of all children. Use this to enumerate the full set of prefixes owned by the discovery stack (e.g. for management security enforcement).

Trait Implementations

impl DiscoveryProtocol for CompositeDiscovery

fn protocol_id(&self) -> ProtocolId

Unique protocol identifier.

fn claimed_prefixes(&self) -> &[Name]

NDN name prefixes this protocol reserves.

fn on_face_up(&self, face_id: FaceId, ctx: &dyn DiscoveryContext)

Called when a new face comes up (after FaceTable::insert).

fn on_face_down(&self, face_id: FaceId, ctx: &dyn DiscoveryContext)

Called when a face goes down (before FaceTable::remove).

fn on_inbound( &self, raw: &Bytes, incoming_face: FaceId, meta: &InboundMeta, ctx: &dyn DiscoveryContext, ) -> bool

Called for every inbound raw packet before it enters the pipeline.

fn on_tick(&self, now: Instant, ctx: &dyn DiscoveryContext)

Periodic tick, called by the engine’s tick task at tick_interval.

fn tick_interval(&self) -> Duration

How often the engine should call on_tick.