octavia.controller.worker package¶

Subpackages¶

Submodules¶

octavia.controller.worker.amphora_rate_limit module¶

class AmphoraBuildRateLimit[source]¶

Bases: object

add_to_build_request_queue(amphora_id, build_priority)[source]¶

has_build_slot()[source]¶

has_highest_priority(amphora_id)[source]¶

remove_all_from_build_req_queue()[source]¶

remove_from_build_req_queue(amphora_id)[source]¶

update_build_status_and_available_build_slots(amphora_id)[source]¶

wait_for_build_slot(amphora_id)[source]¶

octavia.controller.worker.task_utils module¶

Methods common to the controller work tasks.

class TaskUtils(**kwargs)[source]¶

Bases: object

Class of helper/utility methods used by tasks.

get_current_loadbalancer_from_db(loadbalancer_id)[source]¶

Gets a Loadbalancer from db.

Param:	loadbalancer_id: Load balancer ID which to get from db

mark_amphora_status_error(amphora_id)[source]¶

Sets an amphora status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	amphora_id – Amphora ID to set the status to ERROR

mark_health_mon_prov_status_error(health_mon_id)[source]¶

Sets a health monitor provisioning status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	health_mon_id – Health Monitor ID to set prov status to ERROR

mark_l7policy_prov_status_active(l7policy_id)[source]¶

Sets a L7 policy provisioning status to ACTIVE.

NOTE: This should only be called from revert methods.

Parameters:	l7policy_id – L7 Policy ID to set provisioning status to ACTIVE

mark_l7policy_prov_status_error(l7policy_id)[source]¶

Sets a L7 policy provisioning status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	l7policy_id – L7 Policy ID to set provisioning status to ERROR

mark_l7rule_prov_status_error(l7rule_id)[source]¶

Sets a L7 rule provisioning status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	l7rule_id – L7 Rule ID to set provisioning status to ERROR

mark_listener_prov_status_active(listener_id)[source]¶

Sets a listener provisioning status to ACTIVE.

NOTE: This should only be called from revert methods.

Parameters:	listener_id – Listener ID to set provisioning status to ACTIVE

mark_listener_prov_status_error(listener_id)[source]¶

Sets a listener provisioning status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	listener_id – Listener ID to set provisioning status to ERROR

mark_loadbalancer_prov_status_active(loadbalancer_id)[source]¶

Sets a load balancer provisioning status to ACTIVE.

NOTE: This should only be called from revert methods.

Parameters:	loadbalancer_id – Load balancer ID to set provisioning status to ACTIVE

mark_loadbalancer_prov_status_error(loadbalancer_id)[source]¶

Sets a load balancer provisioning status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	loadbalancer_id – Load balancer ID to set provisioning status to ERROR

mark_member_prov_status_error(member_id)[source]¶

Sets a member provisioning status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	member_id – Member ID to set provisioning status to ERROR

mark_pool_prov_status_active(pool_id)[source]¶

Sets a pool provisioning status to ACTIVE.

NOTE: This should only be called from revert methods.

Parameters:	pool_id – Pool ID to set provisioning status to ACTIVE

mark_pool_prov_status_error(pool_id)[source]¶

Sets a pool provisioning status to ERROR.

NOTE: This should only be called from revert methods.

Parameters:	pool_id – Pool ID to set provisioning status to ERROR

unmark_amphora_health_busy(amphora_id)[source]¶

Unmark the amphora_health record busy for an amphora.

NOTE: This should only be called from revert methods.

Parameters:	amphora_id – The amphora id to unmark busy

Module contents¶