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, ) -> Self

Constructs the four restart-relevant chunk component revisions.

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

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