rpc Package

client Module

class thriftpool.rpc.client.Client(app, producer)

Bases: object

Provide simple interface to pass commands to slaves.

class Proxy(app, producer)

Bases: object

Proxy object that execute functions on other side.

Client.spawn

Spawn given function in separate greenlet. Keyword argument proxy will be passed to provided function.

class thriftpool.rpc.client.Proxy(app, producer)

Bases: object

Proxy object that execute functions on other side.

manager Module

class thriftpool.rpc.manager.Clients

Bases: object

Manage clients.

class Client(app, producer)

Bases: object

Provide simple interface to pass commands to slaves.

class Proxy(app, producer)

Bases: object

Proxy object that execute functions on other side.

Clients.Client.spawn

Spawn given function in separate greenlet. Keyword argument proxy will be passed to provided function.

class Clients.Producer(loop, incoming, outgoing, process)

Bases: thriftpool.rpc.transport.Transport

Push commands to consumer.

apply

Enqueue new remote procedure call.

Clients.clear()

Unregister all clients.

Clients.keys()

Clients.register(process, callback=None, **kwargs)

Create new producer for given process.

Clients.spawn

Map given function to all clients.

Clients.unregister(pid)

Stop and remove producer by process id.

transport Module

class thriftpool.rpc.transport.Consumer(loop, incoming, outgoing, handler)

Bases: thriftpool.rpc.transport.Transport

Pull commands from consumer, execute them and return result.

start()

stop()

class thriftpool.rpc.transport.Producer(loop, incoming, outgoing, process)

Bases: thriftpool.rpc.transport.Transport

Push commands to consumer.

apply

Enqueue new remote procedure call.

class thriftpool.rpc.transport.Proto

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

class thriftpool.rpc.transport.Receiver(stream, emitter)

Bases: thriftpool.rpc.transport.Proto

Receive request from channel.

WAIT_LENGTH = 1

WAIT_PAYLOAD = 2

start()

stop()

class thriftpool.rpc.transport.Transmitter(stream, emitter)

Bases: thriftpool.rpc.transport.Proto

Write request to channel.

start()

stop()

write(obj, callback=None, request_id=None)

class thriftpool.rpc.transport.Transport(loop, incoming, outgoing)

Bases: object

Exchange messages on channel.

class Receiver(stream, emitter)

Bases: thriftpool.rpc.transport.Proto

Receive request from channel.

WAIT_LENGTH = 1

WAIT_PAYLOAD = 2

start()

stop()

class Transport.Transmitter(stream, emitter)

Bases: thriftpool.rpc.transport.Proto

Write request to channel.

start()

stop()

write(obj, callback=None, request_id=None)

Transport.start()

Transport.stop()

Transport.subscribe(listener)

Transport.unsubscribe(listener)

Transport.write(obj, callback=None, request_id=None)