octavia.controller.worker.v2 package¶
Subpackages¶
- octavia.controller.worker.v2.flows package
- Submodules
- octavia.controller.worker.v2.flows.amphora_flows module
- octavia.controller.worker.v2.flows.flow_utils module
- octavia.controller.worker.v2.flows.health_monitor_flows module
- octavia.controller.worker.v2.flows.l7policy_flows module
- octavia.controller.worker.v2.flows.l7rule_flows module
- octavia.controller.worker.v2.flows.listener_flows module
- octavia.controller.worker.v2.flows.load_balancer_flows module
- octavia.controller.worker.v2.flows.member_flows module
- octavia.controller.worker.v2.flows.pool_flows module
- Module contents
- octavia.controller.worker.v2.tasks package
- Submodules
- octavia.controller.worker.v2.tasks.amphora_driver_tasks module
- octavia.controller.worker.v2.tasks.cert_task module
- octavia.controller.worker.v2.tasks.compute_tasks module
- octavia.controller.worker.v2.tasks.database_tasks module
- octavia.controller.worker.v2.tasks.lifecycle_tasks module
- octavia.controller.worker.v2.tasks.network_tasks module
- octavia.controller.worker.v2.tasks.notification_tasks module
- octavia.controller.worker.v2.tasks.retry_tasks module
- Module contents
Submodules¶
octavia.controller.worker.v2.controller_worker module¶
- class ControllerWorker[source]¶
Bases:
object
- amphora_cert_rotation(amphora_id)[source]¶
Perform cert rotation for an amphora.
- Parameters
amphora_id – ID for amphora to rotate
- Returns
None
- Raises
AmphoraNotFound – The referenced amphora was not found
- create_health_monitor(health_monitor)[source]¶
Creates a health monitor.
- Parameters
health_monitor – Provider health monitor dict
- Returns
None
- Raises
NoResultFound – Unable to find the object
- create_l7policy(l7policy)[source]¶
Creates an L7 Policy.
- Parameters
l7policy – Provider dict of the l7policy to create
- Returns
None
- Raises
NoResultFound – Unable to find the object
- create_l7rule(l7rule)[source]¶
Creates an L7 Rule.
- Parameters
l7rule – Provider dict l7rule
- Returns
None
- Raises
NoResultFound – Unable to find the object
- create_listener(listener)[source]¶
Creates a listener.
- Parameters
listener – A listener provider dictionary.
- Returns
None
- Raises
NoResultFound – Unable to find the object
- create_load_balancer(loadbalancer, flavor=None, availability_zone=None)[source]¶
Creates a load balancer by allocating Amphorae.
First tries to allocate an existing Amphora in READY state. If none are available it will attempt to build one specifically for this load balancer.
- Parameters
loadbalancer – The dict of load balancer to create
- Returns
None
- Raises
NoResultFound – Unable to find the object
- create_member(member)[source]¶
Creates a pool member.
- Parameters
member – A member provider dictionary to create
- Returns
None
- Raises
NoSuitablePool – Unable to find the node pool
- create_pool(pool)[source]¶
Creates a node pool.
- Parameters
pool – Provider pool dict to create
- Returns
None
- Raises
NoResultFound – Unable to find the object
- delete_amphora(amphora_id)[source]¶
Deletes an existing Amphora.
- Parameters
amphora_id – ID of the amphora to delete
- Returns
None
- Raises
AmphoraNotFound – The referenced Amphora was not found
- delete_health_monitor(health_monitor)[source]¶
Deletes a health monitor.
- Parameters
health_monitor – Provider health monitor dict
- Returns
None
- Raises
HMNotFound – The referenced health monitor was not found
- delete_l7policy(l7policy)[source]¶
Deletes an L7 policy.
- Parameters
l7policy – Provider dict of the l7policy to delete
- Returns
None
- Raises
L7PolicyNotFound – The referenced l7policy was not found
- delete_l7rule(l7rule)[source]¶
Deletes an L7 rule.
- Parameters
l7rule – Provider dict of the l7rule to delete
- Returns
None
- Raises
L7RuleNotFound – The referenced l7rule was not found
- delete_listener(listener)[source]¶
Deletes a listener.
- Parameters
listener – A listener provider dictionary to delete
- Returns
None
- Raises
ListenerNotFound – The referenced listener was not found
- delete_load_balancer(load_balancer, cascade=False)[source]¶
Deletes a load balancer by de-allocating Amphorae.
- Parameters
load_balancer – Dict of the load balancer to delete
- Returns
None
- Raises
LBNotFound – The referenced load balancer was not found
- delete_member(member)[source]¶
Deletes a pool member.
- Parameters
member – A member provider dictionary to delete
- Returns
None
- Raises
MemberNotFound – The referenced member was not found
- delete_pool(pool)[source]¶
Deletes a node pool.
- Parameters
pool – Provider pool dict to delete
- Returns
None
- Raises
PoolNotFound – The referenced pool was not found
- failover_amphora(amphora_id, reraise=False)[source]¶
Perform failover operations for an amphora.
Note: This expects the load balancer to already be in provisioning_status=PENDING_UPDATE state.
- Parameters
amphora_id – ID for amphora to failover
reraise – If enabled reraise any caught exception
- Returns
None
- Raises
octavia.common.exceptions.NotFound – The referenced amphora was not found
- failover_loadbalancer(load_balancer_id)[source]¶
Perform failover operations for a load balancer.
Note: This expects the load balancer to already be in provisioning_status=PENDING_UPDATE state.
- Parameters
load_balancer_id – ID for load balancer to failover
- Returns
None
- Raises
octavia.commom.exceptions.NotFound – The load balancer was not found.
- property services_controller¶
- update_amphora_agent_config(amphora_id)[source]¶
Update the amphora agent configuration.
- Note: This will update the amphora agent configuration file and
update the running configuration for mutatable configuration items.
- Parameters
amphora_id – ID of the amphora to update.
- Returns
None
- update_health_monitor(original_health_monitor, health_monitor_updates)[source]¶
Updates a health monitor.
- Parameters
original_health_monitor – Provider health monitor dict
health_monitor_updates – Dict containing updated health monitor
- Returns
None
- Raises
HMNotFound – The referenced health monitor was not found
- update_l7policy(original_l7policy, l7policy_updates)[source]¶
Updates an L7 policy.
- Parameters
l7policy – Provider dict of the l7policy to update
l7policy_updates – Dict containing updated l7policy attributes
- Returns
None
- Raises
L7PolicyNotFound – The referenced l7policy was not found
- update_l7rule(original_l7rule, l7rule_updates)[source]¶
Updates an L7 rule.
- Parameters
l7rule – Origin dict of the l7rule to update
l7rule_updates – Dict containing updated l7rule attributes
- Returns
None
- Raises
L7RuleNotFound – The referenced l7rule was not found
- update_listener(listener, listener_updates)[source]¶
Updates a listener.
- Parameters
listener – A listener provider dictionary to update
listener_updates – Dict containing updated listener attributes
- Returns
None
- Raises
ListenerNotFound – The referenced listener was not found
- update_load_balancer(original_load_balancer, load_balancer_updates)[source]¶
Updates a load balancer.
- Parameters
original_load_balancer – Dict of the load balancer to update
load_balancer_updates – Dict containing updated load balancer
- Returns
None
- Raises
LBNotFound – The referenced load balancer was not found
octavia.controller.worker.v2.taskflow_jobboard_driver module¶
- class RedisTaskFlowDriver(persistence_driver)[source]¶
Bases:
octavia.controller.worker.v2.taskflow_jobboard_driver.JobboardTaskFlowDriver
- class ZookeeperTaskFlowDriver(persistence_driver)[source]¶
Bases:
octavia.controller.worker.v2.taskflow_jobboard_driver.JobboardTaskFlowDriver