octavia.controller.worker package

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

Creative Commons Attribution 3.0 License

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.