Each component that logs in to the manager gets an avatar created for
it in the manager.
|
|
|
|
|
|
|
addMessage(self,
level,
mid,
format,
*args,
**kwargs)
Convenience message to construct a message and add it to the
component state. |
source code
|
|
|
|
|
|
|
|
twisted.internet.defer.Deferred
|
provideMasterClock(self)
Tell the component to provide a master clock. |
source code
|
|
int
|
getFeedServerPort(self)
Returns the port on which a feed server for this component is
listening on. |
source code
|
|
str
|
getRemoteManagerIP(self)
Get the IP address of the manager as seen by the component. |
source code
|
|
str
|
getWorkerName(self)
Return the name of the worker. |
source code
|
|
int
|
getPid(self)
Return the PID of the component. |
source code
|
|
str
|
getName(self)
Get the name of the component. |
source code
|
|
str
|
getParentName(self)
Get the name of the component's parent. |
source code
|
|
str
|
getType(self)
Get the component type name of the component. |
source code
|
|
dict of eaterName -> [(feedId, eaterAlias)]
|
getEaters(self)
Get the set of eaters that this component eats from. |
source code
|
|
list of feederName
|
getFeeders(self)
Get the list of feeders that this component provides. |
source code
|
|
flumotion.common.common.feedId
|
getFeedId(self,
feedName)
Get the feedId of a feed provided or consumed by this component. |
source code
|
|
flumotion.common.common.fullFeedId
|
|
dict of fullFeedId -> (ComponentAvatar, feederName)
|
getVirtualFeeds(self)
Get the set of virtual feeds provided by this component. |
source code
|
|
str
|
getWorker(self)
Get the worker that this component should run on. |
source code
|
|
avatarId or None
|
getClockMaster(self)
Get this component's clock master, if any. |
source code
|
|
|
stop(self)
Tell the remote component to shut down. |
source code
|
|
|
|
|
eatFrom(self,
eaterAlias,
fullFeedId,
host,
port) |
source code
|
|
|
feedTo(self,
feederName,
fullFeedId,
host,
port) |
source code
|
|
twisted.internet.defer.Deferred
|
|
|
|
|
|
|
|
|
|
|
keepAlive(self,
issuerName,
ttl)
Resets the expiry timeout for keycards issued by issuerName. |
source code
|
|
|
perspective_cleanShutdown(self)
Called by a component to tell the manager that it's shutting down
cleanly (and thus should go to sleeping, rather than lost or sad) |
source code
|
|
|
|
|
|
|
|
Inherited from base.ManagerAvatar :
getClientAddress ,
mindCallRemote ,
perspective_authenticate ,
perspective_getBundleSums ,
perspective_getBundleSumsByFile ,
perspective_getBundleZips ,
perspective_getKeycardClasses ,
perspective_keepAlive ,
perspective_writeFluDebugMarker
Inherited from twisted.pb.PingableAvatar :
mindCallRemoteLogging ,
perspectiveMessageReceivedUnserialised ,
perspective_ping ,
setMind ,
startPingChecking ,
stopPingChecking
Inherited from twisted.pb.Avatar :
disconnect ,
perspectiveMessageReceived
Inherited from twisted.spread.pb.Avatar :
__providedBy__ ,
__provides__
Inherited from extern.log.log.Loggable :
debug ,
doLog ,
error ,
info ,
log ,
logFunction ,
logObjectName ,
warning ,
warningFailure ,
writeMarker
|