Expand description
The graph: topology, validation, execution and stream shutdown.
Structurally this is an index arena: entities live in Vecs and refer to each other by
usize id (see docs/design.md §6.1), which avoids a graph of self-referential pointers.
Queues belong to a consumer’s input port, not to an edge: one edge may feed several consumers and each of them must receive every packet, so a shared queue would make them steal packets from one another. An edge therefore only carries topology and closed-state, and packets are dispatched per consumer — cloning a reference, never the payload.
Structs§
- Graph
- A handle to a computation graph.
- Graph
Inner - Input
- 图输入口句柄(热路径免按名字查表)。
- Input
Queue Stats Snapshot - 节点单个输入口的队列与背压统计快照。
- Node
Stats Snapshot LMFlowNodeStats的 Rust 侧快照。- Poller
- 拉模式输出句柄。
- Poller
Backpressure Stats Snapshot - Poller
Options - Options for
Graph::add_poller_with_options. - Watermark
Backpressure Stats Snapshot
Enums§
- DotView
- Graphviz DOT 输出的详细程度。
- Output
Event - A typed event from an output poller that observes timestamp bounds.
- Poller
Overflow - A bounded poller’s behavior when its queue reaches capacity.
- State
- 与
LMFlowGraphState一致。