• Docs »
• Edit on GitHub

---

Index

A

Acceptor (thriftworker.app.ThriftWorker attribute) (thriftworker.transports.base.Acceptors attribute) acceptor (thriftworker.transports.base.BaseAcceptor attribute) acceptor_cls (thriftworker.app.ThriftWorker attribute) Acceptors (class in thriftworker.transports.base) acceptors (thriftworker.app.ThriftWorker attribute)

Acceptors (thriftworker.app.ThriftWorker attribute) active (thriftworker.transports.base.BaseAcceptor attribute) AllocationError app (thriftworker.services.Services attribute) (thriftworker.utils.mixin.LoopMixin attribute) assertKilled() (thriftworker.tests.app.test_hub.TestGreenlet method)

B

BaseAcceptor (class in thriftworker.transports.base) BaseAcceptor.Connections (class in thriftworker.transports.base) BaseWorker (class in thriftworker.workers.base)

BaseWorker.Request (class in thriftworker.workers.base) BindError body() (thriftworker.workers.threads.Pool.Worker method) (thriftworker.workers.threads.Worker method)

C

cached_property (in module thriftworker.utils.decorators) callback (thriftworker.transports.base.BaseAcceptor.Connections attribute) (thriftworker.transports.base.Connections attribute) (thriftworker.workers.sync.Promise attribute) (thriftworker.workers.threads.ThreadsWorker.Message attribute) cancel() (thriftworker.utils.finalize.Finalize method) cb() (thriftworker.workers.sync.Promise method) cb_read_done() (thriftworker.transports.framed.FramedAcceptor.Connection method) cb_write_done() (thriftworker.transports.framed.FramedAcceptor.Connection method) channel (thriftworker.listener.Listener attribute) (thriftworker.tests.app.test_listener.TestListener.Listener attribute) channels (thriftworker.listener.Listeners attribute) (thriftworker.tests.app.test_listener.TestListeners.Listeners attribute) close (thriftworker.transports.base.BaseAcceptor attribute) close() (thriftworker.transports.base.BaseAcceptor.Connections method) (thriftworker.transports.base.Connections method) (thriftworker.transports.framed.FramedAcceptor.Connection method) concurrency (thriftworker.workers.base.BaseWorker attribute) Connection (thriftworker.transports.base.BaseAcceptor attribute) connection (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute)

Connections (class in thriftworker.transports.base) connections_number (thriftworker.transports.base.Acceptors attribute) (thriftworker.transports.base.BaseAcceptor attribute) Container (class in thriftworker.utils.loop) context() (thriftworker.tests.app.test_hub.TestHub method) Counters (class in thriftworker.utils.stats.counters) create_callback() (thriftworker.workers.base.BaseWorker method) create_consumer() (thriftworker.workers.base.BaseWorker method) (thriftworker.workers.sync.SyncWorker method) (thriftworker.workers.threads.ThreadsWorker method) create_processor() (thriftworker.services.Services method) create_producer() (thriftworker.workers.base.BaseWorker method) create_task() (thriftworker.workers.base.BaseWorker method) CustomAppMixin (class in thriftworker.tests.utils) cwd_in_path() (in module thriftworker.utils.imports)

D

default() (thriftworker.app.ThriftWorker class method) DELEGATION_TIMEOUT (in module thriftworker.utils.loop) dispatch() (thriftworker.utils.loop.Container method) (thriftworker.workers.base.BaseWorker.Request method) (thriftworker.workers.base.Request method)

dispatch_time (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) dispatching_timers (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute)

E

empty (thriftworker.transports.base.Acceptors attribute) (thriftworker.transports.base.BaseAcceptor attribute) end_time (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) enumerated (thriftworker.listener.Listeners attribute) (thriftworker.tests.app.test_listener.TestListeners.Listeners attribute) exception (thriftworker.utils.loop.Container attribute) (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) (thriftworker.workers.sync.Promise attribute)

execute() (thriftworker.workers.base.BaseWorker.Request method) (thriftworker.workers.base.Request method) execution_time (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) ExpectedError

F

Finalize (class in thriftworker.utils.finalize) FramedAcceptor (class in thriftworker.transports.framed) FramedAcceptor.Connection (class in thriftworker.transports.framed)

from_greenlet() (thriftworker.utils.loop.Container method) func (thriftworker.utils.loop.Container attribute) (thriftworker.workers.sync.Promise attribute)

G

get_addresses_from_pool() (in module thriftworker.utils.other) get_current_app() (in module thriftworker.state) get_port_from_range() (in module thriftworker.utils.other)

get_real_module() (in module thriftworker.utils.imports) GreenMeta (class in thriftworker.tests.utils) GreenTest (class in thriftworker.tests.utils)

H

host (thriftworker.listener.Listener attribute) (thriftworker.tests.app.test_listener.TestListener.Listener attribute) Hub (thriftworker.app.ThriftWorker attribute)

hub (thriftworker.app.ThriftWorker attribute)

I

ignore_eagain() (in module thriftworker.transports.base) import_from_cwd() (in module thriftworker.utils.imports) in_loop (in module thriftworker.utils.loop) instance() (thriftworker.app.ThriftWorker static method)

instantiate() (in module thriftworker.utils.imports) is_closed() (thriftworker.transports.framed.FramedAcceptor.Connection method) is_ready() (thriftworker.transports.framed.FramedAcceptor.Connection method)

L

Listener (class in thriftworker.listener) (thriftworker.app.ThriftWorker attribute) (thriftworker.listener.Listeners attribute) (thriftworker.tests.app.test_listener.ListenerMixin attribute) (thriftworker.tests.app.test_listener.TestListeners.Listeners attribute) ListenerMixin (class in thriftworker.tests.app.test_listener) Listeners (class in thriftworker.listener) listeners (thriftworker.app.ThriftWorker attribute)

Listeners (thriftworker.app.ThriftWorker attribute) (thriftworker.tests.app.test_listener.ListenersMixin attribute) ListenersMixin (class in thriftworker.tests.app.test_listener) loop (thriftworker.app.ThriftWorker attribute) (thriftworker.utils.mixin.LoopMixin attribute) (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) LoopMixin (class in thriftworker.utils.mixin)

M

maybe_evaluate() (in module thriftworker.utils.proxy) message_buffer (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute)

method (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) method_name (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute)

O

on_close() (thriftworker.transports.framed.FramedAcceptor.Connection method)

P

Pool (class in thriftworker.workers.threads) Pool.Worker (class in thriftworker.workers.threads) pool_size (thriftworker.app.ThriftWorker attribute) port (thriftworker.listener.Listener attribute) (thriftworker.tests.app.test_listener.TestListener.Listener attribute) port_range (thriftworker.app.ThriftWorker attribute) processor (thriftworker.services.Services.Service attribute)

Promise (class in thriftworker.workers.sync) PromiseProxy (class in thriftworker.utils.proxy) PropertyMixin (class in thriftworker.utils.mixin) proto_factory (thriftworker.services.Services.Service attribute) protocol_factory (thriftworker.app.ThriftWorker attribute) put() (thriftworker.workers.threads.Pool method)

Q

qualname() (in module thriftworker.utils.imports)

R

ready() (thriftworker.transports.framed.FramedAcceptor.Connection method) receipt_time (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) register() (thriftworker.listener.Listeners method) (thriftworker.services.Services method) (thriftworker.tests.app.test_listener.TestListeners.Listeners method) (thriftworker.transports.base.Acceptors method) (thriftworker.transports.base.BaseAcceptor.Connections method) (thriftworker.transports.base.Connections method) remove() (thriftworker.transports.base.BaseAcceptor.Connections method) (thriftworker.transports.base.Connections method) Request (class in thriftworker.workers.base)

request_id (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) response (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) result (thriftworker.utils.loop.Container attribute) (thriftworker.workers.sync.Promise attribute) rgetattr() (in module thriftworker.utils.other) run() (thriftworker.workers.threads.Pool.Worker method) (thriftworker.workers.threads.Worker method)

S

service (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) Services (class in thriftworker.services) services (thriftworker.app.ThriftWorker attribute) Services (thriftworker.app.ThriftWorker attribute) Services.Service (class in thriftworker.services) set_current_app() (in module thriftworker.state) setUp() (thriftworker.tests.app.test_hub.TestHub method) (thriftworker.tests.app.test_listener.ListenerMixin method) (thriftworker.tests.app.test_listener.ListenersMixin method) (thriftworker.tests.utilities.stats.test_counter.TestCounter method) (thriftworker.tests.utilities.stats.test_timer.TestTimer method) (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) (thriftworker.tests.utils.CustomAppMixin method) (thriftworker.tests.utils.GreenTest method) (thriftworker.tests.utils.StartStopLoopMixin method) (thriftworker.tests.utils.TestCase method) skip() (in module thriftworker.tests.utilities.test_other) socket (thriftworker.listener.Listener attribute) (thriftworker.tests.app.test_listener.TestListener.Listener attribute) start (thriftworker.listener.Listener attribute) (thriftworker.tests.app.test_listener.TestListener.Listener attribute) (thriftworker.transports.base.BaseAcceptor attribute) start() (thriftworker.utils.mixin.StartStopMixin method) (thriftworker.workers.threads.Pool method) (thriftworker.workers.threads.ThreadsWorker method) start_accepting() (thriftworker.transports.base.Acceptors method) start_by_name() (thriftworker.transports.base.Acceptors method) start_stop_ctx() (in module thriftworker.tests.utils)

start_time (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) StartStopLoopMixin (class in thriftworker.tests.utils) StartStopMixin (class in thriftworker.utils.mixin) still_active() (thriftworker.utils.finalize.Finalize method) stop (thriftworker.listener.Listener attribute) (thriftworker.tests.app.test_listener.TestListener.Listener attribute) (thriftworker.transports.base.BaseAcceptor attribute) stop() (thriftworker.transports.base.Acceptors method) (thriftworker.utils.mixin.StartStopMixin method) (thriftworker.workers.threads.Pool method) (thriftworker.workers.threads.ThreadsWorker method) stop_accepting() (thriftworker.transports.base.Acceptors method) stop_by_name() (thriftworker.transports.base.Acceptors method) subclass_with_self() (thriftworker.utils.mixin.SubclassMixin method) SubclassMixin (class in thriftworker.utils.mixin) successful (thriftworker.workers.base.BaseWorker.Request attribute) (thriftworker.workers.base.Request attribute) symbol_by_name() (in module thriftworker.utils.imports) SyncWorker (class in thriftworker.workers.sync)

T

task (thriftworker.workers.threads.ThreadsWorker.Message attribute) test_add() (thriftworker.tests.utilities.stats.test_counter.TestCounter method) (thriftworker.tests.utilities.stats.test_timer.TestTimer method) (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_add_sample() (thriftworker.tests.utilities.stats.test_counter.TestCounter method) (thriftworker.tests.utilities.stats.test_timer.TestTimer method) test_addresses_from_pool_auto() (thriftworker.tests.utilities.test_other.TestOther method) test_addresses_from_pool_digit() (thriftworker.tests.utilities.test_other.TestOther method) test_addresses_from_pool_wrong() (thriftworker.tests.utilities.test_other.TestOther method) test_bind_error() (thriftworker.tests.app.test_listener.TestListener method) test_bind_from_pool() (thriftworker.tests.app.test_listener.TestListener method) test_bool() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_cached_property() (thriftworker.tests.utilities.test_decorators.TestOther method) test_cached_property_access() (thriftworker.tests.utilities.test_decorators.TestOther method) test_call() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_change_app() (thriftworker.tests.app.test_state.TestState method) test_cmp() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_context() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_count() (thriftworker.tests.utilities.stats.test_counter.TestCounter method) (thriftworker.tests.utilities.stats.test_timer.TestTimer method) test_current_app() (thriftworker.tests.app.test_app.TestApp method) (thriftworker.tests.app.test_state.TestState method) test_custom_loop() (thriftworker.tests.app.test_app.TestApp method) test_custom_pool_size() (thriftworker.tests.app.test_app.TestApp method) test_custom_port_range() (thriftworker.tests.app.test_app.TestApp method) test_custom_proto_factory() (thriftworker.tests.app.test_app.TestApp method) test_decr() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_default_app() (thriftworker.tests.app.test_app.TestApp method) test_dictproxy() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_dir() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_error_exit() (thriftworker.tests.app.test_hub.TestGreenlet method) test_get() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_getsetdel_attr() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_hash() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_iadd() (thriftworker.tests.utilities.stats.test_counter.TestCounter method) (thriftworker.tests.utilities.stats.test_timer.TestTimer method) test_incr() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_int() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_kill_just_started_block() (thriftworker.tests.app.test_hub.TestGreenlet method) test_kill_just_started_noblock() (thriftworker.tests.app.test_hub.TestGreenlet method) test_kill_not_started_block() (thriftworker.tests.app.test_hub.TestGreenlet method) test_kill_not_started_noblock() (thriftworker.tests.app.test_hub.TestGreenlet method) test_kill_running_block() (thriftworker.tests.app.test_hub.TestGreenlet method) test_kill_running_noblock() (thriftworker.tests.app.test_hub.TestGreenlet method) test_listproxy() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_maybe_evaluate() (thriftworker.tests.utilities.test_proxy.TestPromiseProxy method) test_name() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_negative_pool_size() (thriftworker.tests.app.test_app.TestApp method) test_no_app_created() (thriftworker.tests.app.test_state.TestState method) test_only_evaluated_once() (thriftworker.tests.utilities.test_proxy.TestPromiseProxy method) test_out_of_scope() (thriftworker.tests.utilities.test_finalize.TestOther method) test_port_from_range() (thriftworker.tests.utilities.test_other.TestOther method) test_props() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_reduce() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_register() (thriftworker.tests.app.test_listener.TestListeners method) test_repr() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_reset() (thriftworker.tests.utilities.test_finalize.TestOther method) test_rgetattr() (thriftworker.tests.utilities.test_other.TestOther method) test_set() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_simple_exit() (thriftworker.tests.app.test_hub.TestGreenlet method) test_slots() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_start_stop() (thriftworker.tests.app.test_hub.TestHub method) (thriftworker.tests.app.test_listener.TestListener method) test_sub() (thriftworker.tests.utilities.test_atomics.TestAtomicInteger method) test_unicode() (thriftworker.tests.utilities.test_proxy.TestProxy method) test_wakeup() (thriftworker.tests.app.test_hub.TestHub method)

test_wrong_port_range() (thriftworker.tests.app.test_app.TestApp method) TestApp (class in thriftworker.tests.app.test_app) TestAtomicInteger (class in thriftworker.tests.utilities.test_atomics) TestCase (class in thriftworker.tests.utils) TestCounter (class in thriftworker.tests.utilities.stats.test_counter) TestGreenlet (class in thriftworker.tests.app.test_hub) TestHub (class in thriftworker.tests.app.test_hub) TestListener (class in thriftworker.tests.app.test_listener) TestListener.Listener (class in thriftworker.tests.app.test_listener) TestListeners (class in thriftworker.tests.app.test_listener) TestListeners.Listeners (class in thriftworker.tests.app.test_listener) TestOther (class in thriftworker.tests.utilities.test_decorators) (class in thriftworker.tests.utilities.test_finalize) (class in thriftworker.tests.utilities.test_other) TestPromiseProxy (class in thriftworker.tests.utilities.test_proxy) TestProxy (class in thriftworker.tests.utilities.test_proxy) TestState (class in thriftworker.tests.app.test_state) TestTimer (class in thriftworker.tests.utilities.stats.test_timer) ThreadsWorker (class in thriftworker.workers.threads) ThreadsWorker.Message (class in thriftworker.workers.threads) ThriftWorker (class in thriftworker.app) thriftworker.__init__ (module) thriftworker.app (module) thriftworker.constants (module) thriftworker.exceptions (module) thriftworker.hub (module) thriftworker.listener (module) thriftworker.services (module) thriftworker.state (module) thriftworker.tests (module) thriftworker.tests.app.test_app (module) thriftworker.tests.app.test_hub (module) thriftworker.tests.app.test_listener (module) thriftworker.tests.app.test_state (module) thriftworker.tests.utilities.stats.test_counter (module) thriftworker.tests.utilities.stats.test_timer (module) thriftworker.tests.utilities.test_atomics (module) thriftworker.tests.utilities.test_decorators (module) thriftworker.tests.utilities.test_finalize (module) thriftworker.tests.utilities.test_other (module) thriftworker.tests.utilities.test_proxy (module) thriftworker.tests.utils (module) thriftworker.transports.base (module) thriftworker.transports.framed (module) thriftworker.utils.atomics (module) thriftworker.utils.decorators (module) thriftworker.utils.finalize (module) thriftworker.utils.imports (module) thriftworker.utils.loop (module) thriftworker.utils.mixin (module) thriftworker.utils.other (module) thriftworker.utils.proxy (module) thriftworker.utils.stats (module) thriftworker.utils.stats.counters (module) thriftworker.utils.stats.timers (module) thriftworker.workers.base (module) thriftworker.workers.sync (module) thriftworker.workers.threads (module) timeout (thriftworker.utils.loop.Container attribute) Timers (class in thriftworker.utils.stats.timers) to_dict() (thriftworker.utils.stats.counters.Counters method) (thriftworker.utils.stats.timers.Timers method)

W

wait() (thriftworker.workers.threads.Pool.Worker method) (thriftworker.workers.threads.Worker method) wait_for_predicate() (thriftworker.tests.utils.CustomAppMixin method) wakeup_loop() (thriftworker.tests.utils.StartStopLoopMixin method)

Worker (class in thriftworker.workers.threads) (thriftworker.app.ThriftWorker attribute) worker (thriftworker.app.ThriftWorker attribute) worker_cls (thriftworker.app.ThriftWorker attribute)