nameko.testing.utils¶

Common testing utilities.

Attributes¶

`MockCallArgs`
`ANY_PARTIAL`

Classes¶

`AnyInstanceOf`
`DummyProvider`	入口点封装类
`ResourcePipeline`	Creates and destroys resources in background threads.

Functions¶

`get_extension`(container, extension_cls, **match_attrs)	Inspect `container.extensions` and return the first item that is
`get_container`(runner, service_cls)	Inspect `runner.containers` and return the first item that is
`wait_for_call`(timeout, mock_method)	Return a context manager that waits `timeout` seconds for
`wait_for_worker_idle`(container[, timeout])	Blocks until `container` has no running workers.
`assert_stops_raising`(fn[, exception_type, timeout, ...])	Assert that `fn` returns successfully within `timeout`
`unpack_mock_call`(call)
`get_rabbit_connections`(vhost, rabbit_manager)
`reset_rabbit_connections`(vhost, rabbit_manager)
`find_free_port`([host])

Module Contents¶

nameko.testing.utils.get_extension(container, extension_cls, **match_attrs)[源代码]¶

Inspect container.extensions and return the first item that is an instance of extension_cls.

Optionally also require that the instance has an attribute with a particular value as given in the match_attrs kwargs.

nameko.testing.utils.get_container(runner, service_cls)[源代码]¶: Inspect runner.containers and return the first item that is hosting an instance of service_cls.

nameko.testing.utils.wait_for_call(timeout, mock_method)[源代码]¶

Return a context manager that waits timeout seconds for mock_method to be called, yielding the mock if so.

Raises an eventlet.Timeout if the method was not called within timeout seconds.

nameko.testing.utils.wait_for_worker_idle(container, timeout=10)[源代码]¶

Blocks until container has no running workers.

Raises an eventlet.Timeout if the method was not called within timeout seconds.

nameko.testing.utils.assert_stops_raising(fn, exception_type=Exception, timeout=10, interval=0.1)[源代码]¶

Assert that fn returns successfully within timeout seconds, trying every interval seconds.

If exception_type is provided, fail unless the exception thrown is an instance of exception_type. If not specified, any :class:`Exception instance is allowed.