The ceilometer.tests.unit.publisher.test_messaging_publisher Module¶

Tests for ceilometer/publisher/messaging.py

class ceilometer.tests.unit.publisher.test_messaging_publisher.BasePublisherTestCase(*args, **kwds)[source]¶

Bases: ceilometer.tests.base.BaseTestCase

i = 4¶

setUp()[source]¶

Hook method for setting up the test fixture before exercising it.

test_event_data = [<Event: d3ec22af-39e1-4cb1-81d5-6cd87ace015d, event_0, 2020-05-29 08:30:33.696706, >, <Event: e53ef66f-3a36-43b9-bb71-baaba73242c9, event_1, 2020-05-29 08:30:33.696789, >, <Event: 8e3d58de-7dbd-44d8-9d00-040c73502f34, event_2, 2020-05-29 08:30:33.696846, >, <Event: 13f351f8-c92c-4b0b-ad49-d6559f4c52e0, event_3, 2020-05-29 08:30:33.696900, >, <Event: 910dcc0f-6f03-4f55-9684-21bab1f3d5d7, event_4, 2020-05-29 08:30:33.696951, >]¶

test_sample_data = [<name: test, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.696974>, <name: test, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697083>, <name: test2, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697125>, <name: test2, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697163>, <name: test3, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697199>]¶

class ceilometer.tests.unit.publisher.test_messaging_publisher.NotifierOnlyPublisherTest(*args, **kwds)[source]¶

Bases: ceilometer.tests.unit.publisher.test_messaging_publisher.BasePublisherTestCase

test_publish_other_host(**keywargs)[source]¶

test_publish_other_host_vhost_and_query(**keywargs)[source]¶

test_publish_topic_override(**keywargs)[source]¶

test_publish_with_none_rabbit_driver(**keywargs)[source]¶

class ceilometer.tests.unit.publisher.test_messaging_publisher.TestPublisher(*args, **kwds)[source]¶

Bases: testscenarios.testcase.WithScenarios, ceilometer.tests.unit.publisher.test_messaging_publisher.BasePublisherTestCase

scenarios = [('notifier', {'publisher_cls': <class 'ceilometer.publisher.messaging.SampleNotifierPublisher'>, 'test_data': [<name: test, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.696974>, <name: test, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697083>, <name: test2, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697125>, <name: test2, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697163>, <name: test3, volume: 1, resource_id: test_run_tasks, timestamp: 2020-05-29T08:30:33.697199>], 'protocol': 'notifier', 'pub_func': 'publish_samples', 'attr': 'source'}), ('event_notifier', {'publisher_cls': <class 'ceilometer.publisher.messaging.EventNotifierPublisher'>, 'test_data': [<Event: d3ec22af-39e1-4cb1-81d5-6cd87ace015d, event_0, 2020-05-29 08:30:33.696706, >, <Event: e53ef66f-3a36-43b9-bb71-baaba73242c9, event_1, 2020-05-29 08:30:33.696789, >, <Event: 8e3d58de-7dbd-44d8-9d00-040c73502f34, event_2, 2020-05-29 08:30:33.696846, >, <Event: 13f351f8-c92c-4b0b-ad49-d6559f4c52e0, event_3, 2020-05-29 08:30:33.696900, >, <Event: 910dcc0f-6f03-4f55-9684-21bab1f3d5d7, event_4, 2020-05-29 08:30:33.696951, >], 'protocol': 'notifier', 'pub_func': 'publish_events', 'attr': 'event_type'})]¶

setUp()[source]¶

Hook method for setting up the test fixture before exercising it.

class ceilometer.tests.unit.publisher.test_messaging_publisher.TestPublisherPolicy(*args, **kwds)[source]¶

Bases: ceilometer.tests.unit.publisher.test_messaging_publisher.TestPublisher

test_published_with_no_policy(**keywargs)[source]¶

test_published_with_policy_block(**keywargs)[source]¶

test_published_with_policy_incorrect(**keywargs)[source]¶

class ceilometer.tests.unit.publisher.test_messaging_publisher.TestPublisherPolicyReactions(*args, **kwds)[source]¶

Bases: ceilometer.tests.unit.publisher.test_messaging_publisher.TestPublisher

test_published_with_policy_default_sized_queue_and_rpc_down(**keywargs)[source]¶

test_published_with_policy_drop_and_rpc_down(**keywargs)[source]¶

test_published_with_policy_queue_and_rpc_down(**keywargs)[source]¶

test_published_with_policy_queue_and_rpc_down_up(**keywargs)[source]¶

test_published_with_policy_sized_queue_and_rpc_down(**keywargs)[source]¶