Runtime graph
Actor-style runtime DAG, named-port stages, and the GraphSession/GraphRun pair. More...
Topics Index
| Runtime graph nodes | |
|
Stage, fan-out, join, scheduler, and adapter nodes for runtime graphs. More... | |
| Runtime graph internals | |
|
Queue and mailbox primitives used by runtime graph execution. More... | |
Classes Index
| struct | EdgeSpec |
|
Per-edge spec captured by the compiler — the propagated OutputSpec and a completeness flag. More... | |
| struct | CompiledPipelineSegment |
|
Compiled view of a contiguous pipeline-backend segment in the runtime graph. More... | |
| struct | CompiledStageNode |
|
Compiled record for a single stage-backend node in the runtime graph. More... | |
| struct | CompiledGraph |
|
Result produced by Compiler::compile: pipelines, stages, edges, specs, and port names. More... | |
| class | Compiler |
|
Runtime-graph compiler that partitions a Graph into pipeline segments and stages. More... | |
| class | Graph |
|
Directed acyclic graph of hybrid nodes with named ports. More... | |
| struct | PortRef |
|
Handle to a specific port on a node within a runtime Graph, used by the DSL. More... | |
| struct | NodeRef |
|
Handle to a node within a runtime Graph, used by the fluent DSL. More... | |
| struct | StreamMetadataDefaults |
|
Defaults applied to a Sample by the StreamMetadata stage. More... | |
| class | GraphPrinter |
|
Pretty-printer for runtime Graph instances; emits text, dot, or mermaid. More... | |
| struct | Options |
|
Render options controlling which fields and labels are emitted. More... | |
| struct | GraphRunOptions |
|
Tuning knobs for a GraphRun — queue capacities, push/pull timeouts, verbosity. More... | |
| struct | GraphRunStats |
|
Per-node, per-stream telemetry collector for a running GraphRun. More... | |
| struct | GraphRunPullOptions |
|
Tuning knobs for GraphRun::pull_until() / PullSession::run(). More... | |
| class | GraphRun |
| class | GraphSession |
|
Builder for a runtime graph — compile a Graph into a runnable GraphRun. More... | |
| struct | FanOutOptions |
| class | FanOut |
|
Stage executor that duplicates each incoming sample to multiple output ports. More... | |
| struct | JoinBundleOptions |
|
Configuration for a JoinBundle stage executor. More... | |
| class | JoinBundle |
|
Stage executor that joins samples from multiple input ports into a single bundled output. More... | |
| struct | JoinEncodedWithMetaOptions |
|
Configuration for a JoinEncodedWithMeta stage executor. More... | |
| class | JoinEncodedWithMeta |
|
Stage executor that bundles an encoded payload (e.g., H.264) with associated metadata. More... | |
| class | LambdaStage |
|
Generic stage executor whose behavior is supplied by user-provided callbacks. More... | |
| class | PipelineNode |
|
Runtime-graph node that wraps a builder-side NodeGroup (or single Node) as a pipeline-backend node. More... | |
| struct | StageModelExecutorOptions |
|
Configuration for a StageModelExecutor stage. More... | |
| class | StageModelExecutor |
|
Stage executor that runs a Model's inference pipeline as a runtime-graph stage. More... | |
| struct | StageNodeOptions |
|
Options controlling how a StageNode is instantiated and scheduled by the runtime. More... | |
| class | StageNode |
|
Generic runtime-graph node that adapts a StageExecutor factory into a Node. More... | |
| class | StampFrameId |
|
Stage executor that assigns a monotonically-increasing frame id per stream. More... | |
| class | StreamMetadata |
|
Stage executor that fills in stream metadata defaults on passing samples. More... | |
| struct | StreamSchedulerOptions |
|
Configuration for a StreamScheduler stage. More... | |
| class | StreamScheduler |
|
Stage executor that round-robin-schedules samples across multiple streams. More... | |
| class | BlockingQueue<T> |
|
Thread-safe bounded blocking queue used by the runtime mailboxes. More... | |
| struct | StageMailbox |
|
Single thread-safe inbox the runtime delivers messages into for one stage. More... | |
| struct | StageMsg |
|
A single input message handed to a StageExecutor. More... | |
| struct | StageOutMsg |
|
A single output message produced by a StageExecutor. More... | |
| class | StageEmitter |
|
Runtime-owned output handle for stages that stream while on_input() is active. More... | |
| struct | StagePorts |
|
Resolved port-id table for a stage — populated by the runtime before start(). More... | |
| class | StageExecutor |
|
Actor-style executor base class — implement to add a new runtime-graph stage. More... | |
| class | PendingVideoStore |
|
Per-stream store of video frames awaiting their matching detection metadata. More... | |
| class | YoloTokenStore |
|
Per-stream queue of yolo (or other detection) tokens awaiting a matching frame. More... | |
| class | ReleasePacer |
|
Paces downstream releases of paired samples to a target frame rate. More... | |
Enumerations Index
| enum class | JoinKeyPolicy { ... } |
|
Selects how the JoinBundle stage groups samples coming from different inputs. More... | |
| enum class | StageKeyBy { ... } |
|
Selects how the runtime keys messages for a stage node's instance assignment. More... | |
| enum class | StreamDropPolicy { ... } |
|
Policy used by StreamScheduler when a per-stream queue overflows. More... | |
Description
Actor-style runtime DAG, named-port stages, and the GraphSession/GraphRun pair.
Enumerations
JoinKeyPolicy
| strong |
Selects how the JoinBundle stage groups samples coming from different inputs.
The chosen policy determines the join key used to decide which samples belong to the same emitted bundle (e.g., match by stream id + frame id, or by stream id + presentation timestamp).
Definition at line 32 of file JoinBundle.h.
StageKeyBy
| strong |
Selects how the runtime keys messages for a stage node's instance assignment.
- Enumeration values
-
None No keying — round-robin or unconstrained dispatch (= 0) StreamId Key on Sample::stream_id so all messages for a stream go to the same instance
Used by StageNodeOptions::key_by to pick a deterministic assignment policy when a node has multiple executor instances.
Definition at line 32 of file StageNode.h.
StreamDropPolicy
| strong |
Policy used by StreamScheduler when a per-stream queue overflows.
- Enumeration values
-
DropOldest Drop the oldest queued sample when full (= 0) DropNewest Drop the newly arrived sample when full
Selects which sample is dropped to make room when an incoming sample arrives at a full per-stream queue.
Definition at line 31 of file StreamScheduler.h.
Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.