flumotion.worker.job.JobMedium

Package flumotion :: Package worker :: Module job :: Class JobMedium

[show private | hide private]

Class JobMedium

         Loggable --+    
                    |    
Jellyable --+       |    
            |       |    
 Serializable --+   |    
                |   |    
    Referenceable --+    
                    |    
           BaseMedium --+
                        |
                       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)`
	`remote_initial(self, host, port, transport)`
	`remote_start(self, avatarId, type, config, feedPorts)` I am called on by the worker's JobAvatar to start a component.
	`remote_stop(self)`
	`shutdown(self)` Shut down the job process completely, cleaning up the component so the reactor can be left from.
	`threads_init(self)`
	`_enable_core_dumps(self)`
	`_runComponent(self, avatarId, type, config, defs, feedPorts)`
	`_set_nice(self, nice)`
Inherited from BaseMedium
	`callRemote(self, name, args, *kwargs)`
	`hasRemoteReference(self)`
	`load_module(self, modname)`
	`run_bundled_proc(self, args, *kwargs)`
	`setRemoteReference(self, remoteReference)`
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__` = `(<MetaInterface flumotion.common.interf...`
`str`	`logCategory`: Implementors can provide a category to log their messages under.
Inherited from BaseMedium
`NoneType`	`bundleLoader` = None
`NoneType`	`remote` = None
Inherited from Referenceable
`Implements`	`__implemented__` = `<implementedBy twisted.spread.flavors....`
`ClassProvides`	`__provides__` = `<zope.interface.declarations.ClassProvide...`
`NoneType`	`perspective` = None
Inherited from Jellyable
`ClassProvides`	`__providedBy__` = `<zope.interface.declarations.ClassProvi...`

Method Details

remote_start(self, avatarId, type, config, 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); config - the configuration dictionary
(type=dict); feedPorts - feedName -> port
(type=dict)

shutdown(self)

Shut down the job process completely, cleaning up the component so the reactor can be left from.

_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:: (<MetaInterface 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 Sun Sep 4 00:24:44 2005

http://epydoc.sf.net