Struct ValidationStage 

pub struct ValidationStage {
    pub validator: Option<Arc<Validator>>,
    pub cert_fetcher: Option<Arc<CertFetcher>>,
    /* private fields */
}

Validates Data packet signatures before caching.

Sits between PitMatchStage and CsInsertStage in the data pipeline. When no validator is configured, packets pass through unconditionally.

When a certificate is not yet cached, the packet is queued in a bounded pending queue. A background drain task periodically re-validates queued packets as certificates arrive.

Fields

validator: Option<Arc<Validator>>

cert_fetcher: Option<Arc<CertFetcher>>

Implementations

impl ValidationStage

pub fn new( validator: Option<Arc<Validator>>, cert_fetcher: Option<Arc<CertFetcher>>, config: PendingQueueConfig, ) -> Self

pub fn disabled() -> Self

Disabled validation — all packets pass through.

pub async fn process(&self, ctx: PacketContext) -> Action

pub async fn drain_pending(&self) -> Vec<Action>

Drain the pending queue and re-validate packets whose certs arrived.

Called periodically by the drain task spawned in the dispatcher. Returns actions to inject back into the data pipeline.