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

Class JobMedium

         Loggable --+
                    |
Jellyable --+       |
            |       |
 Serializable --+   |
                |   |
    Referenceable --+
                    |
                   JobMedium


I am a medium between the job and the worker's job avatar. I live in the job process.
Method Summary
  __init__(self, options)
  hasPerspective(self)
  remote_initial(self, host, port, transport)
  remote_start(self, avatarId, type, configDict, feedPorts)
I am called on by the worker's JobAvatar to start a component.
  remote_stop(self)
  setRemoteReference(self, remoteReference)
  threads_init(self)
  _enable_core_dumps(self)
  _runComponent(self, avatarId, type, config, defs, feedPorts)
  _set_nice(self, nice)
    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.
  error(self, *args)
Log an error.
  info(self, *args)
Log an informational message.
  log(self, *args)
Log a log message.
  logFunction(self, message)
Overridable log function.
  logObjectName(self)
Overridable object name function.
  warning(self, *args)
Log a warning.

Class Variable Summary
tuple __implements__ = (<class 'flumotion.common.interfaces.IJ...
str logCategory: Implementors can provide a category to log their messages under.
    Inherited from Referenceable
NoneType perspective = None                                                                  

Method Details

remote_start(self, avatarId, type, configDict, feedPorts)

I am called on by the worker's JobAvatar to start a component.
Parameters:
avatarId - avatarId for component to log in to manager
           (type=string)
type - type of component to start
           (type=string)
configDict - the configuration dictionary
           (type=dict)
feedPorts - feedName -> port
           (type=dict)

_runComponent(self, avatarId, type, config, defs, feedPorts)

Parameters:
avatarId - avatarId component will use to log in to manager
           (type=string)
type - type of component to start
           (type=string)
config - the configuration dictionary
           (type=dict)
defs - the registry entry for a component
           (type=flumotion.common.registry.RegistryEntryComponent)
feedPorts - feedName -> port
           (type=dict)

Class Variable Details

__implements__

Type:
tuple
Value:
(<class 'flumotion.common.interfaces.IJobMedium'>,)                    

logCategory

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

Generated by Epydoc 2.1 on Wed Feb 16 07:22:59 2005 http://epydoc.sf.net