Package flumotion :: Package worker :: Module worker :: Class JobHeaven

Class JobHeaven

 twisted.spread.jelly.Jellyable --+            
                                  |            
twisted.spread.flavors.Serializable --+        
                                      |        
   twisted.spread.flavors.Referenceable --+    
                                          |    
                twisted.spread.flavors.Root --+
                                              |
                        common.log.Loggable --+
                                              |
                                             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.

Instance Methods

__init__(self, brain)

source code

_HUPHandler(self, signum, frame)

source code

createAvatar(self, avatarId)

source code

lostAvatar(self, avatarId)

source code

shutdown(self)

source code

flumotion.twisted.pb.Authenticator

getAuthenticator(self)
Gets the authenticator that the worker used to log in to the manager.

source code

str

getWorkerName(self)
Gets the name of the worker that spawns the process.

source code

Inherited from twisted.spread.flavors.Root: rootObject

Inherited from twisted.spread.flavors.Referenceable: jellyFor, remoteMessageReceived

Inherited from twisted.spread.flavors.Serializable: processUniqueID

Inherited from twisted.spread.jelly.Jellyable: __providedBy__, getStateFor

Inherited from common.log.Loggable: debug, doLog, error, info, log, logFunction, logObjectName, warning, warningFailure

Class Variables

logCategory = 'job-heaven'
Implementors can provide a category to log their messages under.

Inherited from twisted.spread.flavors.Root: __implemented__, __provides__

Inherited from twisted.spread.flavors.Referenceable: perspective

Instance Variables

dict of str -> JobAvatar

avatars
dict of avatarId -> avatar

WorkerBrain

brain
the worker brain

Method Details

init(self, brain)
(Constructor)

Parameters:

brain (WorkerBrain)