concurrent.core.application package¶

Submodules¶

concurrent.core.application.api module¶

Base interface representing an application.

class concurrent.core.application.api.IApp[source]¶

Bases: concurrent.core.components.component.Interface

Extension point that defines a component that will be handled as an application. Applications are components that run in an environment

app_init()[source]¶

Initialize application just before running it

app_main()[source]¶

Main entry point for the application. The app should return a return code or None

class concurrent.core.application.api.NodeType[source]¶

Bases: object

Node types that life in the framework

client = 2¶

invalid = -1¶

master = 0¶

slave = 1¶

class concurrent.core.application.api.NodeState[source]¶

Bases: object

Node state within the framework

active = 1¶

inactive = 2¶

inactive_forced = 3¶

invalid = -1¶

pending = 0¶

concurrent.core.application.application module¶

Base interface representing an application.

class concurrent.core.application.application.DefaultApplication(compmgr, init=None, cls=<class 'concurrent.core.application.application.DefaultApplication'>)[source]¶

Bases: concurrent.core.components.component.Component

app_init()[source]¶

Initialize application just before running it

app_main()[source]¶

Default Main implementation

class concurrent.core.application.application.ApplicationManager(compmgr, init=None, cls=<class 'concurrent.core.application.application.ApplicationManager'>)[source]¶

Bases: concurrent.core.components.component.Component

The application manager is a component that just handles a list of available applications

exception concurrent.core.application.application.ApplicationNotImplementedError(message, title=None, show_traceback=False)[source]¶

Bases: concurrent.core.exceptions.baseerror.BaseError

Error used when an app dose not implement a specifc methos

title = '[Config Error]'¶

concurrent.core.application.pickler module¶

Pickling of python instances

exception concurrent.core.application.pickler.PickleException(message=None, data=None)[source]¶

Bases: concurrent.core.transport.pyjsonrpc.rpcerror.JsonRpcError

code = -10001¶

message = u'Failed to pickle a remote object'¶

class concurrent.core.application.pickler.Pickler(compmgr, init=<function __init__ at 0x0000000004CB9BA8>, cls=<class 'concurrent.core.application.pickler.Pickler'>)[source]¶

Bases: concurrent.core.components.component.Component

aes_padding¶

Padding used for AES encryption

num_iterations¶

Number of iterations used in the key generation

pickle_encode_s(obj)[source]¶

Encode a pickled object

pickle_f(fname, obj)[source]¶

picke an object into a file

pickle_protocol¶

Protocol used when pickling, by default pickle.HIGHEST_PROTOCOL

pickle_s(obj)[source]¶

pickle an object and return the pickled string

salt_size¶

Size of the salt used in the encryption process

secret¶

Default salt used on decrypting encrypting a pickle

unpickle_decode_s(pickle_string)[source]¶

Unpickle a base64 string and return an object

unpickle_f(fname)[source]¶

Unpicke an object from a file

unpickle_s(pickle_string)[source]¶

unpickle a string and return an object

exception concurrent.core.application.pickler.UnpickleException(message=None, data=None)[source]¶

Bases: concurrent.core.transport.pyjsonrpc.rpcerror.JsonRpcError

code = -10002¶

message = u'Failed to unpickle a remote object'¶

Module contents¶