diff options
| author | Andrew Smith <ansmith@redhat.com> | 2017-06-13 08:46:50 -0400 |
|---|---|---|
| committer | Andrew Smith <ansmith@redhat.com> | 2017-06-13 08:46:50 -0400 |
| commit | eccdea5ceb86d65d20e8beb305fa52b56f3acc24 (patch) | |
| tree | 5b048caef7bd2429124174628e4addbfba2e001c | |
| parent | 4784d70a0ec64161af22b55ac43e2b49756618c4 (diff) | |
| download | oslo-messaging-eccdea5ceb86d65d20e8beb305fa52b56f3acc24.tar.gz | |
Add kafka_driver directory
Make uniform with other drivers, kafka driver files, etc.
Change-Id: I6c6e201c304a6005ef191f96e5ac39ffaf4ab8f7
| -rw-r--r-- | oslo_messaging/_drivers/impl_kafka.py | 2 | ||||
| -rw-r--r-- | oslo_messaging/_drivers/kafka_driver/__init__.py | 0 | ||||
| -rw-r--r-- | oslo_messaging/_drivers/kafka_driver/kafka_options.py (renamed from oslo_messaging/_drivers/kafka_options.py) | 0 | ||||
| -rw-r--r-- | oslo_messaging/opts.py | 2 | ||||
| -rw-r--r-- | oslo_messaging/tests/functional/utils.py | 2 |
5 files changed, 3 insertions, 3 deletions
diff --git a/oslo_messaging/_drivers/impl_kafka.py b/oslo_messaging/_drivers/impl_kafka.py index 3412bdf..6b037a5 100644 --- a/oslo_messaging/_drivers/impl_kafka.py +++ b/oslo_messaging/_drivers/impl_kafka.py @@ -32,7 +32,7 @@ import tenacity from oslo_messaging._drivers import base from oslo_messaging._drivers import common as driver_common -from oslo_messaging._drivers import kafka_options +from oslo_messaging._drivers.kafka_driver import kafka_options from oslo_messaging._drivers import pool as driver_pool from oslo_messaging._i18n import _LE from oslo_messaging._i18n import _LW diff --git a/oslo_messaging/_drivers/kafka_driver/__init__.py b/oslo_messaging/_drivers/kafka_driver/__init__.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/oslo_messaging/_drivers/kafka_driver/__init__.py diff --git a/oslo_messaging/_drivers/kafka_options.py b/oslo_messaging/_drivers/kafka_driver/kafka_options.py index 0bdcde5..0bdcde5 100644 --- a/oslo_messaging/_drivers/kafka_options.py +++ b/oslo_messaging/_drivers/kafka_driver/kafka_options.py diff --git a/oslo_messaging/opts.py b/oslo_messaging/opts.py index 61bb692..b766bb3 100644 --- a/oslo_messaging/opts.py +++ b/oslo_messaging/opts.py @@ -26,7 +26,7 @@ from oslo_messaging._drivers import base as drivers_base from oslo_messaging._drivers import impl_pika from oslo_messaging._drivers import impl_rabbit from oslo_messaging._drivers.impl_zmq import zmq_options -from oslo_messaging._drivers import kafka_options +from oslo_messaging._drivers.kafka_driver import kafka_options from oslo_messaging._drivers.pika_driver import pika_connection_factory from oslo_messaging._drivers.zmq_driver.matchmaker import zmq_matchmaker_redis from oslo_messaging.notify import notifier diff --git a/oslo_messaging/tests/functional/utils.py b/oslo_messaging/tests/functional/utils.py index b83ec65..5cf3cb0 100644 --- a/oslo_messaging/tests/functional/utils.py +++ b/oslo_messaging/tests/functional/utils.py @@ -20,7 +20,7 @@ from oslo_config import cfg from six import moves import oslo_messaging -from oslo_messaging._drivers import kafka_options +from oslo_messaging._drivers.kafka_driver import kafka_options from oslo_messaging._drivers.zmq_driver import zmq_options from oslo_messaging.notify import notifier from oslo_messaging.tests import utils as test_utils |