The heat.engine.clients.progress Module¶
Helper classes that are simple key-value storages meant to be passed between handle_* and check_*_complete, being mutated during subsequent check_*_complete calls.
Some of them impose restrictions on client plugin API, thus they are put in this client-plugin-agnostic module.
-
class
heat.engine.clients.progress.ServerCreateProgress(server_id, complete=False)[source]¶ Bases:
object
-
class
heat.engine.clients.progress.ServerDeleteProgress(server_id, image_id=None, image_complete=True)[source]¶ Bases:
object
-
class
heat.engine.clients.progress.ServerUpdateProgress(server_id, handler, complete=False, called=False, handler_extra=None, checker_extra=None)[source]¶ Bases:
heat.engine.clients.progress.ServerCreateProgressKeeps track on particular server update task.
handleris a method of client plugin performing required update operation. Its first positional argument must beserver_idand this method must be resilent to intermittent failures, returningTrueif API was successfully called,Falseotherwise.If result of API call is asynchronous, client plugin must have corresponding
check_<handler>method. Its first positional argument must beserver_idand it must returnTrueorFalseindicating completeness of the update operation.For synchronous API calls, set
completeattribute of this object toTrue.[handler|checker]_extraarguments, if passed to constructor, should be dictionaries of{‘args’: tuple(), ‘kwargs’: dict()}structure and contain parameters with which corresponding
handlerandcheck_<handler>methods of client plugin must be called.argsis automatically prepended withserver_id. Missingargsorkwargsare interpreted as empty tuple/dict respectively. Defaults are interpreted as bothargsandkwargsbeing empty.
-
class
heat.engine.clients.progress.VolumeAttachProgress(srv_id, vol_id, device, task_complete=False)[source]¶ Bases:
object
-
class
heat.engine.clients.progress.VolumeBackupRestoreProgress(vol_id, backup_id)[source]¶ Bases:
object
-
class
heat.engine.clients.progress.VolumeDetachProgress(srv_id, vol_id, attach_id, task_complete=False)[source]¶ Bases:
object