dex_sdk/
lib.rs

1// Copyright (c) 2026 Super Durable, Inc.
2//
3// Licensed under the Super Durable Source License 1.0.
4// You may not use this file except in compliance with the License.
5// See the LICENSE file in the repository root.
6//
7// SPDX-License-Identifier: LicenseRef-Super-Durable-1.0
8
9//! Strongly typed Rust client and worker APIs for durable Dex Flows.
10//!
11//! Define [`Flow`] and [`Step`] implementations, register them with [`Registry`], host them with
12//! [`Worker`], and control executions with [`Client`]. The crate also exposes typed Attributes,
13//! Channels, waits, decisions, RPCs, lifecycle options, and structured errors.
14
15#![deny(missing_docs)]
16
17mod attribute;
18mod channel;
19mod client;
20mod client_options;
21mod context;
22mod flow;
23mod flow_config;
24mod flow_info;
25mod flow_result;
26mod flow_timeout_handler_options;
27mod handler_error;
28mod persistence;
29mod registry;
30mod retry_policy;
31mod rpc;
32mod sdk_error;
33mod start_flow_options;
34mod step;
35mod step_execution;
36mod step_options;
37mod stop_flow_options;
38mod stream;
39mod sub_flow;
40mod time_travel_options;
41mod timer;
42mod value;
43mod value_hydrator;
44mod value_mapper;
45mod wait;
46mod worker;
47mod worker_dispatcher;
48mod worker_options;
49mod worker_output;
50
51pub use attribute::{Attribute, AttributeIndex, AttributeMap, AttributeMapLoad};
52pub use channel::{Channel, ChannelGuard, ChannelMap, ChannelMapLoad, ChannelMessage};
53pub use client::Client;
54pub use client_options::ClientOptions;
55pub use context::{Context, RecoveryErrorInfo};
56pub use dex_blob_cache::{BlobCache, BlobCacheConfig};
57pub use flow::{Flow, FlowTimeoutHandler};
58pub use flow_config::{ActiveStepSearchMode, FlowConfig};
59pub use flow_info::{FlowErrorType, FlowInfo, FlowStatus, SearchFlowEntry, SearchFlowsPage};
60pub use flow_result::{FlowResult, StepCompletion};
61pub use flow_timeout_handler_options::{FlowTimeoutHandlerFailure, FlowTimeoutHandlerOptions};
62pub use handler_error::{HandlerError, HandlerResult};
63pub use persistence::PersistenceSchema;
64pub use registry::Registry;
65pub use retry_policy::RetryPolicy;
66pub use rpc::{Rpc, RpcDefinition, RpcList, RpcResult};
67pub use sdk_error::{ErrorSubStatus, SdkError, SdkResult, ServiceError, WorkerError};
68pub use start_flow_options::{FlowTimeoutPolicy, IdReusePolicy, StartFlowOptions};
69pub use step::{Step, StepDecision, StepList, StepMovement};
70pub use step_execution::StepExecutionId;
71pub use step_options::{StepDurability, StepOptions, WaitForFailurePolicy};
72pub use stop_flow_options::StopFlowOptions;
73pub use stream::{BufferedTextStream, BufferedTextStreamOptions, Stream, StreamMessage};
74pub use sub_flow::{SubFlow, SubFlowOptions, SubFlowReusePolicy};
75pub use time_travel_options::{TimeTravelOptions, TimeTravelStepMethod};
76pub use timer::{Timer, TimerId};
77pub use tonic::Code as GrpcCode;
78pub use value::Value;
79pub use wait::{Condition, ConditionCombination, Wait};
80pub use worker::Worker;
81pub use worker_options::{WorkerOptions, WorkerTarget};
82
83pub(crate) use value::short_type_name;
dex_sdk/lib.rs

dex_sdk/
lib.rs
