Package flumotion :: Package admin :: Module admin :: Class AdminModel
[show private | hide private]
[frames | no frames]

Type AdminModel

       object --+    
                |    
          GObject --+
                    |
         Loggable --+
                    |
Jellyable --+       |
            |       |
 Serializable --+   |
                |   |
    Referenceable --+
                    |
                   AdminModel


I live in the admin client. I am a data model for any admin view implementing a UI to communicate with one manager. I send signals when things happen.

Manager calls on us through flumotion.manager.admin.AdminAvatar
Method Summary
  __init__(self, username, password)
  addView(self, view)
Add a view as a client to the model.
  callRemote(self, methodName, *args, **kwargs)
Call the given remote method on the manager-side AdminAvatar.
  callViews(self, methodName, *args, **kwargs)
Call a method on all views.
  checkElements(self, workerName, elements)
  cleanComponents(self)
twisted.internet.defer.Deferred componentCallRemote(self, componentState, methodName, *args, **kwargs)
Call the given method on the given component with the given args.
  connectToHost(self, host, port, use_insecure)
Connect to a host.
  get_components(self)
  getBundledFile(self, bundledPath)
Do everything needed to get the given bundled file.
  getComponents(self)
  getEntry(self, componentState, type)
Do everything needed to set up the entry point for the given component and type, including transferring and setting up bundles.
  getPlanetState(self)
  getProperty(self, componentState, element, property)
  getWorkerHeavenState(self)
  hasRemoteReference(self)
  isConnected(self)
  loadConfiguration(self, xml_string)
  reconnect(self)
  reload(self)
twisted.internet.defer.Deferred reloadComponent(self, componentState)
Tell the manager to reload code for a component.
deferred reloadManager(self)
Tell the manager to reload its code.
  remote_componentCall(self, componentState, methodName, *args, **kwargs)
  remote_log(self, category, type, message)
  remote_shutdown(self)
  removeView(self, view)
Remove a view as a client to the model.
  setProperty(self, componentState, element, property, value)
  setRemoteReference(self, remoteReference)
  stateAppend(self, state, key, value)
  stateRemove(self, state, key, value)
  stateSet(self, state, key, value)
twisted.internet.defer.Deferred workerCallRemote(self, workerName, methodName, *args, **kwargs)
Call the the given method on the given worker with the given args.
twisted.internet.defer.Deferred workerRun(self, workerName, moduleName, functionName, *args, **kwargs)
Run the given function and args on the given worker.
  _accessDeniedErrback(self, failure)
  _callRemoteCallback(self, result, methodName, componentName)
  _callRemoteErrback(self, failure, type, name, methodName)
  _connectedCallback(self, result)
  _connectionRefusedErrback(self, failure)
  _defaultErrback(self, failure)
  _getPlanetState(self, result)
  _getWorkerHeavenState(self, result)
  _loginCallback(self, result, password)
  _registerCachedPaths(self, paths)
  _remoteDisconnected(self, remoteReference)
  _setPlanetState(self, planetState)
  _setWorkerHeavenState(self, state)
  _writeConnection(self)
    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.
    Inherited from GObject
  __cmp__(x, y)
x.__cmp__(y) <==> cmp(x,y)
  __gobject_init__(...)
  __hash__(x)
x.__hash__() <==> hash(x)
  __new__(T, S, ...)
T.__new__(S, ...) -> a new object with type S, a subtype of T
  __repr__(x)
x.__repr__() <==> repr(x)
  chain(...)
  connect(...)
  connect_after(...)
  connect_object(...)
  connect_object_after(...)
  disconnect(...)
  emit(...)
  emit_stop_by_name(...)
  freeze_notify(...)
  get_data(...)
  get_property(...)
  handler_block(...)
  handler_disconnect(...)
  handler_is_connected(...)
  handler_unblock(...)
  notify(...)
  set_data(...)
  set_property(...)
  stop_emission(...)
  thaw_notify(...)
    Inherited from object
  __delattr__(...)
x.__delattr__('name') <==> del x.name
  __getattribute__(...)
x.__getattribute__('name') <==> x.name
  __reduce__(...)
helper for pickle
  __reduce_ex__(...)
helper for pickle
  __setattr__(...)
x.__setattr__('name', value) <==> x.name = value
  __str__(x)
x.__str__() <==> str(x)

Class Variable Summary
GType __gtype__ = <GType flumotion+admin+admin+AdminModel (165...
tuple __implements__ = (<class 'flumotion.common.interfaces.IA...
NoneType clientFactory = None                                                                  
NoneType host = None                                                                  
str logCategory: Implementors can provide a category to log their messages under.
NoneType passwd = None                                                                  
NoneType port = None                                                                  
NoneType remote = None                                                                  
str state = 'disconnected'
NoneType use_insecure = None                                                                  
NoneType user = None                                                                  
dict _components = {}
NoneType _unbundler = None                                                                  
list _views = []
NoneType _workerHeavenState = None                                                                  
    Inherited from Referenceable
NoneType perspective = None                                                                  
    Inherited from GObject
str __gdoc__ = 'Object GObject\n\nSignals from GObject:\n  n...
getset_descriptor __grefcount__ = <attribute '__grefcount__' of 'gobject.G...

Method Details

addView(self, view)

Add a view as a client to the model.

callRemote(self, methodName, *args, **kwargs)

Call the given remote method on the manager-side AdminAvatar.

callViews(self, methodName, *args, **kwargs)

Call a method on all views.

componentCallRemote(self, componentState, methodName, *args, **kwargs)

Call the given method on the given component with the given args.
Parameters:
componentState - component to call the method on
           (type=flumotion.common.planet.AdminComponentState)
methodName - name of method to call; serialized to a remote_methodName on the worker's medium
Returns:
twisted.internet.defer.Deferred

connectToHost(self, host, port, use_insecure=False)

Connect to a host.

getBundledFile(self, bundledPath)

Do everything needed to get the given bundled file.

Returns: a deferred returning the absolute path to a local copy of the given file.

getEntry(self, componentState, type)

Do everything needed to set up the entry point for the given component and type, including transferring and setting up bundles.

Caller is responsible for adding errbacks to the deferred.

Returns: a deferred returning (entryPath, filename, methodName)

getProperty(self, componentState, element, property)

Parameters:
componentState
           (type=flumotion.common.planet.AdminComponentState)

reloadComponent(self, componentState)

Tell the manager to reload code for a component.
Parameters:
componentState
           (type=flumotion.common.planet.AdminComponentState)
Returns:
twisted.internet.defer.Deferred

reloadManager(self)

Tell the manager to reload its code.
Returns:
deferred

removeView(self, view)

Remove a view as a client to the model.

setProperty(self, componentState, element, property, value)

Parameters:
componentState
           (type=flumotion.common.planet.AdminComponentState)

workerCallRemote(self, workerName, methodName, *args, **kwargs)

Call the the given method on the given worker with the given args.
Parameters:
workerName - name of the worker to call the method on
methodName - name of method to call; serialized to a remote_methodName on the worker's medium
Returns:
twisted.internet.defer.Deferred

workerRun(self, workerName, moduleName, functionName, *args, **kwargs)

Run the given function and args on the given worker. If the worker does not already have the module, or it is out of date, it will be retrieved from the manager.
Returns:
twisted.internet.defer.Deferred

Class Variable Details

__gtype__

Type:
GType
Value:
<GType flumotion+admin+admin+AdminModel (165769856)>                   

__implements__

Type:
tuple
Value:
(<class 'flumotion.common.interfaces.IAdminMedium'>,
 <class 'flumotion.twisted.flavors.IStateListener'>)                   

clientFactory

Type:
NoneType
Value:
None                                                                  

host

Type:
NoneType
Value:
None                                                                  

logCategory

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

passwd

Type:
NoneType
Value:
None                                                                  

port

Type:
NoneType
Value:
None                                                                  

remote

Type:
NoneType
Value:
None                                                                  

state

Type:
str
Value:
'disconnected'                                                         

use_insecure

Type:
NoneType
Value:
None                                                                  

user

Type:
NoneType
Value:
None                                                                  

_components

Type:
dict
Value:
{}                                                                     

_unbundler

Type:
NoneType
Value:
None                                                                  

_views

Type:
list
Value:
[]                                                                     

_workerHeavenState

Type:
NoneType
Value:
None                                                                  

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