octavia.controller.worker.v2.flows package

Submodules

octavia.controller.worker.v2.flows.amphora_flows module

class AmphoraFlows[source]

Bases: object

cert_rotate_amphora_flow()[source]

Implement rotation for amphora’s cert.

  1. Create a new certificate

  2. Upload the cert to amphora

  3. update the newly created certificate info to amphora

  4. 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]
update_amphora_config_flow()[source]

Creates a flow to update the amphora agent configuration.

Returns

The flow for updating an amphora

octavia.controller.worker.v2.flows.flow_utils module

cert_rotate_amphora_flow()[source]
get_batch_update_members_flow(old_members, new_members, updated_members)[source]
get_cascade_delete_load_balancer_flow(lb)[source]
get_create_all_listeners_flow()[source]
get_create_amphora_flow()[source]
get_create_health_monitor_flow()[source]
get_create_l7policy_flow()[source]
get_create_l7rule_flow()[source]
get_create_listener_flow()[source]
get_create_load_balancer_flow(topology, listeners=None)[source]
get_create_member_flow()[source]
get_create_pool_flow()[source]
get_delete_amphora_flow()[source]
get_delete_health_monitor_flow()[source]
get_delete_l7policy_flow()[source]
get_delete_l7rule_flow()[source]
get_delete_listener_flow()[source]
get_delete_listeners_store(lb)[source]
get_delete_load_balancer_flow(lb)[source]
get_delete_member_flow()[source]
get_delete_pool_flow()[source]
get_delete_pools_store(lb)[source]
get_failover_flow(role='STANDALONE', load_balancer=None)[source]
get_update_health_monitor_flow()[source]
get_update_l7policy_flow()[source]
get_update_l7rule_flow()[source]
get_update_listener_flow()[source]
get_update_load_balancer_flow()[source]
get_update_member_flow()[source]
get_update_pool_flow()[source]
update_amphora_config_flow()[source]

octavia.controller.worker.v2.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.v2.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.v2.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.v2.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.v2.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_listeners_store(lb)[source]
get_delete_load_balancer_flow(lb)[source]

Creates a flow to delete a load balancer.

Returns

The flow for deleting a load balancer

get_delete_pools_store(lb)[source]
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.v2.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.v2.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(pool_id)[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