Struct Task 

pub struct Task { /* private fields */ }

Stored Task resource.

The serialized shape is apiVersion, kind, metadata, spec, status. Name, UID, and creation time are preserved by Self::apply_desired.

Implementations

impl Task

pub fn new(name: impl AsRef<str>, spec: TaskSpec) -> ModelResult<Self>

Creates a stored Task with server-owned defaults.

The UID and creation timestamp are generated, generation starts at 1, and status starts as unobserved Pending. The state store assigns the initial resource version separately.

Errors

Returns ModelError::Invalid when the name or spec is invalid, or the entropy source is unavailable.

pub fn from_manifest(manifest: TaskManifest) -> ModelResult<Self>

Creates a stored resource from a manifest.

Errors

Returns ModelError::Invalid when the manifest is invalid or the entropy source is unavailable.

pub fn from_parts( type_meta: TypeMeta, metadata: ObjectMeta, spec: TaskSpec, status: TaskStatus, ) -> ModelResult<Self>

Reconstructs a resource from persisted fields.

Errors

Returns ModelError::Invalid when a resource invariant is violated.

pub fn validate(&self) -> ModelResult<()>

Validates the complete resource.

Errors

Returns ModelError::Invalid when GVK, metadata, spec, status, generation, or conditions are inconsistent.

pub fn type_meta(&self) -> &TypeMeta

Resource type metadata.

pub fn metadata(&self) -> &ObjectMeta

Resource metadata.

pub fn spec(&self) -> &TaskSpec

Desired state.

pub fn status(&self) -> &TaskStatus

Observed state.

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

Returns the serialized resource fields.

pub fn name(&self) -> &TaskId

Stable resource address (metadata.name).

pub fn uid(&self) -> &Uid

Identity of this resource incarnation.

pub fn slot(&self) -> &Slot

Logical concurrency slot.

pub fn labels(&self) -> &Labels

Resource labels.

pub fn phase(&self) -> &TaskPhase

Current lifecycle phase.

pub fn set_resource_version( &mut self, resource_version: impl Into<String>, ) -> ModelResult<()>

Assigns a state-store resource version.

Errors

Returns ModelError::Invalid when the value is empty.

pub fn apply_desired( &mut self, labels: Labels, annotations: Annotations, spec: TaskSpec, resource_version: impl Into<String>, ) -> ModelResult<DesiredChange>

Applies caller-owned metadata and desired state.

UID and creation time are preserved. Metadata-only changes preserve generation and status. Spec changes increment generation and reset phase and attempt. The previous observedGeneration is retained.

Identical desired state returns DesiredChange::None. In that case, resource_version is not assigned.

Errors

Returns ModelError::Invalid when metadata, spec, or a changed resource_version is invalid.

pub fn mark_observed( &mut self, resource_version: impl Into<String>, ) -> ModelResult<bool>

Marks the current generation as reconciled.

Returns true when status changed. Returns false when the same generation was already reconciled.

Errors

Returns ModelError::Invalid when a changed resource_version is empty.

pub fn mark_reconciliation_pending( &mut self, resource_version: impl Into<String>, ) -> ModelResult<bool>

Reschedules reconciliation after a recorded failure.

Returns false when reconciliation is not failed. A change resets phase, attempt, exit code, and lifecycle error.

Errors

Returns ModelError::Invalid when a changed resource_version is empty.

pub fn mark_reconciliation_failed( &mut self, reason: impl Into<String>, message: impl Into<String>, resource_version: impl Into<String>, ) -> ModelResult<bool>

Records a reconciliation failure.

Desired state is retained. Execution phase and diagnostics are reset.

Returns true when status changed.

Errors

Returns ModelError::Invalid when reason, message, or a changed resource_version is invalid.

pub fn transition_starting( &mut self, generation: u64, attempt: u32, resource_version: impl Into<String>, ) -> ModelResult<bool>

Records an authoritative attempt start.

A stale generation returns false. An identical transition also returns false. Attempt numbers come from the execution source of truth.

Errors

Returns ModelError::Invalid when the current generation has attempt zero or a changed resource_version is empty.

pub fn transition_finished( &mut self, generation: u64, attempt: u32, phase: TaskPhase, error: Option<String>, exit_code: Option<i32>, resource_version: impl Into<String>, ) -> ModelResult<bool>

Records a terminal attempt phase.

A stale generation or older attempt returns false. Terminal phases are sticky. Failed may be refined to Exhausted or Timeout.

Errors

Returns ModelError::Invalid when the current generation has attempt zero, phase is not terminal, or a changed resource_version is empty.

pub fn reconcile_finished( &mut self, generation: u64, phase: TaskPhase, error: Option<String>, exit_code: Option<i32>, resource_version: impl Into<String>, ) -> ModelResult<bool>

Records an authoritative final lifecycle outcome.

Unlike Self::transition_finished, this may replace a conflicting terminal attempt phase. A stale generation or identical outcome returns false.

Errors

Returns ModelError::Invalid when phase is not terminal for the current generation or a changed resource_version is empty.

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 From<&Task> for TaskManifest

fn from(task: &Task) -> Self

Converts to this type from the input type.

impl From<Task> for TaskManifest

fn from(task: Task) -> Self

Converts to this type from the input type.

impl JsonSchema for Task

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for Task

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

Equality operator ==.

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

Inequality operator !=.

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