Struct NodeSubscriptionManifest 

pub struct NodeSubscriptionManifest {
    pub protocol_version: SubscriptionProtocolVersion,
    pub epoch: u64,
    pub checkpoint_id: u64,
    pub participant_id: u64,
    pub assignment_certificate: CheckpointAssignmentFence,
    pub streams: Vec<NodeSubscriptionStreamManifest>,
    pub manifest_digest: SubscriptionDigest,
}

Participant-local subscription output bound into its checkpoint manifest.

Fields

protocol_version: SubscriptionProtocolVersion

Exact subscription protocol.

epoch: u64

Checkpoint epoch.

checkpoint_id: u64

Checkpoint id; equal to epoch.

participant_id: u64

Participant publishing this manifest.

assignment_certificate: CheckpointAssignmentFence

Exact assignment and process-incarnation fence.

streams: Vec<NodeSubscriptionStreamManifest>

Canonical stream inventory.

manifest_digest: SubscriptionDigest

SHA-256 of every preceding field.

Implementations

impl NodeSubscriptionManifest

pub fn seal( &mut self, owned_vnodes: &[u16], ) -> Result<(), SubscriptionContractError>

Compute and install the canonical participant-manifest digest.

Errors

Returns the first malformed binding, range, segment, or size error.

pub fn validate( &self, owned_vnodes: &[u16], ) -> Result<(), SubscriptionContractError>

Validate the exact participant binding and owned partition ranges.

Errors

Returns the first malformed binding, range, segment, digest, or size error.

Trait Implementations

impl Clone for NodeSubscriptionManifest

fn clone(&self) -> NodeSubscriptionManifest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeSubscriptionManifest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeSubscriptionManifest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for NodeSubscriptionManifest

impl PartialEq for NodeSubscriptionManifest

fn eq(&self, other: &NodeSubscriptionManifest) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for NodeSubscriptionManifest

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for NodeSubscriptionManifest