Skip to main content

Crate durable_workflow

Crate durable_workflow 

Source
Expand description

Minimal Rust SDK for the Durable Workflow worker protocol.

The crate covers the v1 Rust round-trip: start, signal, query, and durably sleep in 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
ReplayFailure
A stable, machine-readable failure raised when workflow code no longer reconstructs the durable command stream recorded in history.
SignalCall
TimerCall
Future returned by WorkflowContext::sleep.
Worker
WorkerHeartbeatObservation
WorkerRetryPolicy
Bounded retry policy for worker poll acquisition and worker heartbeats.
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