Enum HeaderSyncEvent 

pub enum HeaderSyncEvent {
    PeerConnected(HeaderSyncPeerSession),
    PeerDisconnected(ZakuraPeerId),
    AdvisoryHeaderSummary {
        peer: ZakuraPeerId,
        summary: HeaderSyncServiceSummary,
    },
    FullBlockCommitted {
        height: Height,
        hash: Hash,
    },
    NewBlockAccepted {
        peer: ZakuraPeerId,
        height: Height,
        hash: Hash,
        block: Arc<Block>,
    },
    NewBlockDuplicate {
        peer: ZakuraPeerId,
        height: Height,
        hash: Hash,
    },
    NewBlockAcceptedNonBestChain {
        peer: ZakuraPeerId,
        height: Height,
        hash: Hash,
    },
    NewBlockRejected {
        peer: ZakuraPeerId,
        hash: Hash,
    },
    SessionWireMessage {
        peer: ZakuraPeerId,
        session_id: u64,
        msg: HeaderSyncMessage,
    },
    WireHeaders {
        peer: ZakuraPeerId,
        session_id: u64,
        request_id: HeaderSyncRequestId,
        headers: Vec<Arc<Header>>,
        body_sizes: Vec<u32>,
        tree_aux_roots: Vec<BlockCommitmentRoots>,
    },
    WireGetHeaders {
        peer: ZakuraPeerId,
        session_id: u64,
        request_id: HeaderSyncRequestId,
        start_height: Height,
        count: u32,
        want_tree_aux_roots: bool,
    },
    WireDecodeFailed {
        peer: ZakuraPeerId,
        error: Arc<HeaderSyncWireError>,
    },
    WireProtocolFailure {
        peer: ZakuraPeerId,
        reason: HeaderSyncMisbehavior,
        error: Arc<HeaderSyncWireError>,
    },
    StateFrontiersChanged(HeaderSyncFrontiers),
    VctRootRepairRequested {
        height: Height,
        generation: u64,
        anchor_hash: Hash,
        expected_hashes: Vec<(Height, Hash)>,
    },
    VctRootRepairResolved {
        generation: u64,
    },
    HeaderRangeCommitted {
        start_height: Height,
        tip_height: Height,
        tip_hash: Hash,
    },
    HeaderRangeCommitFailed {
        peer: ZakuraPeerId,
        session_id: u64,
        start_height: Height,
        count: u32,
        kind: HeaderSyncCommitFailureKind,
    },
    HeaderRangeResponseFinished {
        peer: ZakuraPeerId,
        session_id: u64,
        request_id: HeaderSyncRequestId,
        start_height: Height,
        requested_count: u32,
        returned_count: u32,
    },
    HeaderRangeResponseReady {
        peer: ZakuraPeerId,
        session_id: u64,
        request_id: HeaderSyncRequestId,
        start_height: Height,
        requested_count: u32,
        want_tree_aux_roots: bool,
        headers: Vec<Arc<Header>>,
        body_sizes: Vec<u32>,
        tree_aux_roots: Vec<BlockCommitmentRoots>,
    },
}

Facts accepted by the header-sync reactor.

Variants

PeerConnected(HeaderSyncPeerSession)

A peer became available for negotiated header sync.

PeerDisconnected(ZakuraPeerId)

A peer disconnected; all of its outstanding work is dropped.

AdvisoryHeaderSummary

First-party header-sync summary observed over the authenticated discovery stream.

Fields

peer: ZakuraPeerId

Peer that supplied its own summary.

summary: HeaderSyncServiceSummary

Advisory header-sync summary for dial/admission preference only.

FullBlockCommitted

State committed a full block.

Fields

height: Height

Committed block height.

hash: Hash

Committed block hash.

NewBlockAccepted

The node’s block pipeline accepted an inbound NewBlock body.

Fields

peer: ZakuraPeerId

Source peer.

height: Height

Accepted block height.

hash: Hash

Accepted block hash.

block: Arc<Block>

Accepted full block.

NewBlockDuplicate

The node’s block pipeline reported an inbound NewBlock was already known.

Fields

peer: ZakuraPeerId

Source peer.

height: Height

Duplicate block height.

hash: Hash

Duplicate block hash.

NewBlockAcceptedNonBestChain

The node’s block pipeline accepted an inbound NewBlock body, but it did not land on the best chain. The block is remembered for dedup only: a non-best-chain block must not advance the header or verified frontiers and must not be forwarded to peers, or the whole Zakura layer gossips a losing branch while the node’s own chain stays on the best one.

Fields

peer: ZakuraPeerId

Source peer.

height: Height

Accepted non-best-chain block height.

hash: Hash

Accepted non-best-chain block hash.

NewBlockRejected

The node’s block pipeline rejected an inbound NewBlock body.

Fields

peer: ZakuraPeerId

Source peer.

hash: Hash

Rejected block hash.

SessionWireMessage

Inbound control message from a specific transport session.

Fields

peer: ZakuraPeerId

Serving peer.

session_id: u64

Ordered-stream generation that delivered the message.

msg: HeaderSyncMessage

Decoded header-sync message.

WireHeaders

Inbound Headers response with its mandatory request ID.

Fields

peer: ZakuraPeerId

Serving peer.

session_id: u64

Ordered-stream generation that delivered the response.

request_id: HeaderSyncRequestId

Request ID echoed by the peer.

headers: Vec<Arc<Header>>

Headers in ascending height order.

body_sizes: Vec<u32>

Advisory serialized body sizes, parallel to headers.

tree_aux_roots: Vec<BlockCommitmentRoots>

Per-height commitment roots, parallel to headers.

WireGetHeaders

Inbound GetHeaders request with its mandatory request ID.

Fields

peer: ZakuraPeerId

Requesting peer.

session_id: u64

Ordered-stream generation that delivered the request.

request_id: HeaderSyncRequestId

Request ID supplied by the peer.

start_height: Height

First requested height.

count: u32

Requested header count.

want_tree_aux_roots: bool

Whether the requester wants all-or-nothing tree-aux roots.

WireDecodeFailed

Header-sync frame decoding failed after handler admission.

Fields

peer: ZakuraPeerId

Peer that sent the malformed frame.

error: Arc<HeaderSyncWireError>

Decode/validation error.

WireProtocolFailure

Header-sync protocol failure decoded by the peer-owned session.

Fields

peer: ZakuraPeerId

Peer that sent the invalid message.

reason: HeaderSyncMisbehavior

Misbehavior classification for the protocol failure.

error: Arc<HeaderSyncWireError>

Decode/validation error.

StateFrontiersChanged(HeaderSyncFrontiers)

State finalized or verified-body frontiers changed.

VctRootRepairRequested

State needs a bounded re-delivery of VCT supplied roots for a covered height.

Fields

height: Height

Height whose supplied root is missing or was evicted after rejection.

generation: u64

State repair generation.

anchor_hash: Hash

Parent hash for height - 1, used as the first header anchor.

expected_hashes: Vec<(Height, Hash)>

Canonical hashes expected in the repair response, starting at height.

VctRootRepairResolved

State successfully committed the formerly parked VCT height.

Fields

generation: u64

State repair generation that was resolved.

HeaderRangeCommitted

State successfully committed a header range.

Fields

start_height: Height

First committed height.

tip_height: Height

New best header tip height.

tip_hash: Hash

New best header tip hash.

HeaderRangeCommitFailed

State rejected a previously requested range.

Fields

peer: ZakuraPeerId

Peer that supplied the failed range.

session_id: u64

Ordered-stream generation that supplied the range.

start_height: Height

First failed range height.

count: u32

Failed range count.

kind: HeaderSyncCommitFailureKind

Whether state rejected peer data or hit a local resource/channel failure.

HeaderRangeResponseFinished

Node wiring finished or abandoned a Headers response to an inbound GetHeaders.

Fields

peer: ZakuraPeerId

Peer whose served-response slot can be released.

session_id: u64

Ordered-stream generation that requested the range.

request_id: HeaderSyncRequestId

Request ID supplied by the peer.

start_height: Height

First requested height.

requested_count: u32

Requested header count.

returned_count: u32

Number of headers read from state and sent in the response.

HeaderRangeResponseReady

State returned headers requested by a peer and the reactor should send them.

Fields

peer: ZakuraPeerId

Peer whose inbound request is being served.

session_id: u64

Ordered-stream generation that requested the range.

request_id: HeaderSyncRequestId

Request ID supplied by the peer.

start_height: Height

First requested height.

requested_count: u32

Requested header count.

want_tree_aux_roots: bool

Whether the original request wanted all-or-nothing tree-aux roots.

headers: Vec<Arc<Header>>

Bounded headers returned by state.

body_sizes: Vec<u32>

Advisory serialized body sizes, parallel to headers.

tree_aux_roots: Vec<BlockCommitmentRoots>

Per-height commitment roots, parallel to headers.

Trait Implementations

impl Clone for HeaderSyncEvent

fn clone(&self) -> HeaderSyncEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HeaderSyncEvent

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

Formats the value using the given formatter.