app Package

app Package

_state Module

Handle global package state.

thriftpool.app._state.as_default_cls(cls)

thriftpool.app._state.get_current_app()

thriftpool.app._state.get_default_cls()

thriftpool.app._state.set_current_app(app)

base Module

Main factory for this library. Single entry point for all application.

class thriftpool.app.base.ThriftPool

Bases: thriftpool.utils.mixin.SubclassMixin

Main entry point for this application.

Daemon

Loader

Default loader class.

Logging

Create bounded logging initialize class from log.Logging. We will call log.Logging.setup() on finalization to setup logging.

ManagerController

Repository

Create bounded slots repository from slots:Repository.

WorkerController

config

Empty application configuration.

daemon_cls = 'thriftpool.app.daemon:Daemon'

Specify daemonizing behavior.

finalize()

Make some steps before application startup.

gaffer_manager

Create process manager.

hub

loader

loader_cls = 'thriftpool.app.loader:Loader'

Default loader for this application. Must provide configuration for it.

log

Instantiate logging initializer from bounded class.

logging_cls = 'thriftpool.app.log:Logging'

What class should be used for logging setup.

loop

manager_cls = 'thriftpool.controllers.manager:ManagerController'

Manager controller class.

protocol_factory

Create handler instance.

register(*args, **options)

Register new handler.

repo_cls = 'thriftpool.app.slots:Repository'

Repository for registered slots.

request_stack

Store current requests.

request_stack_cls = 'thriftpool.request.stack:RequestStack'

Store active requests here.

slots

Create repository of service slots. By default it is empty.

thriftworker

worker_cls = 'thriftpool.controllers.worker:WorkerController'

Worker controller class.

config Module

class thriftpool.app.config.Configuration(config)

Bases: thriftpool.utils.structures.AggregatedView

Default application configuration.

daemon Module

class thriftpool.app.daemon.Daemon(controller, pidfile=None, daemonize=False, foreground=False, args=None)

Bases: object

Daemon behavior.

app = None

on_exit()

on_start()

start()

Start new worker.

loader Module

Contains initializer for application.

class thriftpool.app.loader.Loader

Bases: object

Provide configuration and some callback for main application.

after_start()

Called after controller start.

after_unpickling()

Called after application was unpickled.

app = None

builtin_modules = ['thriftpool.remote.handler']

Specify modules that should be preloaded.

entrypoint_modules()

List all modules that are registered through setuptools entry points.

get_config()

Return application configuration.

import_module(module)

list_modules()

List all known module names.

on_before_init(controller)

Called before controller initialization.

on_shutdown()

Called after controller shutdown.

on_start()

Called before controller start.

preload_modules()

log Module

Configure logging subsystem.

class thriftpool.app.log.Logging

Bases: object

Setup logging subsystem.

app = None

colorize(logfile=None)

Can be output colored?

get_handler(logfile=None)

Create log handler with either a filename, an open stream or None (stderr).

log_tornado_request(handler)

redirect_stdouts_to_logger(logger, loglevel=None, stdout=True, stderr=True)

Redirect sys.stdout and sys.stderr to a logging instance.

Parameters:

• logger – The logging.Logger instance to redirect to.
• loglevel – The loglevel redirected messages will be logged as.

setup()

setup_handlers(logger, logfile, format, formatter=<class 'thriftpool.utils.logs.ColorFormatter'>)

Register needed handlers for given logger. If logfile equal to None use sys.stderr as logfile.

setup_request_logging()

Setup system to log requests.

setup_tornado_logger()

slots Module

Implement service repository.

class thriftpool.app.slots.Repository(slots=None)

Bases: set

Store existed slots.

class Listener

Bases: thriftpool.app.slots.Listener

Specify which port we should listen.

Repository.Service

alias of ThriftService

Repository.add(slot)

Add new slot to collection.

Repository.app = None

Repository.register(name, processor_cls, handler_cls, **opts)

Register new service in repository.