Struct PartitionedStepNode 

pub struct PartitionedStepNode { /* private fields */ }

A bounded local partition manager and its ordinary worker-step definition.

Implementations

impl PartitionedStepNode

pub fn new( id: NodeId, step_name: StepName, worker: StepNode, partitioner: ComponentRevision, aggregation: ComponentRevision, partitions: PartitionCount, budget: PartitionBudget, ) -> Self

Declares the complete restart-relevant local partition shape.

pub const fn with_failure_policy( self, failure_policy: LocalFailurePolicy, ) -> Self

Selects sibling failure behavior.

pub const fn with_start_controls(self, start: StartControls) -> Self

Declares the partition manager’s start controls.

pub const fn id(&self) -> &NodeId

Borrows the stable manager node identifier.

pub const fn step_name(&self) -> &StepName

Borrows the manager’s durable step name.

pub const fn worker(&self) -> &StepNode

Borrows the ordinary tasklet or chunk worker declaration.

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

Borrows the deterministic partitioner revision.

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

Borrows the deterministic aggregation revision.

pub const fn partition_count(&self) -> PartitionCount

Returns the finite partition count.

pub const fn budget(&self) -> PartitionBudget

Returns the finite local resource budget.

pub const fn failure_policy(&self) -> LocalFailurePolicy

Returns sibling failure behavior.

pub const fn start_controls(&self) -> StartControls

Returns the partition manager’s start controls.

Trait Implementations

impl Clone for PartitionedStepNode

fn clone(&self) -> PartitionedStepNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionedStepNode

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

Formats the value using the given formatter.

impl Eq for PartitionedStepNode

impl PartialEq for PartitionedStepNode

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PartitionedStepNode