Struct ChunkComponentRevisions 

pub struct ChunkComponentRevisions { /* private fields */ }

Component revisions for a one-step chunk definition.

Implementations

impl ChunkComponentRevisions

pub const fn new( reader: ComponentRevision, processor: ComponentRevision, writer: ComponentRevision, checkpoint: ComponentRevision, restart: ChunkRestartContract, ) -> ChunkComponentRevisions

Constructs the four restart-relevant chunk component revisions.

Registers no ItemStream namespaces and no completion-policy revision; use with_stream_revision and with_completion_policy_revision to add them.

pub fn with_stream_revision( self, identity: ComponentStreamIdentity, revision: ComponentRevision, ) -> ChunkComponentRevisions

Registers one ItemStream namespace’s restart-relevant revision.

Namespaces are kept in a deterministic (sorted, not insertion) order so the manifest and fingerprint never depend on registration order. A definition with no registered streams produces a manifest and fingerprint byte-for-byte identical to one built before this method existed.

pub fn stream_revisions( &self, ) -> impl Iterator<Item = (&ComponentStreamIdentity, &ComponentRevision)>

Iterates registered ItemStream namespace revisions in deterministic (sorted) order.

pub fn with_completion_policy_revision( self, revision: ComponentRevision, ) -> ChunkComponentRevisions

Records the restart-relevant revision of an installed crate::CompletionPolicy (an early-completion policy supplementing the chunk’s ChunkSize ceiling).

A definition with no completion policy installed produces a manifest and fingerprint byte-for-byte identical to one built before this method existed.

pub const fn completion_policy_revision(&self) -> Option<&ComponentRevision>

Borrows the completion policy’s restart-relevant revision, if one was registered.

pub const fn delivery_mode(&self) -> ChunkDeliveryMode

Returns the delivery mode declared by the restart contract.

pub const fn in_flight_policy(&self) -> InFlightPolicy

Returns the shutdown policy of an already-open chunk.

pub const fn reader(&self) -> &ComponentRevision

Borrows the revision of the component that reads items.

pub const fn processor(&self) -> &ComponentRevision

Borrows the revision of the component that processes items.

pub const fn writer(&self) -> &ComponentRevision

Borrows the revision of the component that writes items.

pub const fn checkpoint(&self) -> &ComponentRevision

Borrows the revision of the component that produces checkpoints.

pub const fn checkpoint_schema(&self) -> &StateSchemaId

Borrows the declared checkpoint schema.

pub const fn checkpoint_schema_version(&self) -> StateSchemaVersion

Returns the declared checkpoint schema version.

pub const fn context_schema(&self) -> &StateSchemaId

Borrows the declared execution-context schema.

pub const fn context_schema_version(&self) -> StateSchemaVersion

Returns the declared execution-context schema version.

Trait Implementations

impl Clone for ChunkComponentRevisions

fn clone(&self) -> ChunkComponentRevisions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChunkComponentRevisions

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

Formats the value using the given formatter.

impl Eq for ChunkComponentRevisions

impl PartialEq for ChunkComponentRevisions

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ChunkComponentRevisions