Trees | Index | Help |
---|
Package flumotion :: Package manager :: Module manager :: Class Vishnu |
|
Loggable
--+
|
Vishnu
Method Summary | |
---|---|
__init__(self,
name,
unsafeTracebacks,
configDir)
| |
| |
Set the given message on the given component's state. | |
componentAttached(self,
componentAvatar)
| |
Create the given component. | |
componentDetached(self,
componentAvatar)
| |
defer.Deferred
|
Stop the given component. |
a deferred that will fire a flumotion.common.identity.RemoteIdentity
|
Compute a suitable identity for a remote host. |
Empty the planet of the given component. | |
deleteFlow(self,
*args,
**kwargs)
| |
Empty the planet of all components, and flows. | |
flumotion.common.bundle.BundlerBasket
|
Return a bundler basket to unbundle from. |
ComponentMapper or None
|
Look up an object mapper given the object. |
getComponentStates(self)
| |
Returns the manager's configuration as a string suitable for importing via loadConfiguration(). | |
getFactory(self)
| |
getWorkerFeedServerPort(self,
workerName)
| |
Load the configuration from the given XML, merging it on top of the currently running configuration. | |
registerComponent(self,
componentAvatar)
| |
Tells the manager that the given ports are no longer being used, and may be returned to the allocation pool. | |
Requests a number of ports on the worker named workerName. | |
| |
setConnectionInfo(self,
host,
port,
use_ssl)
| |
unregisterComponent(self,
componentAvatar)
| |
workerAttached(self,
workerAvatar)
| |
workerDetached(self,
workerAvatar)
| |
flumotion.common.planet.ManagerComponentState
|
Add a component state for the given component config entry. |
_addManagerPlug(self,
socket,
args,
identity)
| |
_addManagerPlugs(self,
_,
conf,
identity)
| |
_createCallback(self,
result,
componentState)
| |
_createErrback(self,
failure,
state)
| |
Create a heaven of the given klass that will send avatars to clients implementing the given medium interface. | |
_emptyPlanetCallback(self,
result)
| |
_getComponentState(self,
deferredListResult,
avatar)
| |
list of flumotion.common.planet.ManagerComponentState
|
|
_getWorker(self,
workerName)
| |
_loadConfiguration(self,
conf,
identity)
| |
_makeBouncer(self,
conf,
identity)
| |
_startComponents(self,
components,
conf,
identity)
| |
_updateFlowDependencies(self,
state)
| |
list of flumotion.common.planet.ManagerComponentState
|
Add a new config object into the planet state. |
_workerCreateComponentDelayed(self,
result,
workerAvatar,
componentState,
type,
conf)
| |
Create the list of components on the given worker, sequentially, but in no specific order. | |
Inherited from Loggable | |
Log a debug message. | |
dict |
Log a message at the given level, with the possibility of going higher up in the stack. |
Log an error. | |
Log an informational message. | |
Log a log message. | |
Overridable log function. | |
Overridable object name function. | |
Log a warning. | |
Log a warning about a Failure. |
Class Variable Summary | |
---|---|
Implements |
__implemented__ = <implementedBy flumotion.manager.manag...
|
ClassProvides |
__provides__ = <zope.interface.declarations.ClassProvide...
|
admin.AdminHeaven |
adminHeaven : the admin heaven |
component.ComponentHeaven |
componentHeaven : the component heaven |
Dispatcher |
dispatcher : dispatcher to create avatars |
str |
logCategory : Implementors can provide a category to log their messages under. |
worker.WorkerHeaven |
workerHeaven : the worker heaven |
Inherited from Loggable | |
ClassProvides |
__providedBy__ = <zope.interface.declarations.ClassProvi...
|
Method Details |
---|
adminAction(self, identity, message, args, kw)
|
componentAddMessage(self, avatarId, message)Set the given message on the given component's state. Can be called e.g. by a worker to report on a crashed component. Sets the mood to sad if it is an error message. |
componentCreate(self, componentState)Create the given component. This will currently also trigger a start eventually when the component avatar attaches. The component should be sleeping. The worker it should be started on should be present. |
componentStop(self, componentState)Stop the given component. If the component was sad, we clear its sad state as well, since the stop was explicitly requested by the admin.
|
computeIdentity(self, keycard, remoteHost)Compute a suitable identity for a remote host. First looks to see if there is a flumotion.component.plugs.identity.IdentityProvider plug installed on the manager, falling back to user@host. The identity is only used in the adminaction interface. An example of its use is when you have an adminaction plug that checks an admin's privileges before actually doing an action; the identity object you use here might store the privileges that the admin has.
|
deleteComponent(self, componentState)Empty the planet of the given component.
|
emptyPlanet(self)Empty the planet of all components, and flows.
|
getBundlerBasket(self)Return a bundler basket to unbundle from. If the registry files were updated since the last time, the bundlerbasket will be rebuilt.
|
getComponentMapper(self, object)Look up an object mapper given the object.
|
getConfiguration(self)Returns the manager's configuration as a string suitable for importing via loadConfiguration(). |
loadConfigurationXML(self, file, identity)Load the configuration from the given XML, merging it on top of the currently running configuration.
|
releasePortsOnWorker(self, workerName, ports)Tells the manager that the given ports are no longer being used, and may be returned to the allocation pool. |
reservePortsOnWorker(self, workerName, numPorts)Requests a number of ports on the worker named workerName. The ports will be reserved for the use of the caller until releasePortsOnWorker is called.
|
setBouncer(self, bouncer)
|
_addComponent(self, conf, parent, identity)Add a component state for the given component config entry. |
_createHeaven(self, interface, klass)Create a heaven of the given klass that will send avatars to clients implementing the given medium interface.
|
_getComponentsToCreate(self)
|
_updateStateFromConf(self, _, conf, identity)Add a new config object into the planet state.
|
_workerCreateComponents(self, workerId, components)Create the list of components on the given worker, sequentially, but in no specific order.
|
Class Variable Details |
---|
__implemented__
|
__provides__
|
adminHeaventhe admin heaven
|
componentHeaventhe component heaven |
dispatcherdispatcher to create avatars
|
logCategoryImplementors can provide a category to log their messages under.
|
workerHeaventhe worker heaven
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Sat Apr 14 13:16:52 2007 | http://epydoc.sf.net |