Trees       Indices       Help   
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
 
__provides__(...)
Special descriptor for class __provides__

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
hash(x)
  __implemented__ = <implementedBy flumotion.worker.base.BaseJob...

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:

__provides__(...)

  
Special descriptor for class __provides__

The descriptor caches the implementedBy info, so that
we can get declarations for objects without instance-specific
interfaces a bit quicker.

For example:

  >>> from zope.interface import Interface
  >>> class IFooFactory(Interface):
  ...     pass
  >>> class IFoo(Interface):
  ...     pass
  >>> class C(object):
  ...     implements(IFoo)
  ...     classProvides(IFooFactory)
  >>> [i.getName() for i in C.__provides__]
  ['IFooFactory']

  >>> [i.getName() for i in C().__provides__]
  ['IFoo']
Overrides: twisted.spread.jelly.Jellyable.__provides__

Class Variable Details [hide private]

__implemented__

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

   Trees       Indices       Help   
Generated by Epydoc 3.0.1 on Thu May 5 05:30:25 2011 http://epydoc.sourceforge.net