Tests for ceilometer/publisher/kafka_broker.py
-
class ceilometer.tests.unit.publisher.test_kafka_broker_publisher.TestKafkaPublisher(*args, **kwds)[source]
Bases: ceilometer.tests.base.BaseTestCase
-
setUp()[source]
-
test_publish(*args, **keywargs)[source]
-
test_publish_event_with_default_policy(*args, **keywargs)[source]
-
test_publish_to_down_host_with_default_queue_size(*args, **keywargs)[source]
-
test_publish_to_host_from_down_to_up_with_queue(*args, **keywargs)[source]
-
test_publish_to_host_with_default_policy(*args, **keywargs)[source]
-
test_publish_to_host_with_drop_policy(*args, **keywargs)[source]
-
test_publish_to_host_with_queue_policy(*args, **keywargs)[source]
-
test_publish_to_host_without_policy(*args, **keywargs)[source]
-
test_publish_without_options(*args, **keywargs)[source]