The ceilometer.tests.unit.test_coordination Module

class ceilometer.tests.unit.test_coordination.MockAsyncError(error)

Bases: tooz.coordination.CoordAsyncResult

static done()

get(timeout=0)

class ceilometer.tests.unit.test_coordination.MockAsyncResult(result)

Bases: tooz.coordination.CoordAsyncResult

static done()

get(timeout=0)

class ceilometer.tests.unit.test_coordination.MockLoggingHandler(*args, **kwargs)

Bases: logging.Handler

Mock logging handler to check for expected logs.

emit(record)

reset()

class ceilometer.tests.unit.test_coordination.MockToozCoordExceptionOnJoinRaiser(member_id, shared_storage, retry_count=None)

Bases: ceilometer.tests.unit.test_coordination.MockToozCoordinator

join_group(group_id, capabilities='')

class ceilometer.tests.unit.test_coordination.MockToozCoordExceptionRaiser(member_id, shared_storage)

Bases: ceilometer.tests.unit.test_coordination.MockToozCoordinator

get_members(group_id)

heartbeat()

join_group(group_id, capabilities='')

start()

class ceilometer.tests.unit.test_coordination.MockToozCoordinator(member_id, shared_storage)

Bases: object

create_group(group_id)

get_members(group_id)

heartbeat()

join_group(group_id, capabilities='')

leave_group(group_id)

start()

stop()

class ceilometer.tests.unit.test_coordination.TestPartitioning(*args, **kwds)

Bases: ceilometer.tests.base.BaseTestCase

setUp()

test_coordination_backend_connection_fail_on_join()

test_coordination_backend_offline()

test_group_id_none()

test_multiple_groups()

test_partitioning()

test_partitioning_with_unicode()

test_reconnect()

test_single_group()

test_stop()