Crate durable_workflow 

Minimal Rust SDK for the Durable Workflow worker protocol.

The crate covers the v1 Rust round-trip: start, signal, and query workflows, register a Rust worker, poll workflow, activity, and read-only query tasks, reconstruct typed workflow-instance state through deterministic replay, heartbeat worker and activity liveness, and exchange JSON-native payloads through the same avro generic wrapper used by the existing first-party SDKs.

Macros

json

Construct a serde_json::Value from a JSON literal.

Structs

ActivityCall

ActivityContext

ActivityHeartbeatResponse

ActivityTask

Client

ClientBuilder

HistoryEvent

PayloadEnvelope

PollWorkflowTaskResponse

ProtocolFailure

A stable failure returned when a server rejects an SDK protocol version.

QueryContext

Immutable state supplied to a registered query handler.

QueryFailure

A stable, machine-readable workflow query or query-task settlement failure.

QuerySignal

One decoded signal in the committed workflow-history snapshot.

QueryTask

An ephemeral server-routed query task.

RegisterWorkerResponse

SignalCall

Worker

WorkerHeartbeatObservation

WorkflowContext

WorkflowDescription

WorkflowHandle

WorkflowInstance

Typed local state owned by one deterministic workflow invocation.

WorkflowResultOptions

WorkflowTask

Enums

Error

Value

Represents any valid JSON value.

Constants

CONTROL_PLANE_VERSION

DEFAULT_CODEC

JSON_CODEC

QUERY_TASKS_CAPABILITY

Worker-registration capability for server-routed read-only queries.

QUERY_TASK_MINIMUM_WORKER_PROTOCOL_VERSION

First additive worker protocol that defines query-task transport.

SDK_VERSION

WORKER_PROTOCOL_VERSION

Functions

decode_payload

encode_payload

Type Aliases

Result