dex-sdk 1.37.0

// Copyright (c) 2026 Super Durable, Inc.
//
// Licensed under the Sustainable Use License 1.0.
// You may not use this file except in compliance with the License.
// See the LICENSE file in the repository root.
//
// SPDX-License-Identifier: LicenseRef-Sustainable-Use-1.0

//! Strongly typed Rust client and worker APIs for durable Dex Flows.
//!
//! Define [`Flow`] and [`Step`] implementations, register them with [`Registry`], host them with
//! [`Worker`], and control executions with [`Client`]. The crate also exposes typed Attributes,
//! Channels, waits, decisions, RPCs, lifecycle options, and structured errors.

#![deny(missing_docs)]

mod attribute;
mod attribute_match;
mod channel;
mod client;
mod client_options;
mod context;
mod credential;
mod flow;
mod flow_config;
mod flow_info;
mod flow_result;
mod flow_timeout_handler_options;
mod handler_error;
mod persistence;
mod pull_registration;
mod registry;
mod retry_policy;
mod rpc;
mod rpc_invoke_options;
mod sdk_error;
mod search_flows_options;
mod server_protocol;
mod start_flow_options;
mod step;
mod step_execution;
mod step_options;
mod stop_flow_options;
mod stream;
mod sub_flow;
mod time_travel_options;
mod timer;
mod value;
mod value_hydrator;
mod value_mapper;
mod wait;
mod wait_options;
mod worker;
mod worker_dispatcher;
mod worker_options;
mod worker_output;
mod worker_pull;

pub use attribute::{
    Attribute, AttributeIndex, AttributeLock, AttributeMap, AttributeMapInstance, AttributeMapLoad,
};
pub use attribute_match::AttributeMatch;
pub use channel::{Channel, ChannelGuard, ChannelMap, ChannelMapLoad, ChannelMessage};
pub use client::FlowServiceTlsOptions;
pub use client::{AttributeRead, AttributeReads, Client};
pub use client_options::ClientOptions;
pub use context::{Context, RecoveryErrorInfo, StepAttemptProgress};
#[cfg(feature = "api-key-credential")]
pub use credential::{ApiKeyCredential, ApiKeyCredentialBuilder, ApiKeyCredentialError};
pub use credential::{Credential, CredentialError, FileCredential};
pub use dex_blob_cache::{BlobCache, BlobCacheConfig};
pub use flow::{Flow, FlowTimeoutHandler};
pub use flow_config::{ActiveStepSearchMode, FlowConfig};
pub use flow_info::{FlowErrorType, FlowInfo, FlowStatus, SearchFlowEntry, SearchFlowsPage};
pub use flow_result::{FlowResult, StepCompletion};
pub use flow_timeout_handler_options::{FlowTimeoutHandlerFailure, FlowTimeoutHandlerOptions};
pub use handler_error::{HandlerError, HandlerResult};
pub use persistence::PersistenceSchema;
pub use pull_registration::{
    PullQueueRegistrationState, PullRegistrationError, PullRegistrationState,
};
pub use registry::Registry;
pub use retry_policy::RetryPolicy;
pub use rpc::{Rpc, RpcDefinition, RpcList, RpcResult};
pub use rpc_invoke_options::RpcInvokeOptions;
pub use sdk_error::{ErrorSubStatus, SdkError, SdkResult, ServiceError, WorkerError};
pub use search_flows_options::SearchFlowsOptions;
pub use start_flow_options::{FlowTimeoutPolicy, IdReusePolicy, StartFlowOptions};
pub use step::{Step, StepDecision, StepList, StepMovement};
pub use step_execution::StepExecutionId;
pub use step_options::{StepDurability, StepOptions, WaitForFailurePolicy};
pub use stop_flow_options::StopFlowOptions;
pub use stream::{
    BufferedTextStream, BufferedTextStreamOptions, Stream, StreamMessage, StreamMessagesPage,
};
pub use sub_flow::{SubFlow, SubFlowOptions, SubFlowReusePolicy};
pub use time_travel_options::{TimeTravelOptions, TimeTravelStepMethod};
pub use timer::{Timer, TimerId};
pub use tonic::Code as GrpcCode;
pub use value::Value;
pub use wait::{Condition, ConditionCombination, Wait};
pub use wait_options::{WaitForAttributeOptions, WaitForStepCompletionOptions};
pub use worker::Worker;
pub use worker_options::{PullWorkerOptions, WorkerOptions};

pub(crate) use value::short_type_name;