x/cloudcafe
Code Issues Proposed changes

Wait for delete method based on response code.

Browse Source 
Added method to wait for delete of server until a 404 response code is
received.

Change-Id: I9c33dfa8abcab0eb0f0f19943d05f1993ac3f4fe
This commit is contained in:
Apurv Kumaria
2013-07-24 15:53:43 -05:00
parent 26e6b5c58f
commit 4247a91415
1 changed files with 31 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
cloudcafe/compute/servers_api/behaviors.py
View File

@@ -140,9 +140,9 @@ class ServerBehaviors(BaseBehavior):
@param interval_time: The amount of time in seconds to wait
between polling
@type interval_time: Integer
@param interval_time: The amount of time in seconds to wait
@param timeout: The amount of time in seconds to wait
before aborting
@type interval_time: Integer
@type timeout: Integer
"""
interval_time = interval_time or self.config.server_status_interval
@@ -161,6 +161,35 @@ class ServerBehaviors(BaseBehavior):
"observe the server achieving the {1} status.".format(
timeout, 'DELETED'))
def confirm_server_deletion(self, server_id, response_code,
interval_time=None, timeout=None):
"""
@summary: confirm server deletion based on response code.
@param server_id: The uuid of the server
@type server_id: String
@param: response code to wait for to confirm server deletion
@type: Integer
@param interval_time: The amount of time in seconds to wait
between polling
@type interval_time: Integer
@param timeout: The amount of time in seconds to wait
before aborting
@type timeout: Integer
"""
interval_time = interval_time or self.config.server_status_interval
timeout = timeout or self.config.server_build_timeout
end_time = time.time() + timeout
while time.time() < end_time:
resp = self.servers_client.get_server(server_id)
if resp.status_code == response_code:
return
time.sleep(interval_time)
raise TimeoutException(
"wait_for_server_status ran for {0} seconds and did not "
"observe the server achieving the {1} status based on "
"response code.".format(timeout, 'DELETED'))
def get_public_ip_address(self, server):
"""
@summary: Gets the public ip address of instance