ark::distill::DistillStage

Defined in header “ark/distill/stages/distill_stage.hh”.

DistillStage is used to distil information from a stream of messages and generate a report of the information observed.

Methods

  • DistillStage(std::string name)
    Constructor. Initialize the given stage with the specified name.

  • ~DistillStage()
    Virtual destructor, for cleanup.

  • void initialize(pipeline::StageInterface & interface)
    Called on initialization, when a pipeline is first starting. A context is passed into the initialization routine, which allows you to register callbacks and timers.

  • DistilledReport report()
    Generate a report on the data observed.

  • bool get_msg_received()
    Return the message received flag.