Skip to main content

decode_publication

ozzy_replication::wire

Function decode_publication 

Source 
pub fn decode_publication<'a>(
    frames: &[&'a [u8]],
    binding: PeerBinding,
    local: NodeId,
    scope: Scope,
    limits: WireLimits,
) -> Result<PrepareBatch<'a>, WireError>
Expand description

Decode only from a separately bound publisher socket. Reject wrong leader, scope or group before hashing any payload. PUB receipt is neither admission nor a vote; ordinary receive and core checks still apply.