# octavia.controller.worker.v1.flows package

## Submodules

## octavia.controller.worker.v1.flows.amphora_flows module

class `AmphoraFlows`

  Bases: `object`

  `cert_rotate_amphora_flow`()

    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')

    Tries to allocate a spare amphora to a loadbalancer if none

    exists, create a new amphora.

  `get_create_amphora_flow`()

    Creates a flow to create an amphora.

    Returns: | The flow for creating the amphora

  `get_delete_amphora_flow`()

    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)

    Creates a flow to failover a stale amphora

    Returns: | The flow for amphora failover

  `get_vrrp_subflow`(prefix)
  `update_amphora_config_flow`()

    Creates a flow to update the amphora agent configuration.

    Returns: | The flow for updating an amphora

## octavia.controller.worker.v1.flows.health_monitor_flows module

class `HealthMonitorFlows`

  Bases: `object`

  `get_create_health_monitor_flow`()

    Create a flow to create a health monitor

    Returns: | The flow for creating a health monitor

  `get_delete_health_monitor_flow`()

    Create a flow to delete a health monitor

    Returns: | The flow for deleting a health monitor

  `get_update_health_monitor_flow`()

    Create a flow to update a health monitor

    Returns: | The flow for updating a health monitor

## octavia.controller.worker.v1.flows.l7policy_flows module

class `L7PolicyFlows`

  Bases: `object`

  `get_create_l7policy_flow`()

    Create a flow to create an L7 policy

    Returns: | The flow for creating an L7 policy

  `get_delete_l7policy_flow`()

    Create a flow to delete an L7 policy

    Returns: | The flow for deleting an L7 policy

  `get_update_l7policy_flow`()

    Create a flow to update an L7 policy

    Returns: | The flow for updating an L7 policy

## octavia.controller.worker.v1.flows.l7rule_flows module

class `L7RuleFlows`

  Bases: `object`

  `get_create_l7rule_flow`()

    Create a flow to create an L7 rule

    Returns: | The flow for creating an L7 rule

  `get_delete_l7rule_flow`()

    Create a flow to delete an L7 rule

    Returns: | The flow for deleting an L7 rule

  `get_update_l7rule_flow`()

    Create a flow to update an L7 rule

    Returns: | The flow for updating an L7 rule

## octavia.controller.worker.v1.flows.listener_flows module

class `ListenerFlows`

  Bases: `object`

  `get_create_all_listeners_flow`()

    Create a flow to create all listeners

    Returns: | The flow for creating all listeners

  `get_create_listener_flow`()

    Create a flow to create a listener

    Returns: | The flow for creating a listener

  `get_delete_listener_flow`()

    Create a flow to delete a listener

    Returns: | The flow for deleting a listener

  `get_delete_listener_internal_flow`(listener_name)

    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`()

    Create a flow to update a listener

    Returns: | The flow for updating a listener

## octavia.controller.worker.v1.flows.load_balancer_flows module

class `LoadBalancerFlows`

  Bases: `object`

  `get_cascade_delete_load_balancer_flow`(lb)

    Creates a flow to delete a load balancer.

    Returns: | The flow for deleting a load balancer

  `get_create_load_balancer_flow`(topology, listeners=None)

    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)

    Creates a flow to delete a load balancer.

    Returns: | The flow for deleting a load balancer

  `get_new_LB_networking_subflow`()

    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)

    Reload the loadbalancer and create networking subflows for

    created/allocated amphorae. :return: Post amphorae association subflow

  `get_update_load_balancer_flow`()

    Creates a flow to update a load balancer.

    Returns: | The flow for update a load balancer

## octavia.controller.worker.v1.flows.member_flows module

class `MemberFlows`

  Bases: `object`

  `get_batch_update_members_flow`(old_members, new_members, updated_members)

    Create a flow to batch update members

    Returns: | The flow for batch updating members

  `get_create_member_flow`()

    Create a flow to create a member

    Returns: | The flow for creating a member

  `get_delete_member_flow`()

    Create a flow to delete a member

    Returns: | The flow for deleting a member

  `get_update_member_flow`()

    Create a flow to update a member

    Returns: | The flow for updating a member

## octavia.controller.worker.v1.flows.pool_flows module

class `PoolFlows`

  Bases: `object`

  `get_create_pool_flow`()

    Create a flow to create a pool

    Returns: | The flow for creating a pool

  `get_delete_pool_flow`()

    Create a flow to delete a pool

    Returns: | The flow for deleting a pool

  `get_delete_pool_flow_internal`(name)

    Create a flow to delete a pool, etc.

    Returns: | The flow for deleting a pool

  `get_update_pool_flow`()

    Create a flow to update a pool

    Returns: | The flow for updating a pool

## Module contents

this page last updated: 2020-04-10 18:17:54

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.

found an error? report a bug questions?