octavia.controller.worker.flows package

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.

  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', status='READY')[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_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

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.