Bases: object
Manage clients.
Bases: object
Provide simple interface to pass commands to slaves.
Bases: object
Proxy object that execute functions on other side.
Spawn given function in separate greenlet. Keyword argument proxy will be passed to provided function.
Bases: thriftpool.rpc.transport.Transport
Push commands to consumer.
Enqueue new remote procedure call.
Bases: thriftpool.rpc.transport.Transport
Pull commands from consumer, execute them and return result.
Bases: thriftpool.rpc.transport.Transport
Push commands to consumer.
Bases: object
Mixin that produce encode and decode methods. Each packet represented by simple structure:
Length Request id (UUID) Pickled object 4 bytes 32 bytes undefined
Bases: thriftpool.rpc.transport.Proto
Receive request from channel.
Bases: thriftpool.rpc.transport.Proto
Write request to channel.
Bases: object
Exchange messages on channel.
Bases: thriftpool.rpc.transport.Proto
Receive request from channel.
Bases: thriftpool.rpc.transport.Proto
Write request to channel.