Expand description
Runtime-checked graph, shape, port, and junction primitives.
This module starts Datum’s Akka-like graph layer. It deliberately keeps the first execution slice small: acyclic fused regions with linear stages and a few fan-in/fan-out junctions. Ports are typed at the public API boundary and still validated at runtime so invalid GraphDSL wiring and illegal stage operations fail deterministically.
Structs§
- AnyInlet
- AnyOutlet
- Async
Boundary - Async
Boundary Execution Config - Execution settings for the current graph async-boundary benchmark path.
- Async
Callback - A cloneable, thread-safe handle that injects a callback into the stage’s execution context. The callback is serialized with element processing: callbacks are buffered in a lock-protected queue and drained by the fused executor between element deliveries — the callback itself runs on the executor thread, not the invoker’s thread.
- Balance
- Bidi
Shape - Broadcast
- Concat
- FanIn
Shape - FanOut
Shape - FanOut
Shape2 - Flow
Shape - Fused
Execution Config - Fused
Execution Report - Fused
Segment - Fused
Terminal Report - Graph
Blueprint - Graph
Builder - Graph
Dsl - Graph
Stage Logic - Identity
- Inlet
- Interleave
- MapStage
- Merge
- Merge
Latest - Merge
Preferred - Merge
Preferred Shape - Merge
Prioritized - Merge
Sequence - Merge
Sorted - OrElse
- Outlet
- Partial
Graph - Partition
- PortId
- Sink
Shape - Source
Shape - Stage
Spec - Unzip
- Unzip
With - Zip
- ZipShape