Struct Task 

pub struct Task { /* private fields */ }

Unified task resource.

Every task is represented as a single resource with three sections:

• status - observed state: current phase, attempts, errors (TaskStatus)
• spec - desired state: what to run and how (TaskSpec)
• metadata - identity, versioning, timestamps (ObjectMeta)

Also

• TaskSpec desired state (what to run, how to restart).
• TaskStatus observed state (phase, attempt, exit code).
• TaskRun per-attempt execution record.
• ObjectMeta identity and versioning.
• TaskPhase lifecycle state machine.

Implementations

impl Task

pub fn new(id: TaskId, spec: TaskSpec) -> Self

Create a new task in TaskPhase::Pending phase.

pub fn metadata(&self) -> &ObjectMeta

Resource metadata (identity, resource_version, timestamps).

pub fn status(&self) -> &TaskStatus

Observed state (phase, attempt, exit code, error).

pub fn spec(&self) -> &TaskSpec

Desired state (what to run, how to restart).

pub fn into_parts(self) -> (ObjectMeta, TaskSpec, TaskStatus)

Destructure into (metadata, spec, status). Used by transport layers that need owned fields for serialization into wire types.

pub fn transition_starting(&mut self)

Transition the task into a new attempt: bumps attempt counter, sets phase to Running, clears error/exit_code.

pub fn transition_finished( &mut self, phase: TaskPhase, error: Option<String>, exit_code: Option<i32>, ) -> ModelResult<()>

Transition the current attempt into a terminal phase with optional error and exit code.

Rejects illegal transitions:

• target phase must be terminal (see TaskPhase::is_terminal); finishing into Pending or Running is a logic bug upstream.

Sticky terminals: once an attempt has reached a specific final state (Succeeded, Canceled, or Timeout), a later, conflicting terminal event must not overwrite it. taskvisor emits two terminal events per run (the per-attempt TaskStopped/TaskCanceled/TaskFailed followed by the actor-level ActorExhausted/ActorDead); without this guard a trailing ActorExhausted would flip a Canceled run into Exhausted. A failure-class phase (Failed) is still allowed to be refined into a more specific disposition (Exhausted/Timeout), and re-applying the same phase is a harmless no-op.

Bumps resource_version only when the phase actually changes.

pub fn id(&self) -> &TaskId

Task identifier (shortcut for metadata.id).

pub fn slot(&self) -> &Slot

Slot (shortcut for spec.slot()).

pub fn labels(&self) -> &Labels

Labels (shortcut for spec.labels()).

pub fn phase(&self) -> &TaskPhase

Current phase (shortcut for status.phase).

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Task

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Task

impl PartialEq for Task

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

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Task