daliuge
latest
Introduction
Installation Guide
Startup and Shutdown Guide
Basics
Architecture and Design
Operational concepts
Graph development
DALiuGE Component Developers Guide
DALiuGE Users guide
CLI User Guide
API Documentation
daliuge
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
A
AbstractDROP (class in dlg.drop)
add() (dlg.dropmake.scheduler.Partition method)
add_node() (dlg.dropmake.scheduler.KFamilyPartition method)
(dlg.dropmake.scheduler.Partition method)
add_pgt() (dlg.dropmake.pg_manager.PGManager method)
addConsumer() (dlg.drop.AbstractDROP method)
addGraphSpec() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
addLink() (in module dlg.graph_loader)
addProducer() (dlg.drop.AbstractDROP method)
addStreamingConsumer() (dlg.drop.AbstractDROP method)
allDropContents() (in module dlg.droputils)
AppDROP (class in dlg.apps.app_base)
AppDROPStates (class in dlg.ddap_protocol)
append() (dlg.drop.ListAsDict method)
args (dlg.rpc.ZeroRPCClient.request property)
autofill_environment_variables() (dlg.drop.AbstractDROP method)
AverageArraysApp (class in dlg.apps.simple)
B
BarrierAppDROP (class in dlg.apps.app_base)
BashShellApp (class in dlg.apps.bash_shell_app)
BashShellBase (class in dlg.apps.bash_shell_app)
BranchAppDrop (class in dlg.apps.branch)
breadFirstTraverse() (in module dlg.droputils)
browse_service() (in module dlg.utils)
buffer() (dlg.data.io.DataIO method)
build_dag_from_drops() (dlg.dropmake.scheduler.DAGUtil static method)
C
can_add() (dlg.dropmake.scheduler.Partition method)
cancel() (dlg.apps.app_base.AppDROP method)
(dlg.apps.dynlib.DynlibProcApp method)
(dlg.drop.AbstractDROP method)
cancelSession() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
CDlgApp (class in dlg.apps.dynlib)
CDlgInput (class in dlg.apps.dynlib)
CDlgOutput (class in dlg.apps.dynlib)
CDlgStreamingInput (class in dlg.apps.dynlib)
checksum (dlg.data.drops.data_base.DataDROP property)
checksumType (dlg.data.drops.data_base.DataDROP property)
ChecksumTypes (class in dlg.ddap_protocol)
close() (dlg.data.drops.data_base.DataDROP method)
(dlg.data.io.DataIO method)
CommentDrop (class in dlg.apps.constructs)
commit() (dlg.drop.AbstractDROP method)
completedrop() (dlg.drop.AbstractDROP method)
component_meta (dlg.apps.simple.NullBarrierApp attribute)
CompositeManager (class in dlg.manager.composite_manager)
CompositeManagerRestServer (class in dlg.manager.rest)
constrain_func() (dlg.dropmake.scheduler.PSOScheduler method)
consumers (dlg.drop.AbstractDROP property)
ContainerIpWaiter (class in dlg.apps.dockerapp)
CopyApp (class in dlg.apps.simple)
copyDropContents() (in module dlg.droputils)
CRCApp (class in dlg.apps.crc)
CRCStreamApp (class in dlg.apps.crc)
create() (dlg.apps.plasmaflight.PlasmaFlightClient method)
createDirIfMissing() (in module dlg.utils)
createSession() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
D
DAGUtil (class in dlg.dropmake.scheduler)
DataDROP (class in dlg.data.drops.data_base)
DataIO (class in dlg.data.io)
DataIslandManager (class in dlg.manager.composite_manager)
dataURL (dlg.data.drops.data_base.DataDROP property)
(dlg.data.drops.data_base.NullDROP property)
(dlg.data.drops.file.FileDROP property)
(dlg.data.drops.memory.InMemoryDROP property)
(dlg.data.drops.memory.SharedMemoryDROP property)
(dlg.data.drops.ngas.NgasDROP property)
(dlg.data.drops.plasma.PlasmaDROP property)
(dlg.data.drops.plasma.PlasmaFlightDROP property)
(dlg.data.drops.rdbms.RDBMSDrop property)
dataWritten() (dlg.apps.app_base.AppDROP method)
(dlg.apps.bash_shell_app.StreamingInputBashAppBase method)
(dlg.apps.crc.CRCStreamApp method)
(dlg.apps.dynlib.DynlibStreamApp method)
decrRefCount() (dlg.data.drops.data_base.DataDROP method)
delayed() (in module dlg.runtime)
delete() (dlg.data.drops.data_base.DataDROP method)
(dlg.data.drops.directorycontainer.DirectoryContainer method)
(dlg.data.drops.file.FileDROP method)
(dlg.data.io.DataIO method)
(dlg.data.io.NgasIO method)
deliver_event() (dlg.manager.node_manager.NodeManagerBase method)
deploySession() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
depthFirstTraverse() (in module dlg.droputils)
deregister_service() (in module dlg.utils)
DescriptionDrop (class in dlg.apps.constructs)
destroySession() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
DirectoryContainer (class in dlg.data.drops.directorycontainer)
dlg
module
dlg.apps.app_base
module
dlg.apps.archiving
module
dlg.apps.bash_shell_app
module
dlg.apps.branch
module
dlg.apps.constructs
module
dlg.apps.crc
module
dlg.apps.dockerapp
module
dlg.apps.dynlib
module
dlg.apps.mpi
module
dlg.apps.plasmaflight
module
dlg.apps.pyfunc
module
dlg.apps.scp
module
dlg.apps.simple
module
dlg.apps.socket_listener
module
dlg.data
module
dlg.data.drops.data_base
module
dlg.data.drops.directorycontainer
module
dlg.data.drops.file
module
dlg.data.drops.json_drop
module
dlg.data.drops.memory
module
dlg.data.drops.ngas
module
dlg.data.drops.plasma
module
dlg.data.drops.rdbms
module
dlg.data.drops.s3_drop
module
dlg.data.io
module
dlg.ddap_protocol
module
dlg.drop
module
dlg.dropmake
module
dlg.dropmake.pg_generator
module
dlg.dropmake.pg_manager
module
dlg.dropmake.scheduler
module
dlg.droputils
module
dlg.event
module
dlg.graph_loader
module
dlg.manager
module
dlg.manager.client
module
dlg.manager.composite_manager
module
dlg.manager.drop_manager
module
dlg.manager.node_manager
module
dlg.manager.rest
module
dlg.manager.session
module
dlg.rpc
module
dlg.utils
module
DockerApp (class in dlg.apps.dockerapp)
DockerPath (class in dlg.apps.dockerapp)
dropCompleted() (dlg.apps.app_base.AppDROP method)
(dlg.apps.app_base.InputFiredAppDROP method)
(dlg.apps.bash_shell_app.StreamingInputBashAppBase method)
(dlg.apps.crc.CRCStreamApp method)
(dlg.apps.dynlib.DynlibStreamApp method)
DROPFile (class in dlg.droputils)
DROPLinkType (class in dlg.ddap_protocol)
DROPManager (class in dlg.manager.drop_manager)
DropParser (class in dlg.apps.pyfunc)
DROPPhases (class in dlg.ddap_protocol)
DropProxy (class in dlg.rpc)
DROPRel (class in dlg.ddap_protocol)
dropReproComplete() (dlg.drop.AbstractDROP method)
DROPStates (class in dlg.ddap_protocol)
DROPWaiterCtx (class in dlg.droputils)
DynlibApp (class in dlg.apps.dynlib)
DynlibProcApp (class in dlg.apps.dynlib)
DynlibStreamApp (class in dlg.apps.dynlib)
E
efficiency (dlg.dropmake.scheduler.Schedule property)
EndDROP (class in dlg.data.drops.data_base)
endpoint (dlg.manager.node_manager.ZMQPubSubMixIn.subscription property)
ErrorIO (class in dlg.data.io)
ErrorStatusListener (class in dlg.manager.node_manager)
escapeQuotes() (in module dlg.utils)
Event (class in dlg.event)
EventFirer (class in dlg.event)
EventHandler (class in dlg.event)
EventMixIn (in module dlg.manager.node_manager)
EvtConsumer (class in dlg.droputils)
ExclusiveForceDrop (class in dlg.apps.constructs)
execStatus (dlg.apps.app_base.AppDROP property)
execute() (dlg.apps.app_base.InputFiredAppDROP method)
(dlg.apps.branch.BranchAppDrop method)
ExecutionMode (class in dlg.ddap_protocol)
executionMode (dlg.drop.AbstractDROP property)
ExistingProcess (class in dlg.utils)
exists() (dlg.apps.app_base.InputFiredAppDROP method)
(dlg.apps.plasmaflight.PlasmaFlightClient method)
(dlg.data.drops.data_base.DataDROP method)
(dlg.data.drops.directorycontainer.DirectoryContainer method)
(dlg.data.io.DataIO method)
(dlg.data.io.NgasLiteIO method)
ExternalStoreApp (class in dlg.apps.archiving)
F
FileDROP (class in dlg.data.drops.file)
FileIO (class in dlg.data.io)
fill() (in module dlg.dropmake.pg_generator)
finished_evt (dlg.manager.node_manager.ZMQPubSubMixIn.subscription property)
FinishSubprocess
fname_to_pipname() (in module dlg.utils)
G
ganttchart_matrix() (dlg.dropmake.scheduler.DAGUtil static method)
gather_inputs() (dlg.apps.simple.GenericNpyGatherApp method)
GatherDrop (class in dlg.apps.constructs)
generate_merkle_data() (dlg.drop.AbstractDROP method)
generate_recompute_data() (dlg.apps.dockerapp.DockerApp method)
(dlg.apps.dynlib.DynlibApp method)
(dlg.apps.dynlib.DynlibStreamApp method)
(dlg.apps.mpi.MPIApp method)
(dlg.apps.pyfunc.PyFuncApp method)
(dlg.drop.AbstractDROP method)
generate_repeat_data() (dlg.drop.AbstractDROP method)
generate_replicate_comp_data() (dlg.drop.AbstractDROP method)
generate_replicate_sci_data() (dlg.drop.AbstractDROP method)
generate_replicate_total_data() (dlg.drop.AbstractDROP method)
generate_reproduce_data() (dlg.data.drops.file.FileDROP method)
(dlg.data.drops.memory.InMemoryDROP method)
(dlg.data.drops.ngas.NgasDROP method)
(dlg.data.drops.rdbms.RDBMSDrop method)
(dlg.drop.AbstractDROP method)
generate_rerun_data() (dlg.drop.AbstractDROP method)
GenericGatherApp (class in dlg.apps.simple)
GenericNpyGatherApp (class in dlg.apps.simple)
GenericNpyScatterApp (class in dlg.apps.simple)
GenericScatterApp (class in dlg.apps.simple)
get_all_ipv4_addresses() (in module dlg.utils)
get_buffer() (dlg.apps.plasmaflight.PlasmaFlightClient method)
get_consumers_nodes() (dlg.drop.AbstractDROP method)
get_dir() (dlg.data.drops.data_base.PathBasedDrop method)
get_environment_variable() (dlg.drop.AbstractDROP method)
get_environment_variables() (dlg.drop.AbstractDROP method)
get_flight() (dlg.apps.plasmaflight.PlasmaFlightClient method)
get_from_subprocess() (in module dlg.apps.dynlib)
get_gantt_chart() (dlg.dropmake.pg_manager.PGManager method)
get_local_ip_addr() (in module dlg.utils)
get_longest_path() (dlg.dropmake.scheduler.DAGUtil static method)
get_max_antichains() (dlg.dropmake.scheduler.DAGUtil static method)
get_max_dop() (dlg.dropmake.scheduler.DAGUtil static method)
get_max_width() (dlg.dropmake.scheduler.DAGUtil static method)
get_pgt() (dlg.dropmake.pg_manager.PGManager method)
get_schedule_matrices() (dlg.dropmake.pg_manager.PGManager method)
get_symbol() (in module dlg.utils)
getDlgDir() (in module dlg.utils)
getDlgLogsDir() (in module dlg.utils)
getDlgPath() (in module dlg.utils)
getDlgPidDir() (in module dlg.utils)
getDlgVariable() (in module dlg.utils)
getDlgWorkDir() (in module dlg.utils)
getDownstreamObjects() (in module dlg.droputils)
getFileName() (dlg.data.io.FileIO method)
getGraph() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
getGraphReproData() (dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
getGraphSize() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
getGraphStatus() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
getInputArrays() (dlg.apps.simple.AverageArraysApp method)
getIO() (dlg.data.drops.data_base.DataDROP method)
(dlg.data.drops.data_base.NullDROP method)
(dlg.data.drops.file.FileDROP method)
(dlg.data.drops.memory.InMemoryDROP method)
(dlg.data.drops.memory.SharedMemoryDROP method)
(dlg.data.drops.ngas.NgasDROP method)
(dlg.data.drops.plasma.PlasmaDROP method)
(dlg.data.drops.plasma.PlasmaFlightDROP method)
(dlg.data.drops.rdbms.RDBMSDrop method)
getLeafNodes() (in module dlg.droputils)
getSessionIds() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
getSessionReproStatus() (dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
getSessionStatus() (dlg.manager.composite_manager.CompositeManager method)
(dlg.manager.drop_manager.DROPManager method)
(dlg.manager.node_manager.NodeManagerBase method)
getUpstreamObjects() (in module dlg.droputils)
GroupByDrop (class in dlg.apps.constructs)
H
handleEvent() (dlg.apps.app_base.AppDROP method)
(dlg.drop.AbstractDROP method)
handleInterest() (dlg.apps.dockerapp.DockerApp method)
(dlg.drop.AbstractDROP method)
has_path() (in module dlg.droputils)
HelloWorldApp (class in dlg.apps.simple)
I
incrRefCount() (dlg.data.drops.data_base.DataDROP method)
initialize() (dlg.apps.app_base.AppDROP method)
(dlg.apps.app_base.BarrierAppDROP method)
(dlg.apps.app_base.InputFiredAppDROP method)
(dlg.apps.archiving.NgasArchivingApp method)
(dlg.apps.bash_shell_app.StreamingInputBashAppBase method)
(dlg.apps.crc.CRCStreamApp method)
(dlg.apps.dockerapp.DockerApp method)
(dlg.apps.dynlib.DynlibApp method)
(dlg.apps.dynlib.DynlibProcApp method)
(dlg.apps.dynlib.DynlibStreamApp method)
(dlg.apps.mpi.MPIApp method)
(dlg.apps.pyfunc.PyFuncApp method)
(dlg.apps.scp.ScpApp method)
(dlg.apps.simple.AverageArraysApp method)
(dlg.apps.simple.GenericScatterApp method)
(dlg.apps.simple.ListAppendThrashingApp method)
(dlg.apps.simple.PickOne method)
(dlg.apps.simple.RandomArrayApp method)
(dlg.apps.simple.SimpleBranch method)
(dlg.apps.simple.SleepApp method)
(dlg.apps.socket_listener.SocketListenerApp method)
(dlg.data.drops.directorycontainer.DirectoryContainer method)
(dlg.data.drops.file.FileDROP method)
(dlg.data.drops.memory.InMemoryDROP method)
(dlg.data.drops.memory.SharedMemoryDROP method)
(dlg.data.drops.ngas.NgasDROP method)
(dlg.data.drops.plasma.PlasmaDROP method)
(dlg.data.drops.plasma.PlasmaFlightDROP method)
(dlg.data.drops.rdbms.RDBMSDrop method)
(dlg.drop.AbstractDROP method)
initialize_with_func_code() (dlg.apps.pyfunc.PyFuncApp method)
initializeSpecifics() (dlg.manager.rest.CompositeManagerRestServer method)
(dlg.manager.rest.ManagerRestServer method)
(dlg.manager.rest.MasterManagerRestServer method)
(dlg.manager.rest.NMRestServer method)
InMemoryDROP (class in dlg.data.drops.memory)
InputFiredAppDROP (class in dlg.apps.app_base)
inputs (dlg.apps.app_base.AppDROP property)
insert() (dlg.data.drops.rdbms.RDBMSDrop method)
InvalidLibrary
IOForURL() (in module dlg.data.io)
is_exception (dlg.rpc.ZeroRPCClient.response property)
is_time_critical() (dlg.dropmake.scheduler.MinNumPartsScheduler method)
(dlg.dropmake.scheduler.MySarkarScheduler method)
isabs() (in module dlg.utils)
isBeingRead() (dlg.data.drops.data_base.DataDROP method)
isCompleted() (dlg.drop.AbstractDROP method)
isOpened() (dlg.data.io.DataIO method)
K
KFamilyPartition (class in dlg.dropmake.scheduler)
kill() (dlg.utils.ExistingProcess method)
L
label_schedule() (dlg.dropmake.scheduler.DAGUtil static method)
lhs (dlg.ddap_protocol.DROPRel property)
list_flights() (dlg.apps.plasmaflight.PlasmaFlightClient method)
ListAppendThrashingApp (class in dlg.apps.simple)
ListAsDict (class in dlg.drop)
listify() (in module dlg.droputils)
load_and_init() (in module dlg.apps.dynlib)
load_npy() (in module dlg.droputils)
load_pickle() (in module dlg.droputils)
loadDropSpecs() (in module dlg.graph_loader)
LoopDrop (class in dlg.apps.constructs)
M
ManagerRestServer (class in dlg.manager.rest)
map_partitions() (dlg.dropmake.scheduler.Scheduler method)
MasterManager (class in dlg.manager.composite_manager)
MasterManagerRestServer (class in dlg.manager.rest)
MemoryIO (class in dlg.data.io)
merge_partitions() (dlg.dropmake.scheduler.Scheduler method)
method (dlg.rpc.ZeroRPCClient.request property)
metis_part() (dlg.dropmake.scheduler.DAGUtil static method)
MinNumPartsScheduler (class in dlg.dropmake.scheduler)
MKNDrop (class in dlg.apps.constructs)
module
dlg
dlg.apps.app_base
dlg.apps.archiving
dlg.apps.bash_shell_app
dlg.apps.branch
dlg.apps.constructs
dlg.apps.crc
dlg.apps.dockerapp
dlg.apps.dynlib
dlg.apps.mpi
dlg.apps.plasmaflight
dlg.apps.pyfunc
dlg.apps.scp
dlg.apps.simple
dlg.apps.socket_listener
dlg.data
dlg.data.drops.data_base
dlg.data.drops.directorycontainer
dlg.data.drops.file
dlg.data.drops.json_drop
dlg.data.drops.memory
dlg.data.drops.ngas
dlg.data.drops.plasma
dlg.data.drops.rdbms
dlg.data.drops.s3_drop
dlg.data.io
dlg.ddap_protocol
dlg.drop
dlg.dropmake
dlg.dropmake.pg_generator
dlg.dropmake.pg_manager
dlg.dropmake.scheduler
dlg.droputils
dlg.event
dlg.graph_loader
dlg.manager
dlg.manager.client
dlg.manager.composite_manager
dlg.manager.drop_manager
dlg.manager.node_manager
dlg.manager.rest
dlg.manager.session
dlg.rpc
dlg.utils
MPIApp (class in dlg.apps.mpi)
MySarkarScheduler (class in dlg.dropmake.scheduler)
N
NgasArchivingApp (class in dlg.apps.archiving)
NgasDROP (class in dlg.data.drops.ngas)
NgasIO (class in dlg.data.io)
NgasLiteIO (class in dlg.data.io)
NMRestServer (class in dlg.manager.rest)
NodeManager (class in dlg.manager.node_manager)
NodeManagerBase (class in dlg.manager.node_manager)
NullBarrierApp (class in dlg.apps.simple)
NullDROP (class in dlg.data.drops.data_base)
NullIO (class in dlg.data.io)
O
object_tracking() (in module dlg.utils)
objective_func() (dlg.dropmake.scheduler.PSOScheduler method)
oid (dlg.drop.AbstractDROP property)
open() (dlg.data.drops.data_base.DataDROP method)
(dlg.data.io.DataIO method)
OpenMode (class in dlg.data.io)
outputs (dlg.apps.app_base.AppDROP property)
override_cannot_add() (dlg.dropmake.scheduler.MinNumPartsScheduler method)
(dlg.dropmake.scheduler.MySarkarScheduler method)
P
parent (dlg.drop.AbstractDROP property)
Partition (class in dlg.dropmake.scheduler)
partition() (in module dlg.dropmake.pg_generator)
partition_dag() (dlg.dropmake.scheduler.MySarkarScheduler method)
(dlg.dropmake.scheduler.PSOScheduler method)
path (dlg.apps.dockerapp.DockerPath property)
PathBasedDrop (class in dlg.data.drops.data_base)
persist (dlg.drop.AbstractDROP property)
PGManager (class in dlg.dropmake.pg_manager)
PGUtil (class in dlg.dropmake.pg_manager)
phase (dlg.drop.AbstractDROP property)
PickOne (class in dlg.apps.simple)
PlasmaDROP (class in dlg.data.drops.plasma)
PlasmaFlightClient (class in dlg.apps.plasmaflight)
PlasmaFlightDROP (class in dlg.data.drops.plasma)
PlasmaFlightIO (class in dlg.data.io)
PlasmaIO (class in dlg.data.io)
poll() (dlg.utils.ExistingProcess method)
prepare_c_inputs() (in module dlg.apps.dynlib)
prepare_c_outputs() (in module dlg.apps.dynlib)
prepare_c_ranks() (in module dlg.apps.dynlib)
prepare_input_channel() (in module dlg.apps.bash_shell_app)
prepare_output_channel() (in module dlg.apps.bash_shell_app)
prepare_sql() (in module dlg.utils)
probe_max_dop() (dlg.dropmake.scheduler.Partition method)
producerFinished() (dlg.drop.AbstractDROP method)
producers (dlg.drop.AbstractDROP property)
prune_antichains() (dlg.dropmake.scheduler.DAGUtil static method)
PSOScheduler (class in dlg.dropmake.scheduler)
put_raw_buffer() (dlg.apps.plasmaflight.PlasmaFlightClient method)
PyFuncApp (class in dlg.apps.pyfunc)
PythonApp (class in dlg.apps.simple)
Q
queue (dlg.rpc.ZeroRPCClient.request property)
R
RandomArrayApp (class in dlg.apps.simple)
RDBMSDrop (class in dlg.data.drops.rdbms)
read() (dlg.data.drops.data_base.DataDROP method)
(dlg.data.io.DataIO method)
reduce_gather_inputs() (dlg.apps.simple.GenericNpyGatherApp method)
reduce_partitions() (dlg.dropmake.scheduler.MySarkarScheduler method)
register_service() (in module dlg.utils)
rel (dlg.ddap_protocol.DROPRel property)
remove() (dlg.dropmake.scheduler.Partition method)
replace_dataurl_placeholders() (in module dlg.droputils)
replace_path_placeholders() (in module dlg.droputils)
replicate() (dlg.manager.composite_manager.CompositeManager method)
resource_map() (in module dlg.dropmake.pg_generator)
rhs (dlg.ddap_protocol.DROPRel property)
RPCClient (in module dlg.rpc)
RPCClientBase (class in dlg.rpc)
RpcMixIn (class in dlg.manager.node_manager)
RPCObject (class in dlg.rpc)
RPCServer (in module dlg.rpc)
RPCServerBase (class in dlg.rpc)
run() (dlg.apps.app_base.InputFiredAppDROP method)
(dlg.apps.archiving.ExternalStoreApp method)
(dlg.apps.bash_shell_app.BashShellApp method)
(dlg.apps.bash_shell_app.StreamingOutputBashApp method)
(dlg.apps.crc.CRCApp method)
(dlg.apps.dockerapp.DockerApp method)
(dlg.apps.dynlib.DynlibApp method)
(dlg.apps.dynlib.DynlibProcApp method)
(dlg.apps.mpi.MPIApp method)
(dlg.apps.pyfunc.PyFuncApp method)
(dlg.apps.scp.ScpApp method)
(dlg.apps.simple.AverageArraysApp method)
(dlg.apps.simple.CopyApp method)
(dlg.apps.simple.GenericGatherApp method)
(dlg.apps.simple.GenericNpyGatherApp method)
(dlg.apps.simple.GenericNpyScatterApp method)
(dlg.apps.simple.GenericScatterApp method)
(dlg.apps.simple.HelloWorldApp method)
(dlg.apps.simple.ListAppendThrashingApp method)
(dlg.apps.simple.NullBarrierApp method)
(dlg.apps.simple.PickOne method)
(dlg.apps.simple.RandomArrayApp method)
(dlg.apps.simple.SimpleBranch method)
(dlg.apps.simple.SleepAndCopyApp method)
(dlg.apps.simple.SleepApp method)
(dlg.apps.simple.UrlRetrieveApp method)
(dlg.apps.socket_listener.SocketListenerApp method)
(in module dlg.apps.dynlib)
S
sanitize_link() (in module dlg.manager.composite_manager)
sanitize_paths() (dlg.data.drops.file.FileDROP method)
save_npy() (in module dlg.droputils)
save_pickle() (in module dlg.droputils)
ScatterDrop (class in dlg.apps.constructs)
Schedule (class in dlg.dropmake.scheduler)
schedule (dlg.dropmake.scheduler.Partition property)
schedule_matrix (dlg.dropmake.scheduler.Schedule property)
Scheduler (class in dlg.dropmake.scheduler)
SchedulerException
ScpApp (class in dlg.apps.scp)
seal() (dlg.apps.plasmaflight.PlasmaFlightClient method)
select() (dlg.data.drops.rdbms.RDBMSDrop method)
setCompleted() (dlg.data.drops.file.FileDROP method)
(dlg.data.drops.ngas.NgasDROP method)
(dlg.drop.AbstractDROP method)
setError() (dlg.drop.AbstractDROP method)
SharedMemoryDROP (class in dlg.data.drops.memory)
SharedMemoryIO (class in dlg.data.io)
SimpleBranch (class in dlg.apps.simple)
size (dlg.drop.AbstractDROP property)
size() (dlg.data.io.DataIO method)
skip() (dlg.apps.app_base.AppDROP method)
(dlg.drop.AbstractDROP method)
SleepAndCopyApp (class in dlg.apps.simple)
SleepApp (class in dlg.apps.simple)
SocketListenerApp (class in dlg.apps.socket_listener)
status (dlg.drop.AbstractDROP property)
store() (dlg.apps.archiving.ExternalStoreApp method)
(dlg.apps.archiving.NgasArchivingApp method)
streamingConsumers (dlg.drop.AbstractDROP property)
StreamingInputBashApp (class in dlg.apps.bash_shell_app)
StreamingInputBashAppBase (class in dlg.apps.bash_shell_app)
StreamingInputOutputBashApp (class in dlg.apps.bash_shell_app)
streamingInputs (dlg.apps.app_base.AppDROP property)
StreamingOutputBashApp (class in dlg.apps.bash_shell_app)
SubGraphDrop (class in dlg.apps.constructs)
subscribe() (dlg.event.EventFirer method)
T
terminate() (dlg.utils.ExistingProcess method)
timed_import() (in module dlg.utils)
to_externally_contactable_host() (in module dlg.utils)
U
uid (dlg.drop.AbstractDROP property)
unroll() (in module dlg.dropmake.pg_generator)
unsubscribe() (dlg.event.EventFirer method)
UrlRetrieveApp (class in dlg.apps.simple)
V
value (dlg.rpc.ZeroRPCClient.response property)
vstack_mat() (dlg.dropmake.pg_manager.PGUtil static method)
W
wait() (dlg.utils.ExistingProcess method)
workload (dlg.dropmake.scheduler.Schedule property)
write() (dlg.data.drops.data_base.DataDROP method)
(dlg.data.io.DataIO method)
writeData() (dlg.apps.simple.PickOne method)
Z
ZeroRPCClient (class in dlg.rpc)
ZeroRPCClient.request (class in dlg.rpc)
ZeroRPCClient.response (class in dlg.rpc)
ZeroRPCServer (class in dlg.rpc)
ZlibUncompressedStream (class in dlg.utils)
zmq_safe() (in module dlg.utils)
ZMQPubSubMixIn (class in dlg.manager.node_manager)
ZMQPubSubMixIn.subscription (class in dlg.manager.node_manager)
Read the Docs
v: latest
Versions
latest
stable
autodoc_fix
Downloads
pdf
html
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.