Struct ProcessIdentity 

pub struct ProcessIdentity {
    pub process_id: ProcessId,
    pub tenant_id: TenantId,
    pub workflow_id: WorkflowId,
    /* private fields */
}

A serializable value type that bundles all four process identifiers.

Use ProcessIdentity to persist process routing information without keeping a live Process handle. When a new inbound EDIFACT message arrives and must be routed to a running process, look up the identity in your routing table and call Process::from_identity to attach.

Example

// Persist after process creation:
let identity = process.identity();
routing_table.insert(utilmd_conversation_id, identity.clone());

// Restore on a subsequent message:
let identity = routing_table.get(&aperak_conversation_id)?;
let process = Process::<MyWorkflow, _>::from_identity(store, identity);
process.execute(HandleAperak { .. }).await?;

Fields

process_id: ProcessId

The stable process identifier.

tenant_id: TenantId

The tenant that owns this process.

workflow_id: WorkflowId

The workflow version under which this process was created.

Implementations

impl ProcessIdentity

pub fn new( process_id: ProcessId, tenant_id: TenantId, workflow_id: WorkflowId, ) -> Self

Construct a ProcessIdentity, deriving stream_id automatically from tenant_id and process_id.

stream_id is always StreamId::for_process(tenant_id, &process_id) — callers must not supply it independently to avoid accidental mismatches.

pub fn stream_id(&self) -> &StreamId

The event stream identifier for this process.

Trait Implementations

impl Clone for ProcessIdentity

fn clone(&self) -> ProcessIdentity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessIdentity

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProcessIdentity

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ProcessIdentity

impl PartialEq for ProcessIdentity

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

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 ProcessIdentity