Runtime Suppport

Obelisk provides built-in runtime support functions that can be accessed by workflows and activities.

These functions offer essential capabilities like logging, random number generation, creating join sets, and, others. Activities and webhook endpoints have access to logging support functions, but not to the other workflow-specific functions.

The runtime support functions are defined using WIT (WebAssembly Interface Type) files.

Available Support Types

Used by other Obelisk WIT interfaces as well as the generated extension, contains time and execution interfaces with types like execution-id and others.

obelisk:types/types@3.0.0

Available Support Functions

Here's a breakdown of the available functions, grouped by their WIT interface:

obelisk:log/log@1.0.0

Available to: activities workflows webhook endpoints

This interface provides standard logging functions. All messages are strings.

Example (Rust):

use obelisk::log::log;

log::info("This is an informational message.");
log::error("This is an error message!");

obelisk:workflow/workflow-support@3.0.0

Available to: workflows

Some of these functions act like host-based activities - they avoid the need to spawn a WASM activity to obtain e.g. a random number. Other functions are related to persistent sleep and join set construction.

• enum closing-strategy: An enum defining how a join set behaves when the workflow finishes:

  • complete: All child executions that were submitted to the join set but not yet awaited will be awaited before the workflow completes. This is the default and currently the only supported behavior.

• random-u64(min: u64, max-exclusive: u64) -> u64: Generates a pseudo-random unsigned 64-bit integer within the specified range [min, max-exclusive). The max-exclusive value is not included in the possible results.

• random-u64-inclusive(min: u64, max-inclusive: u64) -> u64: Generates a pseudo-random unsigned 64-bit integer within the specified inclusive range [min, max-inclusive]. The max-inclusive value is included in the possible results.

• random-string(min-length: u16, max-length-exclusive: u16) -> string: Generates a pseudo-random alphanumeric string (containing uppercase and lowercase letters, and digits) with a length between min-length (inclusive) and max-length-exclusive (exclusive).

• sleep(duration: duration): Persistently pauses the workflow's execution for the specified duration. The sleep duration can be specified in milliseconds, seconds, minutes, hours, or days.

• submit-delay: func(join-set-id: borrow<join-set-id>, timeout: schedule-at) -> delay-id: Submit a delay request to the join set. The delay can be later polled using join-next.

• new-join-set-named(name: string, closing-strategy: closing-strategy) -> result<join-set-id, join-set-create-error>: Creates a new join set with a user-provided name.

• new-join-set-generated(closing-strategy: closing-strategy) -> join-set-id: Creates a new join set with an automatically generated, unique name.

• close: func(join-set: join-set): Closes the join set.

• join-next: func(join-set-id: borrow<join-set-id>) -> result<response-id, join-next-error>: Block the workflow execution until next response associated with the join set arrives. The response is marked as processed. Child execution result can be obtained using -get extension function using the returned execution ID. Return none if the join set has all requests matched with responses.

obelisk:activity/process@1.0.0

Available to: Activities

The process WIT interface allows activities to spawn, wait for, kill etc. a local process.

See Process API for details.