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, 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

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