datum/
lib.rs

1#![forbid(unsafe_code)]
2#![doc = include_str!("../README.md")]
3
4mod attributes;
5
6pub mod actor;
7pub mod concurrent;
8pub mod context;
9pub mod dynamic;
10pub mod graph;
11pub mod instrument;
12pub mod io;
13pub mod queue;
14pub mod stream;
15pub mod testkit;
16
17pub use actor::{
18    ActorFlow, ActorPubSub, ActorRef, ActorSink, ActorSinkBackpressureMessage, ActorSinkMessage,
19    ActorSource, ActorSourceMessage, ActorStatus, ReplyPort, ReplySendError, SinkRef, SourceRef,
20    StreamRefFrame, StreamRefId, StreamRefMessage, StreamRefOutbound, StreamRefPayload,
21    StreamRefPayloadBatch, StreamRefPayloadBytes, StreamRefProtoConsumer, StreamRefProtoEndpoint,
22    StreamRefProtoProducer, StreamRefSettings, StreamRefs, WatchEvent,
23};
24pub use attributes::{
25    Attribute, AttributeError, AttributeResult, Attributes, Fusion, KernelBackend, MetricsLevel,
26};
27pub use concurrent::{
28    Signal, Subscription, SubscriptionOverflow, Topic, TopicOverflow, TopicPublishError,
29    TopicTryPublishError,
30    channel::{Channel, SendError as ChannelSendError, TrySendError},
31};
32pub use context::{FlowWithContext, SourceWithContext};
33pub use dynamic::{
34    BroadcastHub, BroadcastHubConsumerSource, KillSwitches, MergeHub, MergeHubDrainingControl,
35    PartitionConsumerInfo, PartitionHub, PartitionHubConsumerSource, SharedKillSwitch,
36    UniqueKillSwitch,
37};
38pub use graph::{
39    AnyInlet, AnyOutlet, AsyncBoundary, AsyncBoundaryExecutionConfig, Balance, BidiShape,
40    Broadcast, Buffer, Concat, FanInShape, FanOutShape, FanOutShape2, FlowShape,
41    FlowShape as GraphFlowShape, FusedExecutionConfig, FusedExecutionReport, FusedExecutorTier,
42    FusedNodeAttributes, FusedNodeMetrics, FusedPlanReport, FusedTerminalReport, FusedTierChange,
43    FusedTierChangeReason, Graph, GraphBlueprint, GraphBuilder, GraphDsl, GraphStage,
44    GraphStageLogic, Identity, ImportedGraph, InHandler, Inlet, InletCursor, Interleave, MapStage,
45    Merge, MergeLatest, MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence,
46    MergeSorted, OpenInlet, OpenOutlet, OrElse, OutHandler, Outlet, OutletCursor, PartialGraph,
47    Partition, PortAllocator, PortId, PortKind, SinkShape, SourceShape, StageSpec, TakeWhile,
48    TimerHandler, TypedGraphBuilder, Unzip, UnzipWith, WireDsl, WirePair, WireSpec, Zip, ZipShape,
49};
50pub use instrument::{
51    StreamInstrumentationId, StreamInstrumentationRegistry, StreamInstrumentationRun,
52    StreamInstrumentationSnapshot, StreamInstrumentationState,
53};
54#[cfg(feature = "io-uring-file")]
55pub use io::UringFileIO;
56pub use io::{
57    Compression, FileIO, Framing, FramingByteOrder, InputStreamHandle, IoResult,
58    OutputStreamHandle, StreamConverters, TcpBinding, TcpConnection, TcpIncomingConnection,
59    TokioByteSink, TokioByteSource, TokioFileIO, TokioTcp,
60};
61pub use queue::{BoundedSourceQueue, QueueOfferResult, SinkQueue, SourceQueue};
62pub use stream::{
63    AggregateTimer, BidiFlow, Cancellable, DelayOverflowStrategy, Demand, Flow, IntoSource, Keep,
64    Materializer, MaybeHandle, NotUsed, OverflowStrategy, PushOutlet, RestartFlow, RestartSettings,
65    RestartSink, RestartSource, RetryFlow, RunnableGraph, Runtime, ScalarArithmeticOp,
66    ScalarCompareOp, Sink, SinkCombineStrategy, Source, SourceCombineStrategy, StreamCompletion,
67    StreamError, StreamResult, Supervision, SupervisionDecider, SupervisionDirective, ThrottleMode,
68};
69
70pub mod prelude {
71    pub use crate::{
72        AggregateTimer, AsyncBoundary, AsyncBoundaryExecutionConfig, Attribute, AttributeError,
73        AttributeResult, Attributes, Balance, BidiFlow, BidiShape, Broadcast, Buffer, Cancellable,
74        Channel, ChannelSendError, Concat, DelayOverflowStrategy, Demand, FanInShape, FanOutShape,
75        FanOutShape2, Flow, FlowShape, FusedExecutionConfig, FusedExecutionReport,
76        FusedExecutorTier, FusedNodeAttributes, FusedNodeMetrics, FusedPlanReport,
77        FusedTerminalReport, FusedTierChange, FusedTierChangeReason, Fusion, Graph, GraphBlueprint,
78        GraphBuilder, GraphDsl, GraphFlowShape, Identity, ImportedGraph, Inlet, InletCursor,
79        Interleave, IntoSource, Keep, KernelBackend, MapStage, Materializer, MaybeHandle, Merge,
80        MergeLatest, MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence,
81        MergeSorted, MetricsLevel, NotUsed, OpenInlet, OpenOutlet, OrElse, Outlet, OutletCursor,
82        OverflowStrategy, PartialGraph, Partition, PushOutlet, RestartFlow, RestartSettings,
83        RestartSink, RestartSource, RetryFlow, RunnableGraph, Runtime, ScalarArithmeticOp,
84        ScalarCompareOp, Signal, Sink, SinkCombineStrategy, SinkShape, Source,
85        SourceCombineStrategy, SourceShape, StreamCompletion, StreamError, StreamInstrumentationId,
86        StreamInstrumentationRegistry, StreamInstrumentationRun, StreamInstrumentationSnapshot,
87        StreamInstrumentationState, StreamResult, Subscription, SubscriptionOverflow, Supervision,
88        SupervisionDecider, SupervisionDirective, TakeWhile, ThrottleMode, Topic, TopicOverflow,
89        TopicPublishError, TopicTryPublishError, TrySendError, TypedGraphBuilder, Unzip, UnzipWith,
90        WireDsl, WirePair, WireSpec, Zip, ZipShape,
91    };
92}
datum/lib.rs

datum/
lib.rs
