API Documentation
The following is an extract of the most important parts of the API of DALiuGE. For a complete reference please go to the source code.
- dlg
- dlg.ddap_protocol
- dlg.drop
AbstractDROP
AbstractDROP.addConsumer()
AbstractDROP.addProducer()
AbstractDROP.addStreamingConsumer()
AbstractDROP.autofill_environment_variables()
AbstractDROP.cancel()
AbstractDROP.commit()
AbstractDROP.completedrop()
AbstractDROP.consumers
AbstractDROP.dropReproComplete()
AbstractDROP.executionMode
AbstractDROP.generate_merkle_data()
AbstractDROP.generate_recompute_data()
AbstractDROP.generate_repeat_data()
AbstractDROP.generate_replicate_comp_data()
AbstractDROP.generate_replicate_sci_data()
AbstractDROP.generate_replicate_total_data()
AbstractDROP.generate_reproduce_data()
AbstractDROP.generate_rerun_data()
AbstractDROP.get_consumers_nodes()
AbstractDROP.get_environment_variable()
AbstractDROP.get_environment_variables()
AbstractDROP.handleEvent()
AbstractDROP.handleInterest()
AbstractDROP.initialize()
AbstractDROP.isCompleted()
AbstractDROP.oid
AbstractDROP.parent
AbstractDROP.persist
AbstractDROP.phase
AbstractDROP.producerFinished()
AbstractDROP.producers
AbstractDROP.setCompleted()
AbstractDROP.setError()
AbstractDROP.size
AbstractDROP.skip()
AbstractDROP.status
AbstractDROP.streamingConsumers
AbstractDROP.uid
ListAsDict
- dlg.droputils
- dlg.event
- dlg.graph_loader
- dlg.rpc
- dlg.runtime.delayed
- dlg.utils
ExistingProcess
ZlibUncompressedStream
browse_service()
createDirIfMissing()
deregister_service()
escapeQuotes()
fname_to_pipname()
getDlgDir()
getDlgLogsDir()
getDlgPath()
getDlgPidDir()
getDlgVariable()
getDlgWorkDir()
get_all_ipv4_addresses()
get_local_ip_addr()
get_symbol()
isabs()
object_tracking()
prepare_sql()
register_service()
timed_import()
to_externally_contactable_host()
truncateUidToKey()
zmq_safe()
- dlg.manager
- dlg.manager.session
- dlg.manager.drop_manager
DROPManager
DROPManager.addGraphSpec()
DROPManager.cancelSession()
DROPManager.createSession()
DROPManager.deploySession()
DROPManager.destroySession()
DROPManager.getGraph()
DROPManager.getGraphReproData()
DROPManager.getGraphSize()
DROPManager.getGraphStatus()
DROPManager.getSessionIds()
DROPManager.getSessionReproStatus()
DROPManager.getSessionStatus()
- dlg.manager.node_manager
ErrorStatusListener
EventMixIn
NodeManager
NodeManagerBase
NodeManagerBase.addGraphSpec()
NodeManagerBase.cancelSession()
NodeManagerBase.createSession()
NodeManagerBase.deliver_event()
NodeManagerBase.deploySession()
NodeManagerBase.destroySession()
NodeManagerBase.getGraph()
NodeManagerBase.getGraphReproData()
NodeManagerBase.getGraphSize()
NodeManagerBase.getGraphStatus()
NodeManagerBase.getSessionIds()
NodeManagerBase.getSessionReproStatus()
NodeManagerBase.getSessionStatus()
NodeManagerDropRunner
NodeManagerProcessDropRunner
NodeManagerThreadDropRunner
RpcMixIn
ZMQPubSubMixIn
- dlg.manager.composite_manager
CompositeManager
CompositeManager.addGraphSpec()
CompositeManager.cancelSession()
CompositeManager.createSession()
CompositeManager.deploySession()
CompositeManager.destroySession()
CompositeManager.getGraph()
CompositeManager.getGraphSize()
CompositeManager.getGraphStatus()
CompositeManager.getPastSessionIds()
CompositeManager.getSessionIds()
CompositeManager.getSessionStatus()
CompositeManager.get_node_from_json()
CompositeManager.replicate()
DataIslandManager
MasterManager
sanitize_link()
- dlg.manager.rest
CompositeManagerRestServer
CompositeManagerRestServer.addCMNode()
CompositeManagerRestServer.getCMNodes()
CompositeManagerRestServer.getCMStatus()
CompositeManagerRestServer.getNodeSessions()
CompositeManagerRestServer.getPastSessions()
CompositeManagerRestServer.initializeSpecifics()
CompositeManagerRestServer.pastSessions()
CompositeManagerRestServer.removeCMNode()
ManagerRestServer
MasterManagerRestServer
NMRestServer
- dlg.manager.client
- dlg.apps
- dlg.apps.app_base
- dlg.apps.bash_shell_app
- dlg.apps.branch
- dlg.apps.constructs
- dlg.apps.dynlib
- dlg.apps.mpi
- dlg.apps.pyfunc
- dlg.apps.dockerapp
- dlg.apps.simple
- dlg.apps.socket_listener
- dlg.apps.scp
- dlg.apps.archiving
- dlg.apps.crc
- dlg.data
- dlg.dropmake