octavia.controller.worker.v1 package¶
Subpackages¶
- octavia.controller.worker.v1.flows package
- Submodules
- octavia.controller.worker.v1.flows.amphora_flows module
AmphoraFlows
AmphoraFlows.cert_rotate_amphora_flow()
AmphoraFlows.get_amphora_for_lb_failover_subflow()
AmphoraFlows.get_amphora_for_lb_subflow()
AmphoraFlows.get_create_amphora_flow()
AmphoraFlows.get_delete_amphora_flow()
AmphoraFlows.get_failover_amphora_flow()
AmphoraFlows.get_vrrp_subflow()
AmphoraFlows.update_amphora_config_flow()
- octavia.controller.worker.v1.flows.health_monitor_flows module
- octavia.controller.worker.v1.flows.l7policy_flows module
- octavia.controller.worker.v1.flows.l7rule_flows module
- octavia.controller.worker.v1.flows.listener_flows module
- octavia.controller.worker.v1.flows.load_balancer_flows module
LoadBalancerFlows
LoadBalancerFlows.get_cascade_delete_load_balancer_flow()
LoadBalancerFlows.get_create_load_balancer_flow()
LoadBalancerFlows.get_delete_load_balancer_flow()
LoadBalancerFlows.get_failover_LB_flow()
LoadBalancerFlows.get_post_lb_amp_association_flow()
LoadBalancerFlows.get_update_load_balancer_flow()
- octavia.controller.worker.v1.flows.member_flows module
- octavia.controller.worker.v1.flows.pool_flows module
- Module contents
- octavia.controller.worker.v1.tasks package
- Submodules
- octavia.controller.worker.v1.tasks.amphora_driver_tasks module
AmpListenersUpdate
AmphoraCertUpload
AmphoraComputeConnectivityWait
AmphoraConfigUpdate
AmphoraFinalize
AmphoraGetDiagnostics
AmphoraGetInfo
AmphoraIndexListenerUpdate
AmphoraIndexListenersReload
AmphoraIndexUpdateVRRPInterface
AmphoraIndexVRRPStart
AmphoraIndexVRRPUpdate
AmphoraPostNetworkPlug
AmphoraPostVIPPlug
AmphoraUpdateVRRPInterface
AmphoraVRRPStart
AmphoraVRRPUpdate
AmphoraePostNetworkPlug
AmphoraePostVIPPlug
BaseAmphoraTask
ListenerDelete
ListenersStart
ListenersUpdate
- octavia.controller.worker.v1.tasks.cert_task module
- octavia.controller.worker.v1.tasks.compute_tasks module
- octavia.controller.worker.v1.tasks.database_tasks module
AssociateFailoverAmphoraWithLBID
BaseDatabaseTask
CountPoolChildrenForQuota
CreateAmphoraInDB
CreateVRRPGroupForLB
DecrementHealthMonitorQuota
DecrementL7policyQuota
DecrementL7ruleQuota
DecrementListenerQuota
DecrementLoadBalancerQuota
DecrementMemberQuota
DecrementPoolQuota
DeleteHealthMonitorInDB
DeleteHealthMonitorInDBByPool
DeleteL7PolicyInDB
DeleteL7RuleInDB
DeleteListenerInDB
DeleteMemberInDB
DeletePoolInDB
DisableAmphoraHealthMonitoring
DisableLBAmphoraeHealthMonitoring
GetAmphoraDetails
GetAmphoraeFromLoadbalancer
GetListenersFromLoadbalancer
GetLoadBalancer
GetVipFromLoadbalancer
MarkAmphoraAllocatedInDB
MarkAmphoraBackupInDB
MarkAmphoraBootingInDB
MarkAmphoraDeletedInDB
MarkAmphoraHealthBusy
MarkAmphoraMasterInDB
MarkAmphoraPendingDeleteInDB
MarkAmphoraPendingUpdateInDB
MarkAmphoraReadyInDB
MarkAmphoraStandAloneInDB
MarkHealthMonitorActiveInDB
MarkHealthMonitorPendingCreateInDB
MarkHealthMonitorPendingDeleteInDB
MarkHealthMonitorPendingUpdateInDB
MarkL7PolicyActiveInDB
MarkL7PolicyPendingCreateInDB
MarkL7PolicyPendingDeleteInDB
MarkL7PolicyPendingUpdateInDB
MarkL7RuleActiveInDB
MarkL7RulePendingCreateInDB
MarkL7RulePendingDeleteInDB
MarkL7RulePendingUpdateInDB
MarkLBActiveInDB
MarkLBAmphoraeDeletedInDB
MarkLBAmphoraeHealthBusy
MarkLBAndListenersActiveInDB
MarkLBDeletedInDB
MarkLBPendingDeleteInDB
MarkListenerDeletedInDB
MarkListenerPendingDeleteInDB
MarkMemberActiveInDB
MarkMemberPendingCreateInDB
MarkMemberPendingDeleteInDB
MarkMemberPendingUpdateInDB
MarkPoolActiveInDB
MarkPoolPendingCreateInDB
MarkPoolPendingDeleteInDB
MarkPoolPendingUpdateInDB
ReloadAmphora
ReloadLoadBalancer
UpdateAmpFailoverDetails
UpdateAmphoraCertBusyToFalse
UpdateAmphoraComputeId
UpdateAmphoraDBCertExpiration
UpdateAmphoraInfo
UpdateAmphoraVIPData
UpdateAmphoraeVIPData
UpdateHealthMonInDB
UpdateL7PolicyInDB
UpdateL7RuleInDB
UpdateLBServerGroupInDB
UpdateListenerInDB
UpdateLoadbalancerInDB
UpdateMemberInDB
UpdatePoolInDB
UpdatePoolMembersOperatingStatusInDB
UpdateVIPAfterAllocation
- octavia.controller.worker.v1.tasks.lifecycle_tasks module
AmphoraIDToErrorOnRevertTask
AmphoraToErrorOnRevertTask
BaseLifecycleTask
HealthMonitorToErrorOnRevertTask
L7PolicyToErrorOnRevertTask
L7RuleToErrorOnRevertTask
ListenerToErrorOnRevertTask
ListenersToErrorOnRevertTask
LoadBalancerIDToErrorOnRevertTask
LoadBalancerToErrorOnRevertTask
MemberToErrorOnRevertTask
MembersToErrorOnRevertTask
PoolToErrorOnRevertTask
- octavia.controller.worker.v1.tasks.model_tasks module
- octavia.controller.worker.v1.tasks.network_tasks module
AdminDownPort
AllocateVIP
AllocateVIPforFailover
ApplyQos
ApplyQosAmphora
BaseNetworkTask
CalculateAmphoraDelta
CalculateDelta
CreateVIPBasePort
DeallocateVIP
DeletePort
FailoverPreparationForAmphora
GetAmphoraNetworkConfigs
GetAmphoraNetworkConfigsByID
GetAmphoraeNetworkConfigs
GetMemberPorts
GetPlumbedNetworks
GetSubnetFromVIP
GetVIPSecurityGroupID
HandleNetworkDelta
HandleNetworkDeltas
PlugNetworks
PlugPorts
PlugVIP
PlugVIPAmpphora
RetrievePortIDsOnAmphoraExceptLBNetwork
UnPlugNetworks
UnplugVIP
UpdateVIP
UpdateVIPForDelete
UpdateVIPSecurityGroup
- octavia.controller.worker.v1.tasks.retry_tasks module
- Module contents
Submodules¶
octavia.controller.worker.v1.controller_worker module¶
- class ControllerWorker[source]¶
Bases:
BaseTaskFlowEngine
- 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_id)[source]¶
Creates a health monitor.
- Parameters:
pool_id – ID of the pool to create a health monitor on
- Returns:
None
- Raises:
NoResultFound – Unable to find the object
- create_l7policy(l7policy_id)[source]¶
Creates an L7 Policy.
- Parameters:
l7policy_id – ID of the l7policy to create
- Returns:
None
- Raises:
NoResultFound – Unable to find the object
- create_l7rule(l7rule_id)[source]¶
Creates an L7 Rule.
- Parameters:
l7rule_id – ID of the l7rule to create
- Returns:
None
- Raises:
NoResultFound – Unable to find the object
- create_listener(listener_id)[source]¶
Creates a listener.
- Parameters:
listener_id – ID of the listener to create
- Returns:
None
- Raises:
NoResultFound – Unable to find the object
- create_load_balancer(load_balancer_id, 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:
load_balancer_id – ID of the load balancer to create
- Returns:
None
- Raises:
NoResultFound – Unable to find the object
- create_member(member_id)[source]¶
Creates a pool member.
- Parameters:
member_id – ID of the member to create
- Returns:
None
- Raises:
NoSuitablePool – Unable to find the node pool
- create_pool(pool_id)[source]¶
Creates a node pool.
- Parameters:
pool_id – ID of the pool 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_id)[source]¶
Deletes a health monitor.
- Parameters:
pool_id – ID of the pool to delete its health monitor
- Returns:
None
- Raises:
HMNotFound – The referenced health monitor was not found
- delete_l7policy(l7policy_id)[source]¶
Deletes an L7 policy.
- Parameters:
l7policy_id – ID of the l7policy to delete
- Returns:
None
- Raises:
L7PolicyNotFound – The referenced l7policy was not found
- delete_l7rule(l7rule_id)[source]¶
Deletes an L7 rule.
- Parameters:
l7rule_id – ID of the l7rule to delete
- Returns:
None
- Raises:
L7RuleNotFound – The referenced l7rule was not found
- delete_listener(listener_id)[source]¶
Deletes a listener.
- Parameters:
listener_id – ID of the listener to delete
- Returns:
None
- Raises:
ListenerNotFound – The referenced listener was not found
- delete_load_balancer(load_balancer_id, cascade=False)[source]¶
Deletes a load balancer by de-allocating Amphorae.
- Parameters:
load_balancer_id – ID of the load balancer to delete
- Returns:
None
- Raises:
LBNotFound – The referenced load balancer was not found
- delete_member(member_id)[source]¶
Deletes a pool member.
- Parameters:
member_id – ID of the member to delete
- Returns:
None
- Raises:
MemberNotFound – The referenced member was not found
- delete_pool(pool_id)[source]¶
Deletes a node pool.
- Parameters:
pool_id – ID of the pool 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.
- 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(health_monitor_id, health_monitor_updates)[source]¶
Updates a health monitor.
- Parameters:
pool_id – ID of the pool to have it’s health monitor updated
health_monitor_updates – Dict containing updated health monitor
- Returns:
None
- Raises:
HMNotFound – The referenced health monitor was not found
- update_l7policy(l7policy_id, l7policy_updates)[source]¶
Updates an L7 policy.
- Parameters:
l7policy_id – ID of the l7policy to update
l7policy_updates – Dict containing updated l7policy attributes
- Returns:
None
- Raises:
L7PolicyNotFound – The referenced l7policy was not found
- update_l7rule(l7rule_id, l7rule_updates)[source]¶
Updates an L7 rule.
- Parameters:
l7rule_id – ID 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_id, listener_updates)[source]¶
Updates a listener.
- Parameters:
listener_id – ID of the listener to update
listener_updates – Dict containing updated listener attributes
- Returns:
None
- Raises:
ListenerNotFound – The referenced listener was not found
- update_load_balancer(load_balancer_id, load_balancer_updates)[source]¶
Updates a load balancer.
- Parameters:
load_balancer_id – ID 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