Package wtf :: Package opi :: Package worker

[frames] | no frames]

Package worker

The modules in this package implement the different ways of worker pool models. Currently there are:

threaded: There's one single process managing a threadpool. Accepted sockets are dispatched to a single worker thread.

Author: André Malo

Submodules

wtf.opi.worker.single: Here's the single worker handling implemented.
wtf.opi.worker.threaded: Here's the threadpool handling implemented.

Classes

WorkerInterface
Interface for worker implementations

WorkerPoolInterface
Interface for worker pools

Functions

WorkerInterface

factory(config, opts, args)
Create the worker instance selected by configuration

source code

register(name, klass)
Register a worker implementation

source code

Variables

__package__ = 'wtf.opi.worker'

Function Details

factory(config, opts, args)

Create the worker instance selected by configuration

Parameters:

config (config.Config) - configuration
opts (optparse.OptionContainer) - Option container
args (list) - Fixed arguments

Returns: WorkerInterface

worker instance

register(name, klass)

Register a worker implementation

Parameters:

name (str) - The name (in the config)
klass (WorkerInterface) - The implementation class