Struct NodeContext 

pub struct NodeContext { /* private fields */ }

Minimal execution context passed to runtime-managed nodes.

Implementations

impl NodeContext

pub fn new( workflow_id: WorkflowId, node_id: NodeId, execution: ExecutionMetadata, ) -> Self

Create an active node context for one execution attempt.

pub fn with_cancellation(self, request: CancellationRequest) -> Self

Create a copy of this context with cancellation requested.

pub fn with_cancellation_token(self, token: CancellationToken) -> Self

Attach a shared cancellation token to this context.

pub const fn workflow_id(&self) -> &WorkflowId

Workflow currently being executed.

pub const fn node_id(&self) -> &NodeId

Node currently being executed.

pub const fn execution(&self) -> &ExecutionMetadata

Execution metadata shared by nodes in the same run.

pub fn cancellation(&self) -> CancellationState

Cancellation state visible to this node.

pub fn cancellation_token(&self) -> CancellationToken

Shared cancellation token visible to this node.

pub fn is_cancelled(&self) -> bool

Return whether cancellation has been requested.

Trait Implementations

impl Clone for NodeContext

fn clone(&self) -> NodeContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeContext

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

Formats the value using the given formatter.

impl PartialEq for NodeContext

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

impl StructuralPartialEq for NodeContext