Struct RevocationExchange 

pub struct RevocationExchange { /* private fields */ }

Receives, applies and forwards revocation notices for one node.

Implementations

impl RevocationExchange

pub fn with_log_file(&self, path: impl Into<PathBuf>) -> usize

Keep the replay log in path (loaded now, saved after every notice). Entries that no longer verify (a key since unpinned or revoked) are dropped, so a replay never carries a notice peers would refuse. Returns how many were restored. A missing file starts empty; a malformed or oversized one is ignored (and overwritten on the next notice).

pub fn forget_subject(&self, kind: RevocationKind, id: &str) -> usize

Drop the logged notices for one subject (call when it is lifted) and save. Returns how many were dropped.

pub fn logged(&self) -> Vec<SignedRevocation>

The notices kept for replay, oldest first. Those no longer in force here (lifted, or signer revoked) are dropped first, and the log saved without them.

pub fn replays_started(&self) -> u64

Replays started so far (for tests and diagnostics).

pub async fn replay_to(&self, peer: &str) -> usize

Send every logged notice to peer, oldest first. The first NOTICE_BURST go at once; the rest are paced at the rate the receiver accepts so a long log is not rate-limited away. Returns how many were sent.

impl RevocationExchange

pub fn start( ex: Arc<ArtifactExchange>, list: Arc<RevocationList>, anchors: TrustAnchors, runtime: Arc<MeshRuntime>, ) -> Arc<Self>

Exchange applying notices to ex, recording them in list and trusting anchors. Installs itself on runtime and gives ex the list.

pub fn set_on_applied(&self, hook: AppliedHook) -> bool

Run hook after every notice that was new here is applied (first call wins; returns whether this one did). Covers a notice from a peer and the operator’s own Self::issue.

pub fn accept(&self, signed: &SignedRevocation) -> Result<bool, NoticeError>

Record and apply a notice from a caller with no connection (budget 0). Returns whether it was new here; a notice already applied is not swept again.

pub async fn issue(&self, signed: SignedRevocation) -> Result<bool, NoticeError>

Revoke here (the operator’s own node) and send the notice to every peer. signed must verify against this node’s anchors. Not rate limited: peers’ traffic cannot starve the operator.

Trait Implementations

impl PeerControlSink for RevocationExchange

fn on_peer_control( &self, ctx: &PeerCtx, conn: u64, payload: &Value, ) -> Vec<Value>

Handle one control payload from ctx.peer_id; return replies.