app Package¶

test_app Module¶

class thriftworker.tests.app.test_app.TestApp(methodName='runTest')[source]¶

Bases: thriftworker.tests.utils.TestCase

test_current_app()[source]¶

test_custom_loop()[source]¶

test_custom_pool_size()[source]¶

test_custom_port_range()[source]¶

test_custom_proto_factory()[source]¶

test_default_app()[source]¶

test_negative_pool_size()[source]¶

test_wrong_port_range()[source]¶

test_hub Module¶

exception thriftworker.tests.app.test_hub.ExpectedError[source]¶

Bases: exceptions.Exception

class thriftworker.tests.app.test_hub.TestGreenlet(methodName='runTest')[source]¶

Bases: thriftworker.tests.utils.GreenTest

assertKilled(g)[source]¶

test_error_exit(*args, **kwargs)[source]¶

test_kill_just_started_block(*args, **kwargs)[source]¶

test_kill_just_started_noblock(*args, **kwargs)[source]¶

test_kill_not_started_block(*args, **kwargs)[source]¶

test_kill_not_started_noblock(*args, **kwargs)[source]¶

test_kill_running_block(*args, **kwargs)[source]¶

test_kill_running_noblock(*args, **kwargs)[source]¶

test_simple_exit(*args, **kwargs)[source]¶

class thriftworker.tests.app.test_hub.TestHub(methodName='runTest')[source]¶

Bases: thriftworker.tests.utils.CustomAppMixin, thriftworker.tests.utils.TestCase

context()[source]¶

setUp()[source]¶

test_start_stop()[source]¶

test_wakeup()[source]¶

test_listener Module¶

class thriftworker.tests.app.test_listener.ListenerMixin[source]¶

Bases: thriftworker.tests.utils.StartStopLoopMixin

Listener = None¶

setUp()[source]¶

class thriftworker.tests.app.test_listener.ListenersMixin[source]¶

Bases: thriftworker.tests.utils.StartStopLoopMixin

Listeners = None¶

setUp()[source]¶

class thriftworker.tests.app.test_listener.TestListener(methodName='runTest')[source]¶

Bases: thriftworker.tests.app.test_listener.ListenerMixin, thriftworker.tests.utils.TestCase

class Listener(name, address, backlog=None)¶

Bases: thriftworker.utils.mixin.LoopMixin

channel¶

Wrapper for socket. Needed to pass descriptor to child process.

host¶

Return host to which this socket is binded.

port¶

Return binded port number.

socket¶

A shortcut to create a TCP socket and bind it.

start¶

Bind listener to given port.

stop¶

TestListener.test_bind_error()[source]¶

TestListener.test_bind_from_pool()[source]¶

TestListener.test_start_stop()[source]¶

class thriftworker.tests.app.test_listener.TestListeners(methodName='runTest')[source]¶

Bases: thriftworker.tests.app.test_listener.ListenersMixin, thriftworker.tests.utils.TestCase

class Listeners¶

Bases: thriftworker.utils.mixin.LoopMixin

Maintain pool of listeners.

Listener¶

Shortcut to thriftworker.listener.Listener class.

channels¶

Return list of registered channels. Useful to pass them to child process.

enumerated¶

Return enumerated mapping of listeners.

register(name, host, port, backlog=None)¶

Register new listener with given parameters.

TestListeners.test_register()[source]¶

test_services Module¶

test_state Module¶

class thriftworker.tests.app.test_state.TestState(methodName='runTest')[source]¶

Bases: thriftworker.tests.utils.TestCase

test_change_app()[source]¶

test_current_app()[source]¶

test_no_app_created()[source]¶