Source code for octavia.controller.worker.v2.flows.flow_utils

#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.

from octavia.api.drivers import utils as provider_utils
from octavia.controller.worker.v2.flows import amphora_flows
from octavia.controller.worker.v2.flows import health_monitor_flows
from octavia.controller.worker.v2.flows import l7policy_flows
from octavia.controller.worker.v2.flows import l7rule_flows
from octavia.controller.worker.v2.flows import listener_flows
from octavia.controller.worker.v2.flows import load_balancer_flows
from octavia.controller.worker.v2.flows import member_flows
from octavia.controller.worker.v2.flows import pool_flows


LB_FLOWS = load_balancer_flows.LoadBalancerFlows()
AMP_FLOWS = amphora_flows.AmphoraFlows()
HM_FLOWS = health_monitor_flows.HealthMonitorFlows()
L7_POLICY_FLOWS = l7policy_flows.L7PolicyFlows()
L7_RULES_FLOWS = l7rule_flows.L7RuleFlows()
LISTENER_FLOWS = listener_flows.ListenerFlows()
M_FLOWS = member_flows.MemberFlows()
P_FLOWS = pool_flows.PoolFlows()




def get_create_load_balancer_flow(topology, listeners=None, flavor_dict=None):
    return LB_FLOWS.get_create_load_balancer_flow(
        topology, listeners=listeners, flavor_dict=flavor_dict)





def get_delete_load_balancer_flow(lb):
    return LB_FLOWS.get_delete_load_balancer_flow(lb)





def get_listeners_on_lb(db_lb):
    """Get a list of the listeners on a load balancer.

    :param db_lb: A load balancer database model object.
    :returns: A list of provider dict format listeners.
    """
    listener_dicts = []
    for listener in db_lb.listeners:
        prov_listener = provider_utils.db_listener_to_provider_listener(
            listener)
        listener_dicts.append(prov_listener.to_dict())
    return listener_dicts





def get_pools_on_lb(db_lb):
    """Get a list of the pools on a load balancer.

    :param db_lb: A load balancer database model object.
    :returns: A list of provider dict format pools.
    """
    pool_dicts = []
    for pool in db_lb.pools:
        prov_pool = provider_utils.db_pool_to_provider_pool(pool)
        pool_dicts.append(prov_pool.to_dict())
    return pool_dicts





def get_cascade_delete_load_balancer_flow(lb, listeners=(), pools=()):
    return LB_FLOWS.get_cascade_delete_load_balancer_flow(lb, listeners,
                                                          pools)





def get_update_load_balancer_flow():
    return LB_FLOWS.get_update_load_balancer_flow()





def get_create_amphora_flow():
    return AMP_FLOWS.get_create_amphora_flow()





def get_delete_amphora_flow(amphora, retry_attempts=None, retry_interval=None):
    return AMP_FLOWS.get_delete_amphora_flow(amphora, retry_attempts,
                                             retry_interval)





def get_failover_LB_flow(amps, lb):
    return LB_FLOWS.get_failover_LB_flow(amps, lb)





def get_failover_amphora_flow(amphora_dict, lb_amp_count, flavor_dict=None):
    return AMP_FLOWS.get_failover_amphora_flow(amphora_dict, lb_amp_count,
                                               flavor_dict=flavor_dict)





def cert_rotate_amphora_flow():
    return AMP_FLOWS.cert_rotate_amphora_flow()





def update_amphora_config_flow():
    return AMP_FLOWS.update_amphora_config_flow()





def get_create_health_monitor_flow():
    return HM_FLOWS.get_create_health_monitor_flow()





def get_delete_health_monitor_flow():
    return HM_FLOWS.get_delete_health_monitor_flow()





def get_update_health_monitor_flow():
    return HM_FLOWS.get_update_health_monitor_flow()





def get_create_l7policy_flow():
    return L7_POLICY_FLOWS.get_create_l7policy_flow()





def get_delete_l7policy_flow():
    return L7_POLICY_FLOWS.get_delete_l7policy_flow()





def get_update_l7policy_flow():
    return L7_POLICY_FLOWS.get_update_l7policy_flow()





def get_create_l7rule_flow():
    return L7_RULES_FLOWS.get_create_l7rule_flow()





def get_delete_l7rule_flow():
    return L7_RULES_FLOWS.get_delete_l7rule_flow()





def get_update_l7rule_flow():
    return L7_RULES_FLOWS.get_update_l7rule_flow()





def get_create_listener_flow(flavor_dict=None):
    return LISTENER_FLOWS.get_create_listener_flow(flavor_dict=flavor_dict)





def get_create_all_listeners_flow(flavor_dict=None):
    return LISTENER_FLOWS.get_create_all_listeners_flow(
        flavor_dict=flavor_dict)





def get_delete_listener_flow(flavor_dict=None):
    return LISTENER_FLOWS.get_delete_listener_flow(flavor_dict=flavor_dict)





def get_update_listener_flow(flavor_dict=None):
    return LISTENER_FLOWS.get_update_listener_flow(flavor_dict=flavor_dict)





def get_create_member_flow():
    return M_FLOWS.get_create_member_flow()





def get_delete_member_flow():
    return M_FLOWS.get_delete_member_flow()





def get_update_member_flow():
    return M_FLOWS.get_update_member_flow()





def get_batch_update_members_flow(old_members, new_members, updated_members):
    return M_FLOWS.get_batch_update_members_flow(old_members, new_members,
                                                 updated_members)





def get_create_pool_flow():
    return P_FLOWS.get_create_pool_flow()





def get_delete_pool_flow():
    return P_FLOWS.get_delete_pool_flow()





def get_update_pool_flow():
    return P_FLOWS.get_update_pool_flow()