Struct TaskNamespace 

pub struct TaskNamespace {
    pub tenant_id: String,
    pub package_name: String,
    pub workflow_id: String,
    pub task_id: String,
}

Hierarchical namespace for task identification and isolation.

Provides a structured way to identify tasks across different contexts: multi-tenant environments, packaged workflows, and embedded workflows.

The namespace components form a hierarchy from most general (tenant) to most specific (task), enabling precise task resolution while supporting fallback strategies for compatibility.

Fields

tenant_id: String

Tenant identifier for multi-tenancy support. Default: “public” for single-tenant or public access

package_name: String

Package or deployment context identifier. Default: “embedded” for tasks compiled into the binary For packaged workflows: name from .so file metadata

workflow_id: String

Workflow identifier from workflow macro. Groups related tasks together within a package/tenant

task_id: String

Individual task identifier from task macro. Unique within the workflow context

Implementations

impl TaskNamespace

pub fn new( tenant_id: &str, package_name: &str, workflow_id: &str, task_id: &str, ) -> Self

Create a complete namespace from all components.

This is the most general constructor, useful when all namespace components are known and need to be specified explicitly.

Arguments

• tenant_id - Tenant identifier
• package_name - Package identifier
• workflow_id - Workflow identifier
• task_id - Task identifier

pub fn from_string(namespace_str: &str) -> Result<Self, String>

Create a TaskNamespace from a string representation.

Parses a namespace string in the format “tenant::package::workflow::task” into a TaskNamespace struct.

Arguments

• namespace_str - String in format “tenant::package::workflow::task”

Returns

• Result<TaskNamespace, String> - Successfully parsed namespace or error message

Examples

use cloacina_workflow::TaskNamespace;

let ns = TaskNamespace::from_string("public::embedded::etl::extract").unwrap();
assert_eq!(ns.tenant_id, "public");
assert_eq!(ns.task_id, "extract");

// Invalid format
assert!(TaskNamespace::from_string("invalid_format").is_err());

pub fn is_public(&self) -> bool

Check if this is a public (non-tenant-specific) namespace.

Returns

true if this namespace uses the default “public” tenant

pub fn is_embedded(&self) -> bool

Check if this is an embedded (non-packaged) namespace.

Returns

true if this namespace uses the default “embedded” package

Trait Implementations

impl Clone for TaskNamespace

fn clone(&self) -> TaskNamespace

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskNamespace

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

Formats the value using the given formatter.

impl Display for TaskNamespace

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

Format the namespace as a string using the standard format.

Format: tenant_id::package_name::workflow_id::task_id

Examples

use cloacina_workflow::TaskNamespace;

let ns = TaskNamespace::new("public", "embedded", "etl", "extract");
assert_eq!(ns.to_string(), "public::embedded::etl::extract");

let ns = TaskNamespace::new("tenant_1", "pkg.so", "analytics", "process");
assert_eq!(ns.to_string(), "tenant_1::pkg.so::analytics::process");

impl Hash for TaskNamespace

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for TaskNamespace

fn cmp(&self, other: &TaskNamespace) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for TaskNamespace

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

fn partial_cmp(&self, other: &TaskNamespace) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Eq for TaskNamespace

impl StructuralPartialEq for TaskNamespace