Trees | Index | Help |
---|
Package flumotion :: Package manager :: Module component :: Class ComponentAvatar |
|
Avatar
--+ |Loggable
--+ |ManagerAvatar
--+ | ComponentAvatar
Method Summary | |
---|---|
| |
__del__(self)
| |
__repr__(self)
| |
Tell the avatar that the given mind has been attached. | |
Authenticate the given keycard. | |
Clean up when detaching. | |
Tell the avatar that the peer's client referenced by the mind has detached. | |
Expire a keycard issued to this component because the bouncer decided to. | |
list of str |
Get a list of feeder names feeding this component. |
Get a property of an element. | |
list of str |
Get a list of feeder names (componentName:feedName) in this component. |
int |
Returns the port this feed is being fed on. |
str |
Get the name of the component. |
str |
Get the name of the component's parent. |
int |
Return the PID of the component. |
str |
Get the IP address of the manager as seen by the component. |
str |
Get the component type name of the component. |
str |
Return the name of the worker. |
Call the given method on all connected admin clients. | |
Authenticate the given keycard using the given bouncer. | |
perspective_error(self,
element,
error)
| |
Expire a keycard (and thus the requester's connection) issued to the given requester. | |
Called by the component to tell the manager that a given feed is ready or not. | |
Called by the component to tell the manager that this component is still alive and kicking. | |
Remove a keycard on the given bouncer on behalf of a component's medium. | |
Request reservation a number of ports on a particular worker. | |
twisted.internet.defer.Deferred
|
Tell the component to reload itself. |
Remove a keycard managed by this bouncer because the requester has gone. | |
Set a property on an element. | |
Set up the component with the given config. | |
start(self,
*args,
**kwargs)
| |
stateAppend(self,
state,
key,
value)
| |
stateRemove(self,
state,
key,
value)
| |
stateSet(self,
state,
key,
value)
| |
Tell the avatar to stop the component. | |
_addMessage(self,
message)
| |
_getMoodValue(self)
| |
_getState(self)
| |
Check if we received the heartbeat lately. | |
_mindErrback(self,
failure,
*ignores)
| |
_mindGetStateCallback(self,
state)
| |
_mindPipelineErrback(self,
failure)
| |
_mindPropertyErrback(self,
failure)
| |
_setMood(self,
mood)
| |
_setMoodValue(self,
moodValue)
| |
Inherited from ManagerAvatar | |
str or None |
Get the IPv4 address of the machine the PB client is connecting from, as seen from the avatar. |
bool |
Check if the avatar has a remote reference to the peer. |
Call the given remote method. | |
list of tuple of (str, str) |
Get a list of (bundleName, md5sum) of all dependency bundles, starting with this bundle, in the correct order. |
list of (str, str) tuples |
Get a list of (bundleName, md5sum) of all dependency bundles, starting with this bundle, in the correct order. |
dict of str -> str |
Get the zip files for the given list of bundles. |
| |
Inherited from Avatar | |
This method is called when a network message is received. | |
Inherited from Loggable | |
Log a debug message. | |
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. |
Instance Variable Summary | |
---|---|
Inherited from ManagerAvatar | |
str | avatarId : the id for this avatar, unique inside the heaven |
flumotion.manager.base.ManagerHeaven |
heaven : the heaven this avatar is part of |
twisted.spread.pb.RemoteReference |
mind : a remote reference to the client-side Medium |
flumotion.manager.manager.Vishnu |
vishnu : the vishnu that manages this avatar's heaven |
Class Variable Summary | |
---|---|
tuple |
__implements__ = (<class 'flumotion.twisted.flavors.ISta...
|
flumotion.common.planet.ManagerComponentState |
componentState : component state of this avatar's component |
flumotion.common.planet.ManagerJobState |
jobState : job state of this avatar's component |
str |
logCategory : Implementors can provide a category to log their messages under. |
float |
_heartbeatCheckInterval = 12.5 |
Method Details |
---|
__init__(self,
heaven,
avatarId)
|
attached(self, mind)Tell the avatar that the given mind has been attached. This gives the avatar a way to call remotely to the client that requested this avatar. This is scheduled by the portal after the client has logged in.
|
authenticate(self, keycard)Authenticate the given keycard. Gets proxied toflumotion.component.bouncers.bouncer.BouncerMedium.remote_authenticate
The component should be a subclass of flumotion.component.bouncers.bouncer.Bouncer
|
cleanup(self)Clean up when detaching. |
detached(self, mind)Tell the avatar that the peer's client referenced by the mind has detached. Called through the manager's PB logout trigger callingflumotion.manager.manager.Dispatcher.removeAvatar
|
expireKeycard(self, keycardId)Expire a keycard issued to this component because the bouncer decided to.
|
getEaters(self)Get a list of feeder names feeding this component.
|
getElementProperty(self, element, property)Get a property of an element.
|
getFeeders(self)Get a list of feeder names (componentName:feedName) in this component.
|
getFeedPort(self, feedName)Returns the port this feed is being fed on.
|
getName(self)Get the name of the component.
|
getParentName(self)Get the name of the component's parent.
|
getPid(self)Return the PID of the component.
|
getRemoteManagerIP(self)Get the IP address of the manager as seen by the component.
|
getType(self)Get the component type name of the component.
|
getWorkerName(self)Return the name of the worker.
|
perspective_adminCallRemote(self, methodName, *args, **kwargs)Call the given method on all connected admin clients.
|
perspective_authenticate(self, bouncerName, keycard)Authenticate the given keycard using the given bouncer. The bouncer needs to be part of the atmosphere.
|
perspective_expireKeycard(self, requesterName, keycardId)Expire a keycard (and thus the requester's connection) issued to the given requester. This is called by the bouncer component that authenticated the keycard.
|
perspective_feedReady(self, feedName, isReady)Called by the component to tell the manager that a given feed is ready or not. Will notify other components depending on this feeder, starting them if all of their dependencies are ready.
|
perspective_heartbeat(self, moodValue)Called by the component to tell the manager that this component is still alive and kicking.
|
perspective_removeKeycardId(self, bouncerName, keycardId)Remove a keycard on the given bouncer on behalf of a component's medium. This is requested by a component that created the keycard.
|
perspective_reservePortsOnWorker(self, workerName, numberOfPorts)Request reservation a number of ports on a particular worker. This can be called from a job if it needs some ports itself.
|
reloadComponent(self)Tell the component to reload itself.
|
removeKeycardId(self, keycardId)Remove a keycard managed by this bouncer because the requester has gone.
|
setElementProperty(self, element, property, value)Set a property on an element.
|
setup(self, config)Set up the component with the given config. Proxies toflumotion.component.component.BaseComponentMedium.remote_setup
|
stop(self)Tell the avatar to stop the component. |
_heartbeatCheck(self)Check if we received the heartbeat lately. Set mood to LOST if not. |
Class Variable Details |
---|
__implements__
|
componentStatecomponent state of this avatar's component |
jobStatejob state of this avatar's component |
logCategoryImplementors can provide a category to log their messages under.
|
_heartbeatCheckInterval
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Thu Jan 25 09:31:09 2007 | http://epydoc.sf.net |