Class PipelineStateApi

Defined in File PipelineStateApi.hpp

Class Documentation

class PipelineStateApi

Public Functions

inline PipelineStateApi(std::shared_ptr<MessageQueue> pipelineStateOut, std::shared_ptr<InputQueue> pipelineStateRequest, const std::vector<std::shared_ptr<Node>> &allNodes)

inline NodesStateApi nodes()

inline NodesStateApi nodes(const std::vector<Node::Id> &nodeIds)

inline NodeStateApi nodes(Node::Id nodeId)

void stateAsync(std::function<void(const PipelineState&)> callback, std::optional<PipelineEventAggregationConfig> config = std::nullopt)