octavia.controller.worker.flows package
updated: 2019-01-21 16:28
octavia.controller.worker.flows package
Submodules
octavia.controller.worker.flows.amphora_flows module
-
class
AmphoraFlows
[source]
Bases: object
-
cert_rotate_amphora_flow
()[source]
Implement rotation for amphora’s cert.
- Create a new certificate
- Upload the cert to amphora
- update the newly created certificate info to amphora
- update the cert_busy flag to be false after rotation
Returns: | The flow for updating an amphora |
-
get_amphora_for_lb_subflow
(prefix, role='STANDALONE')[source]
Tries to allocate a spare amphora to a loadbalancer if none
exists, create a new amphora.
-
get_create_amphora_flow
()[source]
Creates a flow to create an amphora.
Returns: | The flow for creating the amphora |
-
get_delete_amphora_flow
()[source]
Creates a flow to delete an amphora.
This should be configurable in the config file
:returns: The flow for deleting the amphora
:raises AmphoraNotFound: The referenced Amphora was not found
-
get_failover_flow
(role='STANDALONE', load_balancer=None)[source]
Creates a flow to failover a stale amphora
Returns: | The flow for amphora failover |
-
get_vrrp_subflow
(prefix)[source]
octavia.controller.worker.flows.health_monitor_flows module
-
class
HealthMonitorFlows
[source]
Bases: object
-
get_create_health_monitor_flow
()[source]
Create a flow to create a health monitor
Returns: | The flow for creating a health monitor |
-
get_delete_health_monitor_flow
()[source]
Create a flow to delete a health monitor
Returns: | The flow for deleting a health monitor |
-
get_update_health_monitor_flow
()[source]
Create a flow to update a health monitor
Returns: | The flow for updating a health monitor |
octavia.controller.worker.flows.l7policy_flows module
-
class
L7PolicyFlows
[source]
Bases: object
-
get_create_l7policy_flow
()[source]
Create a flow to create an L7 policy
Returns: | The flow for creating an L7 policy |
-
get_delete_l7policy_flow
()[source]
Create a flow to delete an L7 policy
Returns: | The flow for deleting an L7 policy |
-
get_update_l7policy_flow
()[source]
Create a flow to update an L7 policy
Returns: | The flow for updating an L7 policy |
octavia.controller.worker.flows.l7rule_flows module
-
class
L7RuleFlows
[source]
Bases: object
-
get_create_l7rule_flow
()[source]
Create a flow to create an L7 rule
Returns: | The flow for creating an L7 rule |
-
get_delete_l7rule_flow
()[source]
Create a flow to delete an L7 rule
Returns: | The flow for deleting an L7 rule |
-
get_update_l7rule_flow
()[source]
Create a flow to update an L7 rule
Returns: | The flow for updating an L7 rule |
octavia.controller.worker.flows.listener_flows module
-
class
ListenerFlows
[source]
Bases: object
-
get_create_all_listeners_flow
()[source]
Create a flow to create all listeners
Returns: | The flow for creating all listeners |
-
get_create_listener_flow
()[source]
Create a flow to create a listener
Returns: | The flow for creating a listener |
-
get_delete_listener_flow
()[source]
Create a flow to delete a listener
Returns: | The flow for deleting a listener |
-
get_delete_listener_internal_flow
(listener_name)[source]
Create a flow to delete a listener and l7policies internally
(will skip deletion on the amp and marking LB active)
Returns: | The flow for deleting a listener |
-
get_update_listener_flow
()[source]
Create a flow to update a listener
Returns: | The flow for updating a listener |
octavia.controller.worker.flows.load_balancer_flows module
-
class
LoadBalancerFlows
[source]
Bases: object
-
get_cascade_delete_load_balancer_flow
(lb)[source]
Creates a flow to delete a load balancer.
Returns: | The flow for deleting a load balancer |
-
get_create_load_balancer_flow
(topology, listeners=None)[source]
Creates a conditional graph flow that allocates a loadbalancer to
two spare amphorae.
:raises InvalidTopology: Invalid topology specified
:return: The graph flow for creating a loadbalancer.
-
get_delete_load_balancer_flow
(lb)[source]
Creates a flow to delete a load balancer.
Returns: | The flow for deleting a load balancer |
-
get_new_LB_networking_subflow
()[source]
Create a sub-flow to setup networking.
Returns: | The flow to setup networking for a new amphora |
-
get_post_lb_amp_association_flow
(prefix, topology, mark_active=True)[source]
Reload the loadbalancer and create networking subflows for
created/allocated amphorae.
:return: Post amphorae association subflow
-
get_update_load_balancer_flow
()[source]
Creates a flow to update a load balancer.
Returns: | The flow for update a load balancer |
octavia.controller.worker.flows.member_flows module
-
class
MemberFlows
[source]
Bases: object
-
get_batch_update_members_flow
(old_members, new_members, updated_members)[source]
Create a flow to batch update members
Returns: | The flow for batch updating members |
-
get_create_member_flow
()[source]
Create a flow to create a member
Returns: | The flow for creating a member |
-
get_delete_member_flow
()[source]
Create a flow to delete a member
Returns: | The flow for deleting a member |
-
get_update_member_flow
()[source]
Create a flow to update a member
Returns: | The flow for updating a member |
octavia.controller.worker.flows.pool_flows module
-
class
PoolFlows
[source]
Bases: object
-
get_create_pool_flow
()[source]
Create a flow to create a pool
Returns: | The flow for creating a pool |
-
get_delete_pool_flow
()[source]
Create a flow to delete a pool
Returns: | The flow for deleting a pool |
-
get_delete_pool_flow_internal
(name)[source]
Create a flow to delete a pool, etc.
Returns: | The flow for deleting a pool |
-
get_update_pool_flow
()[source]
Create a flow to update a pool
Returns: | The flow for updating a pool |
Module contents
updated: 2019-01-21 16:28