10 #ifndef HTGS_EXECUTIONPIPELINEBROADCASTRULE_HPP 11 #define HTGS_EXECUTIONPIPELINEBROADCASTRULE_HPP 31 return "DefaultBroadcastRule";
33 void applyRule(std::shared_ptr<T> data,
size_t pipelineId)
override {
39 #endif //HTGS_EXECUTIONPIPELINEBROADCASTRULE_HPP bool canTerminateRule(size_t pipelineId) override
Virtual function to determine if a rule is ready to be terminated.
Definition: ExecutionPipelineBroadcastRule.hpp:28
std::string getName() override
Virtual function to get the name of the IRule.
Definition: ExecutionPipelineBroadcastRule.hpp:30
void shutdownRule(size_t pipelineId) override
Virtual function that handles when a rule is being shutdown for a particular pipelineId.
Definition: ExecutionPipelineBroadcastRule.hpp:29
Provides an interface to send data along RuleManager edges for processing state and dependencies...
Definition: ExecutionPipeline.hpp:34
Provides an interface to send data along RuleManager edges for processing state and dependencies...
void addResult(std::shared_ptr< T > result)
Adds a result value to the output.
Definition: IRule.hpp:188
void applyRule(std::shared_ptr< T > data, size_t pipelineId) override
Pure virtual function to process input data.
Definition: ExecutionPipelineBroadcastRule.hpp:33
the default execution pipeline rule that is used if no other rule is specified for an execution pipel...
Definition: ExecutionPipelineBroadcastRule.hpp:25
Definition: Bookkeeper.hpp:23