Struct ActivityContext 

pub struct ActivityContext { /* private fields */ }

Handler-facing context for one activity execution.

Implementations

impl ActivityContext

pub fn new( activity_id: ActivityId, attempt: u32, ) -> (Self, ActivityCancellationHandle)

Creates a context and the internal handle that can signal cancellation.

pub const fn activity_id(&self) -> &ActivityId

Returns this activity’s identifier.

pub const fn attempt(&self) -> u32

Returns this activity’s attempt number.

pub fn heartbeat(&self, detail: Option<Payload>) -> Result<(), WorkerError>

Emits a cooperative heartbeat request for this activity.

This is the PROGRESS channel: handlers call it to attach a progress payload to the activity’s liveness record. LIVENESS itself is owned by the worker runtime, which automatically heartbeats every in-flight activity within the server-assigned heartbeat window — a handler that never calls this still stays live for as long as it genuinely runs. Contexts created without a live heartbeat sender remain no-op contexts for isolated unit tests.

Errors

Returns WorkerError when an installed heartbeat seam has been closed or when the context lacks the workflow id required by the live session.

pub fn emit_event(&self, event: ActivityEvent) -> Result<(), WorkerError>

Emit a neutral agent-observability ActivityEvent onto the transcript seam (NOI-5b).

Additive and OPTIONAL: on a context created without a live event seam (every isolated unit test, and every activity that does not run an instrumented agent) this is a no-op returning Ok(()), so behaviour is byte-identical to today. When a seam is installed the worker runtime drains these events and forwards them to the server’s transcript sequencer, which stamps the commit-allocated store_seq — the producer never assigns it.

Harness-neutral: the payload is a pure aion-core ActivityEvent; the per-harness mapping lives in the worker-side adapter, never here.

Errors

Returns WorkerError when an installed event seam has been closed (the runtime drain end was dropped) — a dropped transcript event is surfaced, never silently swallowed.

pub fn is_cancelled(&self) -> bool

Returns true once cooperative cancellation has been signalled.

pub async fn cancelled(&self)

Resolves when cooperative cancellation is signalled.

Trait Implementations

impl Clone for ActivityContext

fn clone(&self) -> ActivityContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityContext

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

Formats the value using the given formatter.