|
Falcon
|
Public Member Functions | |
| ProcessorGraph (GlobalContext &context) | |
| bool | terminated () |
| bool | done () |
| bool | all_processors_running () |
| bool | any_processor_running () |
| void | ConstructProcessorEngines (const YAML::Node &node) |
| YAML::Node | GetProcessorDocumentation () |
| void | Build (const YAML::Node &node) |
| void | Destroy () |
| void | StartProcessing (const std::string &run_group_id, const std::string &run_id, const std::string &template_id, bool test_flag) |
| void | StopProcessing () |
| void | Update (YAML::Node &node) |
| void | Retrieve (YAML::Node &node) |
| void | Apply (YAML::Node &node) |
| std::string | ExportYAML () |
| GraphState | state () const |
| std::string | state_string () const |
| void | set_state (GraphState state) |
| const ProcessorMap & | processors () const |
| const StreamConnections & | connections () const |
| IProcessor * | LookUpProcessor (const std::string &name) |
| std::vector< std::pair< std::string, std::shared_ptr< IState > > > | LookUpStates (const std::vector< std::string > &state_addresses) |
| void | BuildSharedStates (const YAML::Node &node) |
Protected Member Functions | |
| void | CreateConnection (SlotAddress &out, SlotAddress &in) |
| void ProcessorGraph::Apply | ( | YAML::Node & | node | ) |
Apply exposed methods with parameters given in the yaml node
| node | exposed method description |
| void ProcessorGraph::Build | ( | const YAML::Node & | node | ) |
Build the graph
Construct all processors, parse and create connections between them and create shared state.
| node | graph description |
| void ProcessorGraph::ConstructProcessorEngines | ( | const YAML::Node & | node | ) |
Construct processors listed in the graph yaml description.
Looping through the graph description to find every processor, expanded their name, create their instance and run the internal configuration for each.
| node | graph description |
| YAML::Node ProcessorGraph::GetProcessorDocumentation | ( | ) |
Give the documentation of either all registered processor or only processors used in the running graph
| void ProcessorGraph::Retrieve | ( | YAML::Node & | node | ) |
Retrieve the state value for all shared state name given in the yaml node.
| node | shared state description |
| void ProcessorGraph::Update | ( | YAML::Node & | node | ) |
Update processor's shared state with input from the user
| node | graph description |