Struct TaskSpec 

pub struct TaskSpec { /* private fields */ }

The user’s durable intent - what should be executed.

Implementations

impl TaskSpec

pub fn new( id: TaskId, payload: TaskPayload, run_policy: RunPolicy, constraints: TaskConstraints, metadata: TaskMetadata, ) -> Result<Self, TaskSpecError>

Creates a task specification with validated constraints.

parent_task_id defaults to None. Use with_parent to attach a parent before submission.

pub fn with_parent(self, parent_task_id: TaskId) -> Self

Attaches a parent task identifier, returning the modified spec.

Used by the workflow extension to declare parent-child relationships. The parent must exist in the projection when the child is submitted.

Uses debug_assert (not Result) because this is only called from internal workflow submission paths where the parent ID has already been validated against the projection. A nil parent indicates a logic error in the submission pipeline, not invalid user input.

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

Validates this task specification against invariant-sensitive checks.

pub fn id(&self) -> TaskId

Returns this task’s unique identifier.

pub fn payload(&self) -> &[u8]

Returns the task payload bytes.

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

Returns the optional payload content-type hint.

pub fn task_payload(&self) -> &TaskPayload

Returns a reference to the full task payload (bytes + content-type).

pub fn run_policy(&self) -> &RunPolicy

Returns the run policy snapshot for this task.

pub fn constraints(&self) -> &TaskConstraints

Returns the constraints snapshot for this task.

pub fn metadata(&self) -> &TaskMetadata

Returns task metadata.

pub fn parent_task_id(&self) -> Option<TaskId>

Returns the optional parent task identifier.

pub fn tenant_id(&self) -> Option<TenantId>

Returns the optional tenant identifier.

pub fn with_tenant(self, tenant_id: TenantId) -> Self

Attaches a tenant identifier, returning the modified spec.

pub fn set_constraints( &mut self, constraints: TaskConstraints, ) -> Result<(), TaskSpecError>

Replaces task constraints after validating invariants.

pub fn set_metadata(&mut self, metadata: TaskMetadata)

Replaces task metadata.

pub fn set_payload(&mut self, payload: TaskPayload)

Replaces payload bytes and optional content-type hint.

pub fn set_run_policy( &mut self, run_policy: RunPolicy, ) -> Result<(), TaskSpecError>

Replaces run policy after validating policy-shape invariants.

Trait Implementations

impl Clone for TaskSpec

fn clone(&self) -> TaskSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskSpec

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

Formats the value using the given formatter.

impl PartialEq for TaskSpec

fn eq(&self, other: &TaskSpec) -> 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 TaskSpec

impl StructuralPartialEq for TaskSpec