Package flumotion :: Package worker :: Module worker :: Class JobHeaven
[show private | hide private]
[frames | no frames]

Class JobHeaven

             Loggable --+
                        |
Jellyable --+           |
            |           |
 Serializable --+       |
                |       |
    Referenceable --+   |
                    |   |
                 Root --+
                        |
                       JobHeaven


I am similar to but not quite the same as a manager-side Heaven. I manage avatars inside the worker for job processes spawned by the worker.
Method Summary
  __init__(self, brain)
  createAvatar(self, avatarId)
flumotion.twisted.pb.Authenticator getAuthenticator(self)
Gets the authenticator that the worker used to log in to the manager.
str getWorkerName(self)
Gets the name of the worker that spawns the process.
  lostAvatar(self, avatarId)
  shutdown(self)
  _HUPHandler(self, signum, frame)
    Inherited from Root
  rootObject(self, broker)
A pb.BrokerFactory is requesting to publish me as a root object.
    Inherited from Referenceable
  jellyFor(self, jellier)
(internal)
  remoteMessageReceived(self, broker, message, args, kw)
A remote message has been received.
    Inherited from Serializable
  processUniqueID(self)
Return an ID which uniquely represents this object for this process.
    Inherited from Jellyable
  getStateFor(self, jellier)
    Inherited from Loggable
  debug(self, *args)
Log a debug message.
dict doLog(self, level, where, format, *args, **kwargs)
Log a message at the given level, with the possibility of going higher up in the stack.
  error(self, *args)
Log an error.
  info(self, *args)
Log an informational message.
  log(self, *args)
Log a log message.
  logFunction(self, *args)
Overridable log function.
  logObjectName(self)
Overridable object name function.
  warning(self, *args)
Log a warning.
  warningFailure(self, failure, swallow)
Log a warning about a Failure.

Instance Variable Summary
dict of str -> JobAvatar avatars: dict of avatarId -> avatar
WorkerBrain brain: the worker brain

Class Variable Summary
str logCategory: Implementors can provide a category to log their messages under.
    Inherited from Root
Implements __implemented__ = <implementedBy twisted.spread.flavors....
ClassProvides __provides__ = <zope.interface.declarations.ClassProvide...
    Inherited from Referenceable
NoneType perspective = None                                                                  
    Inherited from Jellyable
ClassProvides __providedBy__ = <zope.interface.declarations.ClassProvi...

Method Details

__init__(self, brain)
(Constructor)

Parameters:
brain
           (type=WorkerBrain)

getAuthenticator(self)

Gets the authenticator that the worker used to log in to the manager.
Returns:
flumotion.twisted.pb.Authenticator

getWorkerName(self)

Gets the name of the worker that spawns the process.
Returns:
str

Instance Variable Details

avatars

dict of avatarId -> avatar
Type:
dict of str -> JobAvatar

brain

the worker brain
Type:
WorkerBrain

Class Variable Details

logCategory

Implementors can provide a category to log their messages under.
Type:
str
Value:
'job-heaven'                                                           

Generated by Epydoc 2.1 on Sat Apr 14 13:11:55 2007 http://epydoc.sf.net