1#![deny(unsafe_code)]
51#![warn(missing_docs)]
52#![warn(clippy::pedantic)]
53#![warn(clippy::nursery)]
54#![allow(dead_code)]
56#![allow(clippy::missing_panics_doc)]
57#![allow(clippy::missing_errors_doc)]
58#![allow(clippy::missing_const_for_fn)]
59#![allow(clippy::module_inception)]
60#![allow(clippy::doc_markdown)]
61#![allow(clippy::cast_possible_truncation)]
62#![cfg_attr(test, allow(clippy::large_stack_arrays))]
63#![cfg_attr(test, allow(clippy::large_stack_frames))]
65#![cfg_attr(feature = "simd-intrinsics", feature(portable_simd))]
66
67pub mod actor;
68pub mod app;
69pub mod audit;
70pub mod bytes;
71pub mod cancel;
72pub mod channel;
73pub mod cli;
74pub mod codec;
75pub mod combinator;
76pub mod config;
77pub mod conformance;
78pub mod console;
79pub mod cx;
80#[cfg(any(feature = "sqlite", feature = "postgres", feature = "mysql"))]
81pub mod database;
82pub mod decoding;
83pub mod distributed;
84pub mod encoding;
85pub mod epoch;
86pub mod error;
87pub mod evidence;
88pub mod evidence_sink;
89pub mod fs;
90pub mod gen_server;
91pub mod grpc;
92pub mod http;
93pub mod io;
94pub mod lab;
95pub mod link;
96pub mod messaging;
97pub mod migration;
98pub mod monitor;
99pub mod net;
100pub mod obligation;
101pub mod observability;
102pub mod plan;
103#[cfg(unix)]
104pub mod process;
105pub mod raptorq;
106pub mod record;
107pub mod remote;
108pub mod runtime;
109pub mod security;
110pub mod server;
111pub mod service;
112pub mod session;
113pub mod signal;
114pub mod spork;
115pub mod stream;
116pub mod supervision;
117pub mod sync;
118#[cfg(any(test, feature = "test-internals"))]
119pub mod test_logging;
120#[cfg(any(test, feature = "test-internals"))]
121pub mod test_ndjson;
122#[cfg(any(test, feature = "test-internals"))]
123pub mod test_utils;
124pub mod time;
125#[cfg(feature = "tls")]
126pub mod tls;
127pub mod trace;
128pub mod tracing_compat;
129pub mod transport;
130pub mod types;
131pub mod util;
132pub mod web;
133
134pub use config::{
136 AdaptiveConfig, BackoffConfig, ConfigError, ConfigLoader, EncodingConfig,
137 PathSelectionStrategy, RaptorQConfig, ResourceConfig, RuntimeProfile, SecurityConfig,
138 TimeoutConfig, TransportConfig,
139};
140pub use cx::{Cx, Scope};
141pub use decoding::{
142 DecodingConfig, DecodingError, DecodingPipeline, DecodingProgress, RejectReason,
143 SymbolAcceptResult,
144};
145pub use encoding::{EncodedSymbol, EncodingError, EncodingPipeline, EncodingStats};
146pub use epoch::{
147 BarrierResult, BarrierTrigger, Epoch, EpochBarrier, EpochBulkheadError,
148 EpochCircuitBreakerError, EpochClock, EpochConfig, EpochContext, EpochError, EpochId,
149 EpochJoin2, EpochPolicy, EpochRace2, EpochScoped, EpochSelect, EpochSource, EpochState,
150 EpochTransitionBehavior, SymbolValidityWindow, bulkhead_call_in_epoch,
151 bulkhead_call_weighted_in_epoch, circuit_breaker_call_in_epoch, epoch_join2, epoch_race2,
152 epoch_select,
153};
154pub use error::{
155 AcquireError, BackoffHint, Error, ErrorCategory, ErrorKind, Recoverability, RecoveryAction,
156 RecvError, Result, ResultExt, SendError,
157};
158pub use lab::{LabConfig, LabRuntime};
159pub use remote::{
160 CancelRequest, CompensationResult, ComputationName, DedupDecision, IdempotencyKey,
161 IdempotencyRecord, IdempotencyStore, Lease, LeaseError, LeaseRenewal, LeaseState, NodeId,
162 RemoteCap, RemoteError, RemoteHandle, RemoteMessage, RemoteOutcome, RemoteTaskId,
163 ResultDelivery, Saga, SagaState, SagaStepError, SpawnAck, SpawnAckStatus, SpawnRejectReason,
164 SpawnRequest, spawn_remote,
165};
166pub use types::{
167 Budget, CancelKind, CancelReason, ObligationId, Outcome, OutcomeError, PanicPayload, Policy,
168 RegionId, Severity, SystemPressure, TaskId, Time, join_outcomes,
169};
170
171#[cfg(feature = "proc-macros")]
176pub use asupersync_macros::{join_all, scope, spawn};
177
178#[cfg(feature = "proc-macros")]
180pub mod proc_macros {
181 pub use asupersync_macros::{join, join_all, race, scope, session_protocol, spawn};
186}