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

status_update_retry() WrappedFn
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