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)
    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 Sun Oct 26 16:39:16 2008 http://epydoc.sf.net