StampFrameId Class
Stage executor that assigns a monotonically-increasing frame id per stream. More...
Declaration
Included Headers
Base class
| class | StageExecutor |
|
Actor-style executor base class — implement to add a new runtime-graph stage. More... | |
Public Member Functions Index
| void | set_ports (const StagePorts &ports) override |
|
Bind the executor to its runtime ports. More... | |
| void | on_input (StageMsg &&msg, std::vector< StageOutMsg > &out) override |
|
Stamp the next per-stream frame id onto the incoming sample if it doesn't already have one. More... | |
Private Member Attributes Index
| std::unordered_map< std::string, std::int64_t > | next_id_ |
| PortId | out_port_ = kInvalidPort |
Description
Stage executor that assigns a monotonically-increasing frame id per stream.
For samples lacking a frame id the executor stamps the next id available for that stream. Used for telemetry, debugging, and as a stable key for downstream joins.
- See Also
- See Also
Definition at line 30 of file StampFrameId.h.
Public Member Functions
on_input()
| virtual |
Stamp the next per-stream frame id onto the incoming sample if it doesn't already have one.
Definition at line 35 of file StampFrameId.h.
set_ports()
| virtual |
Bind the executor to its runtime ports.
Definition at line 33 of file StampFrameId.h.
Private Member Attributes
next_id_
|
Definition at line 38 of file StampFrameId.h.
out_port_
|
Definition at line 39 of file StampFrameId.h.
The documentation for this class was generated from the following file:
Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.