dex_sdk/
lib.rs

1// Copyright (c) 2026 Super Durable, Inc.
2//
3// Licensed under the Sustainable Use 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-Sustainable-Use-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 attribute_match;
19mod channel;
20mod client;
21mod client_options;
22mod context;
23mod flow;
24mod flow_config;
25mod flow_info;
26mod flow_result;
27mod flow_timeout_handler_options;
28mod handler_error;
29mod persistence;
30mod registry;
31mod retry_policy;
32mod rpc;
33mod sdk_error;
34mod start_flow_options;
35mod step;
36mod step_execution;
37mod step_options;
38mod stop_flow_options;
39mod stream;
40mod sub_flow;
41mod time_travel_options;
42mod timer;
43mod value;
44mod value_hydrator;
45mod value_mapper;
46mod wait;
47mod worker;
48mod worker_dispatcher;
49mod worker_options;
50mod worker_output;
51
52pub use attribute::{Attribute, AttributeIndex, AttributeMap, AttributeMapLoad};
53pub use attribute_match::AttributeMatch;
54pub use channel::{Channel, ChannelGuard, ChannelMap, ChannelMapLoad, ChannelMessage};
55pub use client::Client;
56pub use client_options::ClientOptions;
57pub use context::{Context, RecoveryErrorInfo};
58pub use dex_blob_cache::{BlobCache, BlobCacheConfig};
59pub use flow::{Flow, FlowTimeoutHandler};
60pub use flow_config::{ActiveStepSearchMode, FlowConfig};
61pub use flow_info::{FlowErrorType, FlowInfo, FlowStatus, SearchFlowEntry, SearchFlowsPage};
62pub use flow_result::{FlowResult, StepCompletion};
63pub use flow_timeout_handler_options::{FlowTimeoutHandlerFailure, FlowTimeoutHandlerOptions};
64pub use handler_error::{HandlerError, HandlerResult};
65pub use persistence::PersistenceSchema;
66pub use registry::Registry;
67pub use retry_policy::RetryPolicy;
68pub use rpc::{Rpc, RpcDefinition, RpcList, RpcResult};
69pub use sdk_error::{ErrorSubStatus, SdkError, SdkResult, ServiceError, WorkerError};
70pub use start_flow_options::{FlowTimeoutPolicy, IdReusePolicy, StartFlowOptions};
71pub use step::{Step, StepDecision, StepList, StepMovement};
72pub use step_execution::StepExecutionId;
73pub use step_options::{StepDurability, StepOptions, WaitForFailurePolicy};
74pub use stop_flow_options::StopFlowOptions;
75pub use stream::{BufferedTextStream, BufferedTextStreamOptions, Stream, StreamMessage};
76pub use sub_flow::{SubFlow, SubFlowOptions, SubFlowReusePolicy};
77pub use time_travel_options::{TimeTravelOptions, TimeTravelStepMethod};
78pub use timer::{Timer, TimerId};
79pub use tonic::Code as GrpcCode;
80pub use value::Value;
81pub use wait::{Condition, ConditionCombination, Wait};
82pub use worker::Worker;
83pub use worker_options::{WorkerOptions, WorkerTarget};
84
85pub(crate) use value::short_type_name;
dex_sdk/lib.rs

dex_sdk/
lib.rs
