Strategy plugins documentation
Following https://review.openstack.org/#/c/245903, this patchset documents the implementation and integration of custom Strategies with Watcher. Change-Id: I573758695d67d523834f145824b6f6cfdd8997fe
This commit is contained in:
parent
7c52a1448d
commit
3a03eb930c
121
doc/source/dev/plugins.rst
Normal file
121
doc/source/dev/plugins.rst
Normal file
@ -0,0 +1,121 @@
|
|||||||
|
===============
|
||||||
|
Watcher plugins
|
||||||
|
===============
|
||||||
|
|
||||||
|
Writing a Watcher Decision Engine plugin
|
||||||
|
========================================
|
||||||
|
|
||||||
|
Watcher has an external :ref:`strategy <strategy_definition>` plugin interface
|
||||||
|
which gives anyone the ability to integrate an external :ref:`strategy
|
||||||
|
<strategy_definition>` in order to make use of placement algorithms.
|
||||||
|
|
||||||
|
This section gives some guidelines on how to implement and integrate custom
|
||||||
|
Stategies with Watcher.
|
||||||
|
|
||||||
|
Pre-requisites
|
||||||
|
--------------
|
||||||
|
|
||||||
|
Before using any strategy, you should make sure you have your Telemetry service
|
||||||
|
configured so that it would provide you all the metrics you need to be able to
|
||||||
|
use your strategy.
|
||||||
|
|
||||||
|
|
||||||
|
Creating a new plugin
|
||||||
|
---------------------
|
||||||
|
|
||||||
|
First of all you have to:
|
||||||
|
|
||||||
|
- Extend the base ``BaseStrategy`` class
|
||||||
|
- Implement its ``execute`` method
|
||||||
|
|
||||||
|
Here is an example showing how you can write a plugin called ``DummyStrategy``:
|
||||||
|
|
||||||
|
.. code-block:: python
|
||||||
|
|
||||||
|
# Filepath = third-party/third_party/dummy.py
|
||||||
|
# Import path = third_party.dummy
|
||||||
|
|
||||||
|
class DummyStrategy(BaseStrategy):
|
||||||
|
|
||||||
|
DEFAULT_NAME = "dummy"
|
||||||
|
DEFAULT_DESCRIPTION = "Dummy Strategy"
|
||||||
|
|
||||||
|
def __init__(self, name=DEFAULT_NAME, description=DEFAULT_DESCRIPTION):
|
||||||
|
super(DummyStrategy, self).__init__(name, description)
|
||||||
|
|
||||||
|
def execute(self, model):
|
||||||
|
self.solution.add_change_request(
|
||||||
|
Migrate(vm=my_vm, source_hypervisor=src, dest_hypervisor=dest)
|
||||||
|
)
|
||||||
|
# Do some more stuff here ...
|
||||||
|
return self.solution
|
||||||
|
|
||||||
|
As you can see in the above example, the ``execute()`` method returns a
|
||||||
|
solution as required.
|
||||||
|
|
||||||
|
Please note that your strategy class will be instantiated without any
|
||||||
|
parameter. Therefore, you should make sure not to make any of them required in
|
||||||
|
your ``__init__`` method.
|
||||||
|
|
||||||
|
|
||||||
|
Abstract Plugin Class
|
||||||
|
---------------------
|
||||||
|
|
||||||
|
Here below is the abstract ``BaseStrategy`` class that every single strategy
|
||||||
|
should implement:
|
||||||
|
|
||||||
|
.. automodule:: watcher.decision_engine.api.strategy.strategy
|
||||||
|
:noindex:
|
||||||
|
|
||||||
|
.. autoclass:: BaseStrategy
|
||||||
|
:members:
|
||||||
|
|
||||||
|
|
||||||
|
Add a new entry point
|
||||||
|
---------------------
|
||||||
|
|
||||||
|
In order for the Watcher Decision Engine to load your new strategy, the
|
||||||
|
strategy must be registered as a named entry point under the
|
||||||
|
``watcher_strategies`` entry point of your ``setup.py`` file. If you are using
|
||||||
|
pbr_, this entry point should be placed in your ``setup.cfg`` file.
|
||||||
|
|
||||||
|
The name you give to your entry point has to be unique.
|
||||||
|
|
||||||
|
Here below is how you would proceed to register ``DummyStrategy`` using pbr_:
|
||||||
|
|
||||||
|
.. code-block:: ini
|
||||||
|
|
||||||
|
[entry_points]
|
||||||
|
watcher_strategies =
|
||||||
|
dummy = third_party.dummy:DummyStrategy
|
||||||
|
|
||||||
|
|
||||||
|
To get a better understanding on how to implement a more advanced strategy,
|
||||||
|
have a look at the :py:class:`BasicConsolidation` class.
|
||||||
|
|
||||||
|
.. _pbr: http://docs.openstack.org/developer/pbr/
|
||||||
|
|
||||||
|
Using strategy plugins
|
||||||
|
----------------------
|
||||||
|
|
||||||
|
The Watcher Decision Engine service will automatically discover any installed
|
||||||
|
plugins when it is run. If a Python package containing a custom plugin is
|
||||||
|
installed within the same environment as Watcher, Watcher will automatically
|
||||||
|
make that plugin available for use.
|
||||||
|
|
||||||
|
At this point, the way Watcher will use your new strategy if you reference it
|
||||||
|
in the ``goals`` under the ``[watcher_goals]`` section of your ``watcher.conf``
|
||||||
|
configuration file. For example, if you want to use a ``dummy`` strategy you
|
||||||
|
just installed, you would have to associate it to a goal like this:
|
||||||
|
|
||||||
|
.. code-block:: ini
|
||||||
|
|
||||||
|
[watcher_goals]
|
||||||
|
goals = BALANCE_LOAD:basic,MINIMIZE_ENERGY_CONSUMPTION:dummy
|
||||||
|
|
||||||
|
|
||||||
|
You should take care when installing strategy plugins. By their very nature,
|
||||||
|
there are no guarantees that utilizing them as is will be supported, as
|
||||||
|
they may require a set of metrics which is not yet available within the
|
||||||
|
Telemetry service. In such a case, please do make sure that you first
|
||||||
|
check/configure the latter so your new strategy can be fully functional.
|
@ -22,6 +22,7 @@ Introduction
|
|||||||
|
|
||||||
dev/architecture
|
dev/architecture
|
||||||
dev/contributing
|
dev/contributing
|
||||||
|
dev/plugins
|
||||||
|
|
||||||
|
|
||||||
API References
|
API References
|
||||||
|
@ -27,6 +27,10 @@ LOG = log.getLogger(__name__)
|
|||||||
|
|
||||||
@six.add_metaclass(abc.ABCMeta)
|
@six.add_metaclass(abc.ABCMeta)
|
||||||
class BaseStrategy(object):
|
class BaseStrategy(object):
|
||||||
|
"""A Strategy is an algorithm implementation which is able to find a
|
||||||
|
Solution for a given Goal.
|
||||||
|
"""
|
||||||
|
|
||||||
def __init__(self, name=None, description=None):
|
def __init__(self, name=None, description=None):
|
||||||
self._name = name
|
self._name = name
|
||||||
self.description = description
|
self.description = description
|
||||||
|
Loading…
Reference in New Issue
Block a user