Struct TaskConstraints 

pub struct TaskConstraints { /* private fields */ }

Constraints that control how a task’s runs are executed.

Implementations

impl TaskConstraints

pub fn new( max_attempts: u32, timeout_secs: Option<u64>, concurrency_key: Option<String>, ) -> Result<Self, TaskConstraintsError>

Creates constraints with validation of invariant-sensitive fields.

pub fn validate(&self) -> Result<(), TaskConstraintsError>

Validates this constraints object against core invariants.

pub fn max_attempts(&self) -> u32

Returns the maximum number of attempts allowed for each run.

pub fn timeout_secs(&self) -> Option<u64>

Returns the optional per-attempt timeout in seconds.

pub fn concurrency_key(&self) -> Option<&str>

Returns the optional concurrency key.

pub fn set_max_attempts( &mut self, max_attempts: u32, ) -> Result<(), TaskConstraintsError>

Sets the attempt cap with invariant validation.

pub fn set_timeout_secs( &mut self, timeout_secs: Option<u64>, ) -> Result<(), TaskConstraintsError>

Sets the optional timeout in seconds.

Errors

Returns TaskConstraintsError::ZeroTimeout if timeout_secs is Some(0).

pub fn set_concurrency_key( &mut self, concurrency_key: Option<String>, ) -> Result<(), TaskConstraintsError>

Sets the optional concurrency key.

Errors

Returns TaskConstraintsError::EmptyConcurrencyKey if the key is Some("").

pub fn concurrency_key_hold_policy(&self) -> ConcurrencyKeyHoldPolicy

Returns the concurrency key hold policy.

pub fn set_concurrency_key_hold_policy( &mut self, policy: ConcurrencyKeyHoldPolicy, )

Sets the concurrency key hold policy.

pub fn safety_level(&self) -> SafetyLevel

Returns the safety level classification for this task.

pub fn set_safety_level(&mut self, safety_level: SafetyLevel)

Sets the safety level classification.

pub fn required_capabilities(&self) -> Option<&[String]>

Returns the required executor capabilities, if any.

In v0.x the local executor handles all tasks (this field is ignored). In Sprint 4 (v1.0), only remote actors declaring all listed capabilities will be offered this task.

pub fn with_capabilities( self, caps: Vec<String>, ) -> Result<Self, TaskConstraintsError>

Attaches required capabilities, returning the modified constraints.

The list must be non-empty; an empty vec is rejected at validation.

Trait Implementations

impl Clone for TaskConstraints

fn clone(&self) -> TaskConstraints

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskConstraints

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

Formats the value using the given formatter.

impl Default for TaskConstraints

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for TaskConstraints

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for TaskConstraints

impl StructuralPartialEq for TaskConstraints