datum-core 0.10.6

Rust stream-processing library mirroring Akka/Pekko Streams Typed, built on Ractor actors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

#![forbid(unsafe_code)]
#![doc = include_str!("../README.md")]

mod attributes;

pub mod actor;
pub mod concurrent;
pub mod context;
pub mod dynamic;
pub mod graph;
pub mod instrument;
pub mod io;
pub mod queue;
pub mod stream;
pub mod testkit;

pub use actor::{
    ActorFlow, ActorPubSub, ActorRef, ActorSink, ActorSinkBackpressureMessage, ActorSinkMessage,
    ActorSource, ActorSourceMessage, ActorStatus, ReplyPort, ReplySendError, SinkRef, SourceRef,
    StreamRefFrame, StreamRefId, StreamRefMessage, StreamRefOutbound, StreamRefPayload,
    StreamRefPayloadBatch, StreamRefPayloadBytes, StreamRefProtoConsumer, StreamRefProtoEndpoint,
    StreamRefProtoProducer, StreamRefSettings, StreamRefs, WatchEvent,
};
pub use attributes::{
    Attribute, AttributeError, AttributeResult, Attributes, Fusion, KernelBackend, MetricsLevel,
};
pub use concurrent::{
    Signal, Subscription, SubscriptionOverflow, Topic, TopicOverflow, TopicPublishError,
    TopicTryPublishError,
    channel::{Channel, SendError as ChannelSendError, TrySendError},
};
pub use context::{FlowWithContext, SourceWithContext};
pub use dynamic::{
    BroadcastHub, BroadcastHubConsumerSource, KillSwitches, MergeHub, MergeHubDrainingControl,
    PartitionConsumerInfo, PartitionHub, PartitionHubConsumerSource, SharedKillSwitch,
    UniqueKillSwitch,
};
pub use graph::{
    AnyInlet, AnyOutlet, AsyncBoundary, AsyncBoundaryExecutionConfig, Balance, BidiShape,
    Broadcast, Buffer, Concat, FanInShape, FanOutShape, FanOutShape2, FlowShape,
    FlowShape as GraphFlowShape, FusedExecutionConfig, FusedExecutionReport, FusedExecutorTier,
    FusedNodeAttributes, FusedNodeMetrics, FusedPlanReport, FusedTerminalReport, FusedTierChange,
    FusedTierChangeReason, Graph, GraphBlueprint, GraphBuilder, GraphDsl, GraphStage,
    GraphStageLogic, Identity, ImportedGraph, InHandler, Inlet, InletCursor, Interleave, MapStage,
    Merge, MergeLatest, MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence,
    MergeSorted, OpenInlet, OpenOutlet, OrElse, OutHandler, Outlet, OutletCursor, PartialGraph,
    Partition, PortAllocator, PortId, PortKind, SinkShape, SourceShape, StageSpec, TakeWhile,
    TimerHandler, TypedGraphBuilder, Unzip, UnzipWith, WireDsl, WirePair, WireSpec, Zip, ZipShape,
};
pub use instrument::{
    StreamInstrumentationId, StreamInstrumentationRegistry, StreamInstrumentationRun,
    StreamInstrumentationSnapshot, StreamInstrumentationState,
};
#[cfg(feature = "io-uring-file")]
pub use io::UringFileIO;
pub use io::{
    Compression, FileIO, Framing, FramingByteOrder, InputStreamHandle, IoResult,
    OutputStreamHandle, StreamConverters, TcpBinding, TcpConnection, TcpIncomingConnection,
    TokioByteSink, TokioByteSource, TokioFileIO, TokioTcp,
};
pub use queue::{BoundedSourceQueue, QueueOfferResult, SinkQueue, SourceQueue};
pub use stream::{
    AggregateTimer, BidiFlow, Cancellable, DelayOverflowStrategy, Demand, Flow, IntoSource, Keep,
    Materializer, MaybeHandle, NotUsed, OverflowStrategy, PushOutlet, RestartFlow, RestartSettings,
    RestartSink, RestartSource, RetryFlow, RunnableGraph, Runtime, ScalarArithmeticOp,
    ScalarCompareOp, Sink, SinkCombineStrategy, Source, SourceCombineStrategy, StreamCompletion,
    StreamError, StreamResult, Supervision, SupervisionDecider, SupervisionDirective, ThrottleMode,
};

pub mod prelude {
    pub use crate::{
        AggregateTimer, AsyncBoundary, AsyncBoundaryExecutionConfig, Attribute, AttributeError,
        AttributeResult, Attributes, Balance, BidiFlow, BidiShape, Broadcast, Buffer, Cancellable,
        Channel, ChannelSendError, Concat, DelayOverflowStrategy, Demand, FanInShape, FanOutShape,
        FanOutShape2, Flow, FlowShape, FusedExecutionConfig, FusedExecutionReport,
        FusedExecutorTier, FusedNodeAttributes, FusedNodeMetrics, FusedPlanReport,
        FusedTerminalReport, FusedTierChange, FusedTierChangeReason, Fusion, Graph, GraphBlueprint,
        GraphBuilder, GraphDsl, GraphFlowShape, Identity, ImportedGraph, Inlet, InletCursor,
        Interleave, IntoSource, Keep, KernelBackend, MapStage, Materializer, MaybeHandle, Merge,
        MergeLatest, MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence,
        MergeSorted, MetricsLevel, NotUsed, OpenInlet, OpenOutlet, OrElse, Outlet, OutletCursor,
        OverflowStrategy, PartialGraph, Partition, PushOutlet, RestartFlow, RestartSettings,
        RestartSink, RestartSource, RetryFlow, RunnableGraph, Runtime, ScalarArithmeticOp,
        ScalarCompareOp, Signal, Sink, SinkCombineStrategy, SinkShape, Source,
        SourceCombineStrategy, SourceShape, StreamCompletion, StreamError, StreamInstrumentationId,
        StreamInstrumentationRegistry, StreamInstrumentationRun, StreamInstrumentationSnapshot,
        StreamInstrumentationState, StreamResult, Subscription, SubscriptionOverflow, Supervision,
        SupervisionDecider, SupervisionDirective, TakeWhile, ThrottleMode, Topic, TopicOverflow,
        TopicPublishError, TopicTryPublishError, TrySendError, TypedGraphBuilder, Unzip, UnzipWith,
        WireDsl, WirePair, WireSpec, Zip, ZipShape,
    };
}