from quantum.common import exceptions as qexception
from quantum import manager
from quantum.plugins.common import constants
-from quantum.plugins.services.service_base import ServicePluginBase
+from quantum.services.service_base import ServicePluginBase
# Loadbalancer Exceptions
from quantum.agent.linux import interface
from quantum.openstack.common.rpc import service as rpc_service
from quantum.openstack.common import service
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import (
+from quantum.services.loadbalancer.drivers.haproxy import (
agent_manager as manager,
plugin_driver
)
from quantum.openstack.common import importutils
from quantum.openstack.common import log as logging
from quantum.openstack.common import periodic_task
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import (
+from quantum.services.loadbalancer.drivers.haproxy import (
agent_api,
plugin_driver
)
from quantum.agent.linux import utils
from quantum.plugins.common import constants as qconstants
-from quantum.plugins.services.agent_loadbalancer import constants
+from quantum.services.loadbalancer import constants
PROTOCOL_MAP = {
from quantum.agent.linux import utils
from quantum.common import exceptions
from quantum.openstack.common import log as logging
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import (
- cfg as hacfg
-)
+from quantum.services.loadbalancer.drivers.haproxy import cfg as hacfg
LOG = logging.getLogger(__name__)
NS_PREFIX = 'qlbaas-'
from quantum.openstack.common import rpc
from quantum.openstack.common.rpc import proxy
from quantum.plugins.common import constants
-from quantum.plugins.services.agent_loadbalancer.drivers import (
- abstract_driver
-)
+from quantum.services.loadbalancer.drivers import abstract_driver
LOG = logging.getLogger(__name__)
from quantum.openstack.common import log as logging
-from quantum.plugins.services.agent_loadbalancer.drivers import (
+from quantum.services.loadbalancer.drivers import (
abstract_driver
)
LOG = logging.getLogger(__name__)
-DEFAULT_DRIVER = ("quantum.plugins.services.agent_loadbalancer"
- ".drivers.haproxy"
+DEFAULT_DRIVER = ("quantum.services.loadbalancer.drivers.haproxy"
".plugin_driver.HaproxyOnHostPluginDriver")
lbaas_plugin_opts = [
import quantum.extensions
from quantum.extensions import loadbalancer
from quantum.plugins.common import constants
-from quantum.plugins.services.agent_loadbalancer import (
+from quantum.services.loadbalancer import (
plugin as loadbalancer_plugin
)
from quantum.tests.unit import test_db_plugin
DB_CORE_PLUGIN_KLASS = 'quantum.db.db_base_plugin_v2.QuantumDbPluginV2'
DB_LB_PLUGIN_KLASS = (
- "quantum.plugins.services.agent_loadbalancer."
+ "quantum.services.loadbalancer."
"plugin.LoadBalancerPlugin"
)
ROOTDIR = os.path.dirname(__file__) + '../../../..'
from quantum import manager
from quantum.openstack.common import uuidutils
from quantum.plugins.common import constants
-from quantum.plugins.services.service_base import ServicePluginBase
+from quantum.services.service_base import ServicePluginBase
DUMMY_PLUGIN_NAME = "dummy_plugin"
import mock
from oslo.config import cfg
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import agent
+from quantum.services.loadbalancer.drivers.haproxy import agent
from quantum.tests import base
import mock
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import (
+from quantum.services.loadbalancer.drivers.haproxy import (
agent_manager as manager
)
from quantum.tests import base
self.mock_importer = mock.patch.object(manager, 'importutils').start()
rpc_mock_cls = mock.patch(
- 'quantum.plugins.services.agent_loadbalancer.drivers'
+ 'quantum.services.loadbalancer.drivers'
'.haproxy.agent_api.LbaasAgentApi'
).start()
import mock
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import (
+from quantum.services.loadbalancer.drivers.haproxy import (
agent_api as api
)
from quantum.tests import base
from oslo.config import cfg as config
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import cfg
+from quantum.services.loadbalancer.drivers.haproxy import cfg
from quantum.tests import base
class TestHaproxyCfg(base.BaseTestCase):
def test_save_config(self):
with contextlib.nested(
- mock.patch('quantum.plugins.services.agent_loadbalancer.'
+ mock.patch('quantum.services.loadbalancer.'
'drivers.haproxy.cfg._build_global'),
- mock.patch('quantum.plugins.services.agent_loadbalancer.'
+ mock.patch('quantum.services.loadbalancer.'
'drivers.haproxy.cfg._build_defaults'),
- mock.patch('quantum.plugins.services.agent_loadbalancer.'
+ mock.patch('quantum.services.loadbalancer.'
'drivers.haproxy.cfg._build_frontend'),
- mock.patch('quantum.plugins.services.agent_loadbalancer.'
+ mock.patch('quantum.services.loadbalancer.'
'drivers.haproxy.cfg._build_backend'),
mock.patch('quantum.agent.linux.utils.replace_file')
) as (b_g, b_d, b_f, b_b, replace):
import mock
from quantum.common import exceptions
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import (
+from quantum.services.loadbalancer.drivers.haproxy import (
namespace_driver
)
from quantum.tests import base
from quantum import manager
from quantum.openstack.common import uuidutils
from quantum.plugins.common import constants
-from quantum.plugins.services.agent_loadbalancer.drivers.haproxy import (
+from quantum.services.loadbalancer.drivers.haproxy import (
plugin_driver
)
from quantum.tests import base