Struct TaskIndex 

pub struct TaskIndex(/* private fields */);

O(1) lookup table from TaskId to per-node metadata.

Built once via TaskIndex::build at workflow construction. Stored behind an Arc on Workflow and shared with anything that needs to resolve TaskId → name / timeout / priority / tags on the dispatch hot path.

Implementations

impl TaskIndex

pub fn build(continuation: &WorkflowContinuation) -> Self

Build the index by walking continuation once and hashing each Task node’s id to its TaskId.

pub fn contains(&self, task_id: &TaskId) -> bool

true if the index knows about task_id.

pub fn get(&self, task_id: &TaskId) -> Option<&TaskNodeMetadata>

Borrow the metadata for task_id.

pub fn name(&self, task_id: &TaskId) -> Option<&Arc<str>>

Human-readable node id for task_id, if any.

pub fn priority(&self, task_id: &TaskId) -> Option<u8>

Look up the priority configured on task_id.

pub fn timeout(&self, task_id: &TaskId) -> Option<Duration>

Look up the timeout configured on task_id.

pub fn tags(&self, task_id: &TaskId) -> &[String]

Look up the affinity tags configured on task_id.

Returns a borrow into the index — callers that need to own the tags clone explicitly (e.g. when feeding into TaskHint::new).

pub fn retry_policy(&self, task_id: &TaskId) -> Option<&RetryPolicy>

Look up the retry policy configured on task_id.

pub fn build_task_metadata(&self, task_id: &TaskId) -> TaskMetadata

Build a TaskMetadata from the indexed fields. Equivalent to WorkflowContinuation::build_task_metadata but O(1) instead of O(N) tree walk + per-node SHA-256.

pub fn len(&self) -> usize

Number of indexed task nodes.

pub fn is_empty(&self) -> bool

true when no task nodes are indexed.

Trait Implementations

impl Clone for TaskIndex

fn clone(&self) -> TaskIndex

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskIndex

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

Formats the value using the given formatter.

impl Default for TaskIndex

fn default() -> TaskIndex

Returns the “default value” for a type.