ark::catalog::TelemetryStage

Defined in header “ark/catalog/stages/telemetry_stage.hh”.

---

A stage that can receive telemetry from over the pipeline, and forward them on to the catalog safely. Note: The owning organization configuration must be set in the Pipeline Metadata to define what organization owns the Telemetry data.

Methods

• TelemetryStage(std::string name)
  Constructor.

• ~TelemetryStage()
  Destructor. Implemented privately to handle cleanup.

• void initialize(pipeline::StageInterface & interface)
  Initializes the stage.

• void start()
  Indicates that the system has settled and you should begin any threads or processing.

• void shutdown()
  Stops the stage, shutting down threads.