![]() ![]() "Decision Engine" -> "Planner" : schedule actions "Planner" -> "Decision Engine" : planner plugin "Decision Engine" "Planner" : load actions scheduler "Strategy" -> "Strategy" : compute/set the solution global efficacy "Strategy" -> "Strategy" : compute/set efficacy indicators for the solution : compute/set needed actions for the solution so it achieves its goal "Strategy" -> "Ceilometer API" : get necessary metrics Loop while enough history data for the strategy : copy of the in-memory cluster data model "Cluster Data Model Collector" -> "Strategy"\ "Strategy" -> "Cluster Data Model Collector" : get cluster data model "Decision Engine" -> "Strategy" : execute strategy : select appropriate optimization strategy (via the Strategy Selector) "AMQP Bus" "Database" : get audit parameters (goal, strategy. "Decision Engine" -> "Database" : update audit.state = ONGOING "AMQP Bus" -> "Decision Engine" : trigger audit ) select appropriate optimization strategy (via the Strategy Selector) execute strategy Strategy get cluster data model copy of the in-memory cluster data model loop get necessary metrics aggregated metrics compute/set needed actions for the solution so it achieves its goal compute/set efficacy indicators for the solution compute/set the solution global efficacy solution (unordered actions, efficacy indicators and global efficacy) load actions scheduler Planner planner plugin schedule actions schedule actions according to scheduling rules/policies new action plan save new action plan in database update audit.state = SUCCEEDED notify new audit state = SUCCEEDED IdleÄ«arzaH/watcher - seq._decision_engine.txt COPY maxMessageSize 100 Strategy Planner AMQP Bus AMQP Bus Decision Engine Decision Engine Database Database Strategy Cluster Data Model Collector Cluster Data Model Collector Ceilometer API Ceilometer API Planner trigger audit update audit.state = ONGOING notify new audit state = ONGOING get audit parameters (goal, strategy. ) select appropriate optimization strategy (via the Strategy Selector) execute strategy Strategy get cluster data model copy of the in-memory cluster data model loop get necessary metrics aggregated metrics compute/set needed actions for the solution so it achieves its goal compute/set efficacy indicators for the solution compute/set the solution global efficacy solution (unordered actions, efficacy indicators and global efficacy) load actions scheduler Planner planner plugin schedule actions schedule actions according to scheduling rules/policies new action plan save new action plan in database update audit.state = SUCCEEDED notify new audit state = SUCCEEDED Idle Receiver_incompat -> receiver_incompat: shutdownÄeactivate Planner AMQP Bus AMQP Bus Decision Engine Decision Engine Database Database Strategy Cluster Data Model Collector Cluster Data Model Collector Ceilometer API Ceilometer API Planner trigger audit update audit.state = ONGOING notify new audit state = ONGOING get audit parameters (goal, strategy. Sender_broadcast -> sender_broadcast: ignore pause Receiver_incompat -> sender_broadcast: /pause Receiver_incompat -> receiver_incompat: stop playout ' sender_broadcast -> receiver_incompat: /audio Receiver_incompat -> receiver_incompat: start/continue playout Receiver_incompat -> receiver_incompat: check compatibility Sender_broadcast -> receiver_incompat: /audio Sender_broadcast -> sender_broadcast: start sending audio\n(skip /offer) Proc -> sender_broadcast: configure
0 Comments
Leave a Reply. |