ark::pipeline::SubscriberWorkItem

Defined in header “ark/pipeline/subscriber_base.hh”.

This structure is part of the execution phase of a subscriber. It contains enough information for the subscriber to safely execute() it and track its metrics.

Variables

  • AbstractEnvelopeCPtr envelope
    The dequed envelope.

  • std::chrono::steady_clock::time_point start_time
    The time that this opeation began.