Package flumotion :: Package worker :: Module base :: Class BaseJobHeaven
[hide private]

Class BaseJobHeaven

source code

 twisted.spread.jelly.Jellyable --+            
                                  |            
twisted.spread.flavors.Serializable --+        
                                      |        
   twisted.spread.flavors.Referenceable --+    
                                          |    
                twisted.spread.flavors.Root --+
                                              |
                    extern.log.log.Loggable --+
                                              |
                                             BaseJobHeaven
Known Subclasses:

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 [hide private]
 
__init__(self, brain) source code
 
listen(self) source code
 
requestAvatar(self, avatarId, mind, *interfaces) source code
 
removeAvatar(self, avatarId) source code
str
getWorkerName(self)
Gets the name of the worker that spawns the process.
source code
 
addJobInfo(self, processId, jobInfo) source code
 
getJobInfo(self, processId) source code
 
getJobInfos(self) source code
 
getJobPids(self) source code
 
rotateChildLogFDs(self) source code
 
jobStopped(self, pid) source code
 
shutdown(self) source code
 
kill(self, signum=9) source code
 
killJobByPid(self, pid, signum) source code
 
killJob(self, avatarId, signum) 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 extern.log.log.Loggable: debug, doLog, error, info, log, logFunction, logObjectName, warning, warningFailure, writeMarker

Class Variables [hide private]
  logCategory = 'job-heaven'
Implementors can provide a category to log their messages under.
  avatarClass = None
  __implemented__ = <implementedBy flumotion.worker.base.BaseJob...
  __provides__ = <zope.interface.declarations.ClassProvides obje...

Inherited from twisted.spread.flavors.Referenceable: perspective

Instance Variables [hide private]
dict of str -> base.BaseJobAvatar avatars
dict of avatarId -> avatar
worker.WorkerBrain brain
the worker brain
Method Details [hide private]

__init__(self, brain)
(Constructor)

source code 
Parameters:

Class Variable Details [hide private]

__implemented__

Value:
<implementedBy flumotion.worker.base.BaseJobHeaven>

__provides__

Value:
<zope.interface.declarations.ClassProvides object at 0xa8b644c>