Dragon
Installation
Introduction to Dragon
Use Cases
API Reference
Command Line Interface
Developer Guide
Benchmarks
FAQ
Dragon
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
X
|
Z
_
__contains__() (Connection.State class method)
(ConnectionOptions.CreationPolicy class method)
(DDict method)
(DDictItemsView method)
(DDictKeysView method)
(DDictValuesView method)
(DragonDataset method)
(FinalResponse method)
(InferenceRequest method)
(MemoryStrategy method)
(MsgType method)
(PipeOptions.CreationPolicy class method)
(Policy.Distribution class method)
(Policy.Placement class method)
(Policy.WaitMode class method)
(PriorityMultiMap method)
(ResponseModel method)
(SpanKind method)
(Store method)
(TaskStatus method)
(ToolCall method)
(ToolRequest method)
__delitem__() (DDict method)
(Store method)
__getitem__() (Array method)
(Connection.State class method)
(ConnectionOptions.CreationPolicy class method)
(DDict method)
(DragonArray method)
(DragonDataset method)
(DragonRawArray method)
(FinalResponse method)
(InferenceRequest method)
(MemoryStrategy method)
(MsgType method)
(PipeOptions.CreationPolicy class method)
(Policy.Distribution class method)
(Policy.Placement class method)
(Policy.WaitMode class method)
(ResponseModel method)
(SpanKind method)
(Store method)
(TaskStatus method)
(ToolCall method)
(ToolRequest method)
__init__() (AbnormalTermination method)
(AbnormalTerminationError method)
(AbsorbingChannel method)
(AcceleratorDescriptor method)
(AgentConfig method)
,
[1]
(AnalysisClient method)
(AnalysisGroupBase method)
(ApplyResult method)
,
[1]
(Array method)
(B64 method)
(Barrier method)
(BaseTool method)
(Batch method)
,
[1]
,
[2]
,
[3]
(BatchingConfig method)
,
[1]
(BatchItem method)
,
[1]
(BatchTopology method)
,
[1]
(BEHalted method)
(BEHaltOverlay method)
(BEIsUp method)
(BENodeIdxSH method)
(BEPingSH method)
(Breakpoint method)
(CapNProtoMsg method)
(CapNProtoResponseMsg method)
(Channel method)
(ChannelDescriptor method)
(ChannelOptions method)
(ChannelRecvH method)
(ChannelSendH method)
(ChannelSet method)
(CheckpointPersister method)
(CollectorDetectorGroup method)
(CollectorGroup method)
(CommunicationProtocol method)
(Connection method)
,
[1]
(ConnectionOptions method)
,
[1]
(ContextManager method)
,
[1]
(CPUWorker method)
,
[1]
(CuPyDataMover method)
(CuPyInputQueue method)
(CuPyOptimizedDataMover method)
(DAGOrchestrator method)
,
[1]
(DAOSCheckpointPersister method)
,
[1]
(DataMover method)
(DataMovers method)
(DDAdvance method)
(DDAdvanceResponse method)
(DDBatchPut method)
(DDBatchPutResponse method)
(DDBPut method)
(DDBPutResponse method)
(DDChkptAvail method)
(DDChkptAvailResponse method)
(DDClear method)
(DDClearResponse method)
(DDConnectToManager method)
(DDConnectToManagerResponse method)
(DDContains method)
(DDContainsResponse method)
(DDCreate method)
(DDCreateManagerResponse method)
(DDCreateResponse method)
(DDDeregisterClient method)
(DDDeregisterClientResponse method)
(DDDestroy method)
(DDDestroyManager method)
(DDDestroyManagerResponse method)
(DDDestroyResponse method)
(DDEmptyManagers method)
(DDEmptyManagersResponse method)
(DDFreeze method)
(DDFreezeResponse method)
(DDGet method)
(DDGetFreeze method)
(DDGetFreezeResponse method)
(DDGetManagers method)
(DDGetManagersResponse method)
(DDGetMetaData method)
(DDGetMetaDataResponse method)
(DDGetResponse method)
(DDict method)
,
[1]
(DDictAccessor method)
,
[1]
(DDictItemsView method)
,
[1]
(DDictKeyError method)
(DDictKeysView method)
,
[1]
(DDictManagerStats method)
,
[1]
(DDictValuesView method)
,
[1]
(DDItems method)
(DDItemsResponse method)
(DDIterator method)
(DDIteratorNext method)
(DDIteratorNextResponse method)
(DDIteratorResponse method)
(DDKeys method)
(DDKeysResponse method)
(DDLength method)
(DDLengthResponse method)
(DDManagerNewestChkptID method)
(DDManagerNewestChkptIDResponse method)
(DDManagerNodes method)
(DDManagerNodesResponse method)
(DDManagerSetState method)
(DDManagerSetStateResponse method)
(DDManagerStats method)
(DDManagerStatsResponse method)
(DDManagerSync method)
(DDManagerSyncResponse method)
(DDMarkDrainedManagers method)
(DDMarkDrainedManagersResponse method)
(DDPersist method)
(DDPersistChkpts method)
(DDPersistChkptsResponse method)
(DDPersistedChkptAvail method)
(DDPersistedChkptAvailResponse method)
(DDPersistResponse method)
(DDPop method)
(DDPopResponse method)
(DDPut method)
(DDPutResponse method)
(DDRandomManager method)
(DDRandomManagerResponse method)
(DDRegisterClient method)
(DDRegisterClientID method)
(DDRegisterClientIDResponse method)
(DDRegisterClientResponse method)
(DDRegisterManager method)
(DDRegisterManagerResponse method)
(DDRestore method)
(DDRestoreResponse method)
(DDSync method)
(DDSyncResponse method)
(DDUnFreeze method)
(DDUnFreezeResponse method)
(DDUnmarkDrainedManagers method)
(DDUnmarkDrainedManagersResponse method)
(DDValues method)
(DDValuesResponse method)
(Detector method)
(DictTracingProcessor method)
,
[1]
(DispatchHeader method)
,
[1]
(DragonAgent method)
,
[1]
(DragonArray method)
,
[1]
(DragonBarrier method)
,
[1]
(DragonBatchPoolExecutor method)
(DragonBoundedSemaphore method)
,
[1]
(DragonCondition method)
,
[1]
(DragonContext.AuthenticationError method)
(DragonContext.BufferTooShort method)
(DragonContext.ProcessError method)
(DragonContext.TimeoutError method)
(DragonDataset method)
,
[1]
(DragonEvent method)
,
[1]
(DragonException method)
(DragonFLIError method)
(DragonJoinableQueue method)
,
[1]
(DragonLock method)
,
[1]
(DragonLoggingError method)
(DragonMemoryError method)
(DragonMemoryTypeError method)
(DragonMPIExecutor method)
(DragonPool method)
,
[1]
(DragonPoolAllocationNotAvailable method)
(DragonPoolAttachFail method)
(DragonPoolCreateFail method)
(DragonPoolDetachFail method)
(DragonPoolError method)
(DragonPoolExecutor method)
(DragonProcess method)
,
[1]
(DragonQueue method)
,
[1]
(DragonQueueLLMProxy method)
,
[1]
(DragonQueueProtocol method)
,
[1]
(DragonRawArray method)
,
[1]
(DragonRawValue method)
,
[1]
(DragonRLock method)
,
[1]
(DragonSemaphore method)
,
[1]
(DragonSimpleQueue method)
,
[1]
(DragonValue method)
,
[1]
(DynamicBatcher method)
,
[1]
(DynamicWorkerConfig method)
,
[1]
(Event method)
(ExceptionlessAbort method)
(FENodeIdxBE method)
(FilterContextManager method)
,
[1]
(FinalResponse method)
,
[1]
(FLInterface method)
(FLIRecvH method)
(FLISendH method)
(Function method)
,
[1]
(FunctionTool method)
,
[1]
(GroupDescriptor method)
(GroupDescriptor.GroupMember method)
(GSChannelCreate method)
(GSChannelCreateResponse method)
(GSChannelDestroy method)
(GSChannelDestroyResponse method)
(GSChannelDetach method)
(GSChannelDetachResponse method)
(GSChannelGetRecvH method)
(GSChannelGetRecvHResponse method)
(GSChannelGetSendH method)
(GSChannelGetSendHResponse method)
(GSChannelJoin method)
(GSChannelJoinResponse method)
(GSChannelList method)
(GSChannelListResponse method)
(GSChannelQuery method)
(GSChannelQueryResponse method)
(GSChannelRelease method)
(GSDumpState method)
(GSGroupAddTo method)
(GSGroupAddToResponse method)
(GSGroupCreate method)
(GSGroupCreateAddTo method)
(GSGroupCreateAddToResponse method)
(GSGroupCreateResponse method)
(GSGroupDestroy method)
(GSGroupDestroyPMIx method)
(GSGroupDestroyPMIxResponse method)
(GSGroupDestroyRemoveFrom method)
(GSGroupDestroyRemoveFromResponse method)
(GSGroupDestroyResponse method)
(GSGroupKill method)
(GSGroupKillResponse method)
(GSGroupList method)
(GSGroupListResponse method)
(GSGroupQuery method)
(GSGroupQueryResponse method)
(GSGroupRemoveFrom method)
(GSGroupRemoveFromResponse method)
(GSHalted method)
(GSHeadExit method)
(GSIsUp method)
(GSNodeList method)
(GSNodeListResponse method)
(GSNodeQuery method)
(GSNodeQueryAll method)
(GSNodeQueryAllResponse method)
(GSNodeQueryResponse method)
(GSNodeQueryTotalCPUCount method)
(GSNodeQueryTotalCPUCountResponse method)
(GSPingProc method)
(GSPingSH method)
(GSPoolCreate method)
(GSPoolCreateResponse method)
(GSPoolDestroy method)
(GSPoolDestroyResponse method)
(GSPoolList method)
(GSPoolListResponse method)
(GSPoolQuery method)
(GSPoolQueryResponse method)
(GSProcessCreate method)
(GSProcessCreateResponse method)
(GSProcessJoin method)
(GSProcessJoinList method)
(GSProcessJoinListResponse method)
(GSProcessJoinResponse method)
(GSProcessKill method)
(GSProcessKillResponse method)
(GSProcessList method)
(GSProcessListResponse method)
(GSProcessQuery method)
(GSProcessQueryResponse method)
(GSRebootRuntime method)
(GSRebootRuntimeResponse method)
(GSStarted method)
(GSTeardown method)
(GSUnexpected method)
(GuardrailsConfig method)
,
[1]
(GuardrailsProcessor method)
,
[1]
(HaltLoggingInfra method)
(HaltOverlay method)
(HardwareConfig method)
,
[1]
(HitlTcpBridge method)
,
[1]
(HumanApprovalRequest method)
,
[1]
(HumanApprovalResponse method)
,
[1]
(Inference method)
,
[1]
(InferenceConfig method)
,
[1]
(InferenceRequest method)
(InferenceWorker method)
,
[1]
(InfraMsg method)
(Job method)
,
[1]
(LABroadcast method)
(LAChannelsInfo method)
(LADumpState method)
(LAExit method)
(LAHaltOverlay method)
(LAPassThruBF method)
(LAPassThruFB method)
(LAProcessDict method)
(LAProcessDictResponse method)
(LAServerMode method)
(LAServerModeExit method)
(LaunchParameters method)
(LLMInferenceEngine method)
,
[1]
(LLMProxy method)
(Lock method)
(LogFlushed method)
(LoggingMsg method)
(LoggingMsgList method)
(LSDestroyPMIx method)
(LSDestroyPMIxResponse method)
(MakeTask method)
,
[1]
(Many2ManyReadingChannelFile method)
(Many2ManyWritingChannelFile method)
(MapResult method)
,
[1]
(MCPServerClient method)
,
[1]
(MCPServerConfig method)
,
[1]
(MemoryConfig method)
,
[1]
(MemoryPool method)
(MemoryStrategy method)
,
[1]
(Message method)
,
[1]
(MetricCollector method)
(MetricsConsolidator method)
,
[1]
(ModelConfig method)
,
[1]
(MPIApp method)
(MsgType method)
,
[1]
(NewlineStreamWrapper method)
(Node method)
(NodeDescriptor method)
(NULLCheckpointPersister method)
,
[1]
(NumPyDataMover method)
(NumPyOptimizedInputQueue method)
(OrchestratorConfig method)
,
[1]
(OutputQueue method)
(OverlayHalted method)
(OverlayPingBE method)
(OverlayPingLA method)
(Peer2PeerReadingChannelFile method)
(Peer2PeerWritingChannelFile method)
(PGAddProcessTemplates method)
(PGClientResponse method)
(PGClose method)
(PGJoin method)
(PGPuids method)
(PGRegisterClient method)
(PGSetProperties method)
(PGSignal method)
(PGStart method)
(PGState method)
(PGStop method)
(PGStopRestart method)
(PGUnregisterClient method)
(PickleReadAdapter method)
(PickleWriteAdapter method)
(Pipeline method)
,
[1]
(PipelineNode method)
,
[1]
(PipeOptions method)
,
[1]
(PMIGroupInfo method)
(PMIProcessInfo method)
(PMIxFenceMsg method)
(PMOD method)
(PMODError method)
(Policy method)
,
[1]
,
[2]
(Policy.Distribution method)
(Policy.Placement method)
(Policy.WaitMode method)
(PollResult method)
(Pool method)
,
[1]
(PoolDescriptor method)
(PoolOptions method)
(Popen method)
(PosixCheckpointPersister method)
,
[1]
(PriorityMultiMap method)
(Process method)
(ProcessDescriptor method)
(ProcessGroup method)
,
[1]
(ProcessOptions method)
(ProcessTemplate method)
(PromptGuard method)
,
[1]
(Proxy method)
,
[1]
(PseudoStructure method)
(Queue method)
(RankInfo method)
(ReadWorker method)
,
[1]
(RebootRuntime method)
(ResponseModel method)
,
[1]
(ResponseQueuePool method)
,
[1]
(RuntimeDesc method)
(Semaphore method)
(SHAllocBlock method)
(SHAllocBlockResponse method)
(SHAllocMsg method)
(SHAllocMsgResponse method)
(SHChannelCreate method)
(SHChannelCreateResponse method)
(SHChannelDestroy method)
(SHChannelDestroyResponse method)
(SHChannelsUp method)
(SHCreateProcessLocalChannel method)
(SHCreateProcessLocalChannelResponse method)
(SHCreateProcessLocalPool method)
(SHCreateProcessLocalPoolResponse method)
(SHDeregisterProcessLocalPool method)
(SHDeregisterProcessLocalPoolResponse method)
(SHDestroyProcessLocalChannel method)
(SHDestroyProcessLocalChannelResponse method)
(SHDumpState method)
(SHExecMemRequest method)
(SHExecMemResponse method)
(SHFwdInput method)
(SHFwdInputErr method)
(SHFwdOutput method)
(SHGetKV method)
(SHGetKVL method)
(SHGetKVLResponse method)
(SHGetKVResponse method)
(SHHaltBE method)
(SHHalted method)
(SHHaltTA method)
(SHLockChannel method)
(SHLockChannelResponse method)
(SHMultiProcessCreate method)
(SHMultiProcessCreateResponse method)
(SHMultiProcessKill method)
(SHMultiProcessKillResponse method)
(SHPingBE method)
(SHPingGS method)
(SHPoolCreate method)
(SHPoolCreateResponse method)
(SHPoolDestroy method)
(SHPoolDestroyResponse method)
(SHPopKVL method)
(SHPopKVLResponse method)
(SHProcessCreate method)
(SHProcessCreateResponse method)
(SHProcessExit method)
(SHProcessKill method)
(SHProcessKillResponse method)
(SHPushKVL method)
(SHPushKVLResponse method)
(SHRegisterProcessLocalPool method)
(SHRegisterProcessLocalPoolResponse method)
(SHSetKV method)
(SHSetKVResponse method)
(SHTeardown method)
(SlowGPUDetector method)
(Span method)
,
[1]
(SpanKind method)
,
[1]
(Store method)
,
[1]
(SubAgent method)
,
[1]
(SubmitAfterCloseError method)
(System method)
(TAHalted method)
(TAPingSH method)
(Task method)
,
[1]
(TaskResult method)
,
[1]
(TaskStatus method)
,
[1]
(TAUp method)
(TAUpdateNodes method)
(Telemetry method)
(TimeKeeper method)
(TimeKeeper.Recorder method)
(ToolCall method)
,
[1]
(ToolDispatcher method)
,
[1]
(ToolExecutionError method)
(ToolRegistry method)
,
[1]
(ToolRequest method)
,
[1]
(Trace method)
,
[1]
(TraceTcpBridge method)
,
[1]
(TracingProcessor method)
(TypedParm method)
(UserHaltOOB method)
(Value method)
(WrappedResult method)
,
[1]
(XNumPy2DPickler method)
(XScalarPickler method)
(XStringPickler method)
__len__() (Array method)
(Connection.State class method)
(ConnectionOptions.CreationPolicy class method)
(DDict method)
(DDictItemsView method)
(DDictKeysView method)
(DDictValuesView method)
(DragonArray method)
(DragonDataset method)
(DragonRawArray method)
(FinalResponse method)
(InferenceRequest method)
(MemoryStrategy method)
(MsgType method)
(PipeOptions.CreationPolicy class method)
(Policy.Distribution class method)
(Policy.Placement class method)
(Policy.WaitMode class method)
(ResponseModel method)
(SpanKind method)
(Store method)
(TaskStatus method)
(ToolCall method)
(ToolRegistry method)
(ToolRequest method)
__setitem__() (Array method)
(DDict method)
(DragonArray method)
(DragonRawArray method)
(Store method)
A
ABNORMAL_TERMINATION (MessageTypes attribute)
AbnormalTermination (class in dragon.infrastructure.messages)
AbnormalTerminationError
abort() (Barrier method)
(DragonBarrier method)
AbsorbingChannel (class in dragon.infrastructure.util)
AcceleratorDescriptor (class in dragon.infrastructure.gpu_desc)
AccEnvStr (class in dragon.infrastructure.gpu_desc)
AccVendor (class in dragon.infrastructure.gpu_desc)
acquire() (Array method)
(DragonArray method)
(DragonBoundedSemaphore method)
(DragonLock method)
(DragonRawArray method)
(DragonRLock method)
(DragonSemaphore method)
(DragonValue method)
(Lock method)
(ResponseQueuePool method)
(Semaphore method)
ACTIVE (ChannelDescriptor.State attribute)
(GroupDescriptor.State attribute)
(NodeDescriptor.State attribute)
(PoolDescriptor.State attribute)
(ProcessDescriptor.State attribute)
active_children() (DragonContext static method)
add() (TimeKeeper method)
add_data() (Telemetry method)
add_elapsed() (TimeKeeper method)
add_item() (DynamicBatcher method)
add_note() (DragonContext.AuthenticationError method)
(DragonContext.BufferTooShort method)
(DragonContext.ProcessError method)
(DragonContext.TimeoutError method)
add_process() (ProcessGroup method)
add_to() (in module dragon.globalservices.group)
address (HitlTcpBridge property)
(TraceTcpBridge property)
advance() (CheckpointPersister method)
(DAOSCheckpointPersister method)
(DDict method)
(NULLCheckpointPersister method)
(PosixCheckpointPersister method)
(Store method)
advance_raw_header() (Peer2PeerReadingChannelFile method)
agent_id (AgentConfig attribute)
(HumanApprovalRequest attribute)
(PipelineNode attribute)
(TaskResult attribute)
AgentConfig (class in dragon.ai.agent.config.agent_config)
AgentError
AgentLoopError
AgentObservabilityWarning
agents (OrchestratorConfig attribute)
alias (MCPServerConfig attribute)
all_parm_names() (LaunchParameters class method)
alloc() (MemoryPool method)
alloc_blocking() (MemoryPool method)
alloc_from_id() (MemoryPool method)
alloc_id() (MemoryAllocations method)
alloc_type() (MemoryAllocations method)
allocation_exists() (MemoryPool method)
AllocType (class in dragon.managed_memory)
allow_connection_pickling() (DragonContext method)
allowRestart (DDDestroy property)
(DDDestroyManager property)
ALREADY (GroupDescriptor.GroupMember.Errors attribute)
(GSChannelCreateResponse.Errors attribute)
(GSGroupKillResponse.Errors attribute)
(GSPoolCreateResponse.Errors attribute)
(GSProcessCreateResponse.Errors attribute)
(SHLockChannelResponse.Errors attribute)
AMD (AccEnvStr attribute)
(AccVendor attribute)
AnalysisClient (class in dragon.telemetry.analysis)
AnalysisGroupBase (class in dragon.telemetry.analysis)
analyze_data() (CollectorDetectorGroup static method)
(Detector static method)
(SlowGPUDetector static method)
ANYWHERE (Policy.Placement attribute)
apply() (DragonPool method)
apply_async() (DragonPool method)
(Pool method)
ApplyResult (class in dragon.native.pool)
approval_filter (AgentConfig attribute)
approved (HumanApprovalResponse attribute)
ArgMode (class in dragon.infrastructure.process_desc)
args (DDCreate property)
(Popen property)
(ToolCall attribute)
Array (class in dragon.native.array)
Array() (DragonContext method)
as_integer_ratio() (Policy.Distribution method)
(Policy.Placement method)
(Policy.WaitMode method)
AsyncResult (in module dragon.native.pool)
attach() (Channel class method)
(DDict class method)
(DragonLock static method)
(FIFOLock static method)
(FLInterface class method)
(GreedyLock static method)
(in module dragon.workflows.runtime)
(MemoryAlloc class method)
(MemoryPool class method)
(PriorityHeap static method)
(Queue class method)
(Store class method)
attach_default() (MemoryPool class method)
ATTACH_FAIL (DragonPoolError.Errors attribute)
ATTACHED (Connection.State attribute)
attributes (Span attribute)
authkey (DragonProcess property)
available (DDChkptAvailResponse property)
(DDPersistedChkptAvailResponse property)
B
B64 (class in dragon.utils)
b64decode() (in module dragon.utils)
b64encode() (in module dragon.utils)
backend (PMIGroupInfo attribute)
Barrier (class in dragon.native.barrier)
Barrier() (DragonContext method)
barrier_count (Channel attribute)
BASE_BE_CUID (in module dragon.infrastructure.facts)
BASE_BE_FE_CUID (in module dragon.infrastructure.facts)
BASE_BE_GW_CUID (in module dragon.infrastructure.facts)
BASE_BE_LOCAL_CUID (in module dragon.infrastructure.facts)
BASE_GW_CUID (in module dragon.infrastructure.facts)
BASE_LOG_CUID (in module dragon.infrastructure.facts)
BASE_PMOD_LAUNCH_CUID (in module dragon.infrastructure.facts)
BASE_TA_CUID (in module dragon.infrastructure.facts)
BASE_USER_MANAGED_CUID (in module dragon.infrastructure.facts)
BaseTool (class in dragon.ai.agent.tools.base)
Batch (class in dragon.ai.inference.batching)
(class in dragon.workflows.batch)
batch (DDBPut property)
batch_type (BatchingConfig attribute)
batch_wait_seconds (BatchingConfig attribute)
batching (InferenceConfig attribute)
BatchingConfig (class in dragon.ai.inference.config)
BatchItem (class in dragon.ai.inference.batching)
BatchTopology (class in dragon.workflows.batch)
be_fe_cuid_from_hostid() (in module dragon.infrastructure.facts)
be_gw_cuid_from_hostid() (in module dragon.infrastructure.facts)
BE_HALT_OVERLAY (MessageTypes attribute)
BE_HALTED (MessageTypes attribute)
BE_IS_UP (MessageTypes attribute)
be_local_cuid_in_from_hostid() (in module dragon.infrastructure.facts)
be_local_cuid_out_from_hostid() (in module dragon.infrastructure.facts)
BE_NODE_IDX_SH (MessageTypes attribute)
BE_PING_SH (MessageTypes attribute)
be_pool_muid_from_hostid() (in module dragon.infrastructure.facts)
BEHalted (class in dragon.infrastructure.messages)
BEHaltOverlay (class in dragon.infrastructure.messages)
BEIsUp (class in dragon.infrastructure.messages)
BENodeIdxSH (class in dragon.infrastructure.messages)
BEPingSH (class in dragon.infrastructure.messages)
bget() (DDict method)
(Store method)
bit_count() (Policy.Distribution method)
(Policy.Placement method)
(Policy.WaitMode method)
bit_length() (Policy.Distribution method)
(Policy.Placement method)
(Policy.WaitMode method)
BLOCK (Policy.Distribution attribute)
block_size (Channel attribute)
blocked_receivers (Channel attribute)
blockSize (SHCreateProcessLocalChannel property)
BOOTSTRAP (AllocType attribute)
BoundedSemaphore() (DragonContext method)
bput() (DDict method)
(Store method)
Breakpoint (class in dragon.infrastructure.messages)
BREAKPOINT (MessageTypes attribute)
broadcast (DDClear property)
(DDLength property)
(DDManagerNewestChkptID property)
(DDManagerStats property)
(DDSync property)
broken (Barrier property)
(DragonBarrier property)
broken_barrier (Channel attribute)
BrokenBarrierError
bufferedRespFLI (DDRegisterClient property)
(DDRegisterClientID property)
builder() (CapNProtoMsg method)
(CapNProtoResponseMsg method)
(DDAdvance method)
(DDAdvanceResponse method)
(DDBatchPut method)
(DDBatchPutResponse method)
(DDBPut method)
(DDBPutResponse method)
(DDChkptAvail method)
(DDChkptAvailResponse method)
(DDClear method)
(DDConnectToManager method)
(DDConnectToManagerResponse method)
(DDContains method)
(DDCreate method)
(DDCreateManagerResponse method)
(DDDeregisterClient method)
(DDDestroy method)
(DDDestroyManager method)
(DDEmptyManagers method)
(DDEmptyManagersResponse method)
(DDFreeze method)
(DDGet method)
(DDGetFreeze method)
(DDGetFreezeResponse method)
(DDGetManagers method)
(DDGetManagersResponse method)
(DDGetMetaData method)
(DDGetMetaDataResponse method)
(DDGetResponse method)
(DDItems method)
(DDItemsResponse method)
(DDIterator method)
(DDIteratorNext method)
(DDIteratorResponse method)
(DDKeys method)
(DDLength method)
(DDLengthResponse method)
(DDManagerNewestChkptID method)
(DDManagerNewestChkptIDResponse method)
(DDManagerNodes method)
(DDManagerNodesResponse method)
(DDManagerSetState method)
(DDManagerStats method)
(DDManagerStatsResponse method)
(DDManagerSync method)
(DDMarkDrainedManagers method)
(DDPersist method)
(DDPersistChkpts method)
(DDPersistChkptsResponse method)
(DDPersistedChkptAvail method)
(DDPersistedChkptAvailResponse method)
(DDPop method)
(DDPopResponse method)
(DDPut method)
(DDRandomManager method)
(DDRandomManagerResponse method)
(DDRegisterClient method)
(DDRegisterClientID method)
(DDRegisterClientResponse method)
(DDRegisterManager method)
(DDRegisterManagerResponse method)
(DDRestore method)
(DDSync method)
(DDUnFreeze method)
(DDUnmarkDrainedManagers method)
(DDValues method)
(DDValuesResponse method)
(PMIxFenceMsg method)
(SHCreateProcessLocalChannel method)
(SHCreateProcessLocalChannelResponse method)
(SHCreateProcessLocalPool method)
(SHCreateProcessLocalPoolResponse method)
(SHDeregisterProcessLocalPool method)
(SHDestroyProcessLocalChannel method)
(SHGetKV method)
(SHGetKVL method)
(SHGetKVLResponse method)
(SHGetKVResponse method)
(SHPopKVL method)
(SHPushKVL method)
(SHRegisterProcessLocalPool method)
(SHSetKV method)
BUSY (GSChannelDestroyResponse.Errors attribute)
bytes_memview() (Message method)
BYTES_TO_OBJ (ValueConversion attribute)
bytes_to_str() (B64 class method)
C
call_tool() (MCPServerClient method)
camel_case_msg_name() (in module dragon.infrastructure.messages)
cancel() (Function method)
(Job method)
(Task method)
cancel_join_thread() (DragonJoinableQueue method)
(DragonQueue method)
CANT (GSChannelGetRecvHResponse.Errors attribute)
(GSChannelGetSendHResponse.Errors attribute)
capacity (Channel attribute)
(SHCreateProcessLocalChannel property)
capitalize() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
capnp_name (CapNProtoMsg property)
CapNProtoMsg (class in dragon.infrastructure.messages)
CapNProtoResponseMsg (class in dragon.infrastructure.messages)
casefold() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
cast_return_when_mode() (in module dragon.infrastructure.parameters)
cast_wait_mode() (in module dragon.infrastructure.parameters)
center() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
Channel
CHANNEL (AllocType attribute)
Channel (class in dragon.channels)
CHANNEL_BUFFER (AllocType attribute)
CHANNEL_CLEANUP (EventType attribute)
ChannelAdapterMsgTypes (class in dragon.channels)
ChannelBarrierBroken
ChannelBarrierReady
ChannelDescriptor (class in dragon.infrastructure.channel_desc)
ChannelDescriptor.State (class in dragon.infrastructure.channel_desc)
ChannelDestroyed
ChannelEmpty
ChannelError
,
[1]
ChannelFlags (class in dragon.channels)
ChannelFull
ChannelHandleNotOpenError
ChannelOptions (class in dragon.infrastructure.channel_desc)
ChannelRecvError
ChannelRecvH (class in dragon.channels)
ChannelRecvTimeout
ChannelRemoteOperationNotSupported
ChannelSendError
ChannelSendH (class in dragon.channels)
ChannelSendTimeout
ChannelSet (class in dragon.channels)
ChannelSetError
ChannelSetTimeout
ChannelTimeout
ChannelValueError
chat() (DragonQueueLLMProxy method)
(LLMProxy method)
(ToolDispatcher method)
chat_template_formatter() (in module dragon.ai.inference.llm_engine)
check_base64() (in module dragon.infrastructure.parameters)
check_header() (Peer2PeerReadingChannelFile method)
check_mode() (in module dragon.infrastructure.parameters)
check_pct() (in module dragon.infrastructure.parameters)
check_pool() (in module dragon.infrastructure.parameters)
check_prompts() (GuardrailsProcessor method)
checkpoint() (DDict method)
(Store method)
checkpoint_id (DDict property)
(Store property)
CheckpointPersister (class in dragon.data.ddict)
checkpoints() (CheckpointPersister method)
(DAOSCheckpointPersister method)
(NULLCheckpointPersister method)
(PosixCheckpointPersister method)
children() (Process method)
chkptID (DDAdvanceResponse property)
(DDBatchPut property)
(DDBPut property)
(DDChkptAvail property)
(DDClear property)
(DDContains property)
(DDGet property)
(DDItems property)
(DDIterator property)
(DDKeys property)
(DDLength property)
(DDManagerNewestChkptIDResponse property)
(DDPersist property)
(DDPersistedChkptAvail property)
(DDPop property)
(DDPut property)
(DDRestore property)
(DDValues property)
chkptIDs (DDPersistChkptsResponse property)
cleanup() (CuPyDataMover method)
(CuPyOptimizedDataMover method)
(in module dragon.globalservices.process)
(NumPyDataMover method)
cleanup_metadata() (CheckpointPersister class method)
(DAOSCheckpointPersister class method)
(NULLCheckpointPersister class method)
(PosixCheckpointPersister class method)
cleanup_pmix_resources() (in module dragon.globalservices.group)
clear() (DDict method)
(DragonEvent method)
(Event method)
(MemoryAlloc method)
(Store method)
clear_payload() (Message method)
clear_results() (Batch method)
Client() (DragonContext method)
clientID (DDAdvance property)
(DDBatchPut property)
(DDBPut property)
(DDClear property)
(DDConnectToManager property)
(DDContains property)
(DDDeregisterClient property)
(DDDestroy property)
(DDGet property)
(DDGetFreeze property)
(DDItems property)
(DDIterator property)
(DDIteratorNext property)
(DDKeys property)
(DDLength property)
(DDPersistChkpts property)
(DDPop property)
(DDPut property)
(DDRegisterClientID property)
(DDRegisterClientResponse property)
(DDRestore property)
(DDValues property)
clientid (Message attribute)
clone() (DDict method)
(MemoryAlloc method)
(Store method)
close() (Batch method)
(ChannelRecvH method)
(ChannelSendH method)
(Connection method)
(DragonJoinableQueue method)
(DragonPool method)
(DragonProcess method)
(DragonQueue method)
(DragonSimpleQueue method)
(FLIRecvH method)
(FLISendH method)
(Many2ManyReadingChannelFile method)
(Many2ManyWritingChannelFile method)
(MCPServerClient method)
(NewlineStreamWrapper method)
(Peer2PeerReadingChannelFile method)
(Peer2PeerWritingChannelFile method)
(Pool method)
(ProcessGroup method)
(Queue method)
(Store method)
close_mcp() (ToolDispatcher method)
closed (Connection property)
CLOSED (Connection.State attribute)
closed (Queue property)
collect() (MetricCollector method)
CollectiveGroup() (in module dragon.ai.collective_group)
collector_test() (CollectorDetectorGroup static method)
(CollectorGroup static method)
(SlowGPUDetector static method)
CollectorDetectorGroup (class in dragon.telemetry.analysis)
CollectorGroup (class in dragon.telemetry.analysis)
communicate() (Popen method)
CommunicationProtocol (class in dragon.ai.agent.communication.protocol)
compare_dev_shm() (in module dragon.infrastructure.util)
completion_event (DispatchHeader attribute)
CompletionSignalError
Condition() (DragonContext method)
conjugate() (Policy.Distribution method)
(Policy.Placement method)
(Policy.WaitMode method)
connect() (AnalysisClient method)
connect_mcp() (ToolDispatcher method)
connect_to_infrastructure() (in module dragon.globalservices.api_setup)
Connection (class in dragon.infrastructure.connection)
Connection.State (class in dragon.infrastructure.connection)
ConnectionOptions (class in dragon.infrastructure.connection)
ConnectionOptions.CreationPolicy (class in dragon.infrastructure.connection)
construct_input_output_queues() (CuPyDataMover method)
(CuPyOptimizedDataMover method)
(DataMover method)
(NumPyDataMover method)
(NumPyOptimizedDataMover method)
context (HumanApprovalRequest attribute)
ContextManager (class in dragon.ai.agent.memory.context_manager)
continue_final_message (InferenceRequest attribute)
continue_final_message_list (Batch property)
control_port (PMIGroupInfo attribute)
copy() (DDict method)
(MemoryAlloc method)
(Store method)
copy_on_send (ChannelSendH attribute)
(OwnershipOnSend attribute)
count() (DragonLock method)
(DragonRLock method)
(InferenceRequest method)
(Lock method)
(MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
cpu_affinity (Policy attribute)
cpu_count() (DragonContext method)
(in module dragon.native.machine)
cpus (Node property)
CPUWorker (class in dragon.ai.inference.cpu_worker_utils)
CRAY (PMIBackend attribute)
create() (in module dragon.globalservices.channel)
(in module dragon.globalservices.group)
(in module dragon.globalservices.pool)
(in module dragon.globalservices.process)
(PriorityHeap static method)
create_add_to() (in module dragon.globalservices.group)
create_alloc() (Message static method)
create_buffered() (FLInterface class method)
create_cpu_device_workers_by_node() (Inference method)
create_empty() (Message static method)
CREATE_FAIL (DragonPoolError.Errors attribute)
create_fd() (FLIRecvH method)
(FLISendH method)
create_from_mem() (Message static method)
create_inf_worker() (CPUWorker method)
create_sub_agent() (in module dragon.ai.agent.core.sub_agent)
create_with_argdata() (in module dragon.globalservices.process)
cuid (Channel attribute)
(SHDestroyProcessLocalChannel property)
CuPyDataMover (class in dragon.workflows.data_mover)
CuPyInputQueue (class in dragon.workflows.data_mover)
CuPyOptimizedDataMover (class in dragon.workflows.data_mover)
current() (in module dragon.native.machine)
(in module dragon.native.process)
current_allocations (MemoryPool attribute)
current_batch_age (DynamicBatcher property)
current_batch_size (DynamicBatcher property)
current_chkpt (CheckpointPersister property)
(DAOSCheckpointPersister property)
(NULLCheckpointPersister property)
(PosixCheckpointPersister property)
current_pool_allocations_used (DDictManagerStats attribute)
current_process() (DragonContext static method)
D
daemon (DragonProcess property)
(HitlTcpBridge property)
(TraceTcpBridge property)
DAGOrchestrator (class in dragon.ai.agent.orchestrator.orchestrator)
DAOSCheckpointPersister (class in dragon.data.ddict)
DATA (AllocType attribute)
data (DDManagerStatsResponse property)
DataMover (class in dragon.workflows.data_mover)
DataMovers (class in dragon.workflows.data_mover)
db_dump() (AnalysisClient method)
DD_ADVANCE (MessageTypes attribute)
DD_ADVANCE_RESPONSE (MessageTypes attribute)
DD_B_PUT (MessageTypes attribute)
DD_B_PUT_RESPONSE (MessageTypes attribute)
DD_BATCH_PUT (MessageTypes attribute)
DD_BATCH_PUT_RESPONSE (MessageTypes attribute)
DD_CHKPT_AVAIL (MessageTypes attribute)
DD_CHKPT_AVAIL_RESPONSE (MessageTypes attribute)
DD_CLEAR (MessageTypes attribute)
DD_CLEAR_RESPONSE (MessageTypes attribute)
DD_CONNECT_TO_MANAGER (MessageTypes attribute)
DD_CONNECT_TO_MANAGER_RESPONSE (MessageTypes attribute)
DD_CONTAINS (MessageTypes attribute)
DD_CONTAINS_RESPONSE (MessageTypes attribute)
DD_CREATE (MessageTypes attribute)
DD_CREATE_MANAGER_RESPONSE (MessageTypes attribute)
DD_CREATE_RESPONSE (MessageTypes attribute)
DD_DEREGISTER_CLIENT (MessageTypes attribute)
DD_DEREGISTER_CLIENT_RESPONSE (MessageTypes attribute)
DD_DESTROY (MessageTypes attribute)
DD_DESTROY_MANAGER (MessageTypes attribute)
DD_DESTROY_MANAGER_RESPONSE (MessageTypes attribute)
DD_DESTROY_RESPONSE (MessageTypes attribute)
DD_EMPTY_MANAGERS (MessageTypes attribute)
DD_EMPTY_MANAGERS_RESPONSE (MessageTypes attribute)
DD_FREEZE (MessageTypes attribute)
DD_FREEZE_RESPONSE (MessageTypes attribute)
DD_GET (MessageTypes attribute)
DD_GET_FREEZE (MessageTypes attribute)
DD_GET_FREEZE_RESPONSE (MessageTypes attribute)
DD_GET_MANAGERS (MessageTypes attribute)
DD_GET_MANAGERS_RESPONSE (MessageTypes attribute)
DD_GET_META_DATA (MessageTypes attribute)
DD_GET_META_DATA_RESPONSE (MessageTypes attribute)
DD_GET_RESPONSE (MessageTypes attribute)
DD_ITEMS (MessageTypes attribute)
DD_ITEMS_RESPONSE (MessageTypes attribute)
DD_ITERATOR (MessageTypes attribute)
DD_ITERATOR_NEXT (MessageTypes attribute)
DD_ITERATOR_NEXT_RESPONSE (MessageTypes attribute)
DD_ITERATOR_RESPONSE (MessageTypes attribute)
DD_KEYS (MessageTypes attribute)
DD_KEYS_RESPONSE (MessageTypes attribute)
DD_LENGTH (MessageTypes attribute)
DD_LENGTH_RESPONSE (MessageTypes attribute)
DD_MANAGER_NEWEST_CHKPT_ID (MessageTypes attribute)
DD_MANAGER_NEWEST_CHKPT_ID_RESPONSE (MessageTypes attribute)
DD_MANAGER_NODES (MessageTypes attribute)
DD_MANAGER_NODES_RESPONSE (MessageTypes attribute)
DD_MANAGER_SET_STATE (MessageTypes attribute)
DD_MANAGER_SET_STATE_RESPONSE (MessageTypes attribute)
DD_MANAGER_STATS (MessageTypes attribute)
DD_MANAGER_STATS_RESPONSE (MessageTypes attribute)
DD_MANAGER_SYNC (MessageTypes attribute)
DD_MANAGER_SYNC_RESPONSE (MessageTypes attribute)
DD_MARK_DRAINED_MANAGERS (MessageTypes attribute)
DD_MARK_DRAINED_MANAGERS_RESPONSE (MessageTypes attribute)
DD_PERSIST (MessageTypes attribute)
DD_PERSIST_CHKPTS (MessageTypes attribute)
DD_PERSIST_CHKPTS_RESPONSE (MessageTypes attribute)
DD_PERSIST_RESPONSE (MessageTypes attribute)
DD_PERSISTED_CHKPT_AVAIL (MessageTypes attribute)
DD_PERSISTED_CHKPT_AVAIL_RESPONSE (MessageTypes attribute)
DD_POP (MessageTypes attribute)
DD_POP_RESPONSE (MessageTypes attribute)
DD_PUT (MessageTypes attribute)
DD_PUT_RESPONSE (MessageTypes attribute)
DD_RANDOM_MANAGER (MessageTypes attribute)
DD_RANDOM_MANAGER_RESPONSE (MessageTypes attribute)
DD_REGISTER_CLIENT (MessageTypes attribute)
DD_REGISTER_CLIENT_ID (MessageTypes attribute)
DD_REGISTER_CLIENT_ID_RESPONSE (MessageTypes attribute)
DD_REGISTER_CLIENT_RESPONSE (MessageTypes attribute)
DD_REGISTER_MANAGER (MessageTypes attribute)
DD_REGISTER_MANAGER_RESPONSE (MessageTypes attribute)
DD_RESTORE (MessageTypes attribute)
DD_RESTORE_RESPONSE (MessageTypes attribute)
DD_SYNC (MessageTypes attribute)
DD_SYNC_RESPONSE (MessageTypes attribute)
DD_UN_FREEZE (MessageTypes attribute)
DD_UN_FREEZE_RESPONSE (MessageTypes attribute)
DD_UNMARK_DRAINED_MANAGERS (MessageTypes attribute)
DD_UNMARK_DRAINED_MANAGERS_RESPONSE (MessageTypes attribute)
DD_VALUES (MessageTypes attribute)
DD_VALUES_RESPONSE (MessageTypes attribute)
DDAdvance (class in dragon.infrastructure.messages)
DDAdvanceResponse (class in dragon.infrastructure.messages)
DDBatchPut (class in dragon.infrastructure.messages)
DDBatchPutResponse (class in dragon.infrastructure.messages)
DDBPut (class in dragon.infrastructure.messages)
DDBPutResponse (class in dragon.infrastructure.messages)
DDChkptAvail (class in dragon.infrastructure.messages)
DDChkptAvailResponse (class in dragon.infrastructure.messages)
DDClear (class in dragon.infrastructure.messages)
DDClearResponse (class in dragon.infrastructure.messages)
DDConnectToManager (class in dragon.infrastructure.messages)
DDConnectToManagerResponse (class in dragon.infrastructure.messages)
DDContains (class in dragon.infrastructure.messages)
DDContainsResponse (class in dragon.infrastructure.messages)
DDCreate (class in dragon.infrastructure.messages)
DDCreateManagerResponse (class in dragon.infrastructure.messages)
DDCreateResponse (class in dragon.infrastructure.messages)
DDDeregisterClient (class in dragon.infrastructure.messages)
DDDeregisterClientResponse (class in dragon.infrastructure.messages)
DDDestroy (class in dragon.infrastructure.messages)
DDDestroyManager (class in dragon.infrastructure.messages)
DDDestroyManagerResponse (class in dragon.infrastructure.messages)
DDDestroyResponse (class in dragon.infrastructure.messages)
DDEmptyManagers (class in dragon.infrastructure.messages)
DDEmptyManagersResponse (class in dragon.infrastructure.messages)
DDFreeze (class in dragon.infrastructure.messages)
DDFreezeResponse (class in dragon.infrastructure.messages)
DDGet (class in dragon.infrastructure.messages)
DDGetFreeze (class in dragon.infrastructure.messages)
DDGetFreezeResponse (class in dragon.infrastructure.messages)
DDGetManagers (class in dragon.infrastructure.messages)
DDGetManagersResponse (class in dragon.infrastructure.messages)
DDGetMetaData (class in dragon.infrastructure.messages)
DDGetMetaDataResponse (class in dragon.infrastructure.messages)
DDGetResponse (class in dragon.infrastructure.messages)
DDict (class in dragon.data)
ddict (DAGOrchestrator property)
ddict_kwargs (OrchestratorConfig attribute)
DDictAccessor (class in dragon.ai.agent.ddict.accessor)
DDictCheckpointSyncError
DDictError
DDictFullError
DDictFutureCheckpointError
DDictItemsView (class in dragon.data.ddict)
DDictKeyError
DDictKeysView (class in dragon.data.ddict)
DDictManagerStats (class in dragon.data.ddict)
DDictPersistCheckpointError
DDictSyncError
DDictTimeoutError
DDictUnableToCreateError
DDictValuesView (class in dragon.data.ddict)
DDItems (class in dragon.infrastructure.messages)
DDItemsResponse (class in dragon.infrastructure.messages)
DDIterator (class in dragon.infrastructure.messages)
DDIteratorNext (class in dragon.infrastructure.messages)
DDIteratorNextResponse (class in dragon.infrastructure.messages)
DDIteratorResponse (class in dragon.infrastructure.messages)
DDKeys (class in dragon.infrastructure.messages)
DDKeysResponse (class in dragon.infrastructure.messages)
DDLength (class in dragon.infrastructure.messages)
DDLengthResponse (class in dragon.infrastructure.messages)
DDManagerNewestChkptID (class in dragon.infrastructure.messages)
DDManagerNewestChkptIDResponse (class in dragon.infrastructure.messages)
DDManagerNodes (class in dragon.infrastructure.messages)
DDManagerNodesResponse (class in dragon.infrastructure.messages)
DDManagerSetState (class in dragon.infrastructure.messages)
DDManagerSetStateResponse (class in dragon.infrastructure.messages)
DDManagerStats (class in dragon.infrastructure.messages)
DDManagerStatsResponse (class in dragon.infrastructure.messages)
DDManagerSync (class in dragon.infrastructure.messages)
DDManagerSyncResponse (class in dragon.infrastructure.messages)
DDMarkDrainedManagers (class in dragon.infrastructure.messages)
DDMarkDrainedManagersResponse (class in dragon.infrastructure.messages)
DDPersist (class in dragon.infrastructure.messages)
DDPersistChkpts (class in dragon.infrastructure.messages)
DDPersistChkptsResponse (class in dragon.infrastructure.messages)
DDPersistedChkptAvail (class in dragon.infrastructure.messages)
DDPersistedChkptAvailResponse (class in dragon.infrastructure.messages)
DDPersistResponse (class in dragon.infrastructure.messages)
DDPop (class in dragon.infrastructure.messages)
DDPopResponse (class in dragon.infrastructure.messages)
DDPut (class in dragon.infrastructure.messages)
DDPutResponse (class in dragon.infrastructure.messages)
DDRandomManager (class in dragon.infrastructure.messages)
DDRandomManagerResponse (class in dragon.infrastructure.messages)
DDRegisterClient (class in dragon.infrastructure.messages)
DDRegisterClientID (class in dragon.infrastructure.messages)
DDRegisterClientIDResponse (class in dragon.infrastructure.messages)
DDRegisterClientResponse (class in dragon.infrastructure.messages)
DDRegisterManager (class in dragon.infrastructure.messages)
DDRegisterManagerResponse (class in dragon.infrastructure.messages)
DDRestore (class in dragon.infrastructure.messages)
DDRestoreResponse (class in dragon.infrastructure.messages)
DDSync (class in dragon.infrastructure.messages)
DDSyncResponse (class in dragon.infrastructure.messages)
DDUnFreeze (class in dragon.infrastructure.messages)
DDUnFreezeResponse (class in dragon.infrastructure.messages)
DDUnmarkDrainedManagers (class in dragon.infrastructure.messages)
DDUnmarkDrainedManagersResponse (class in dragon.infrastructure.messages)
DDValues (class in dragon.infrastructure.messages)
DDValuesResponse (class in dragon.infrastructure.messages)
DEAD (ChannelDescriptor.State attribute)
(GroupDescriptor.State attribute)
(GSChannelJoinResponse.Errors attribute)
(GSGroupAddToResponse.Errors attribute)
(GSGroupCreateAddToResponse.Errors attribute)
(GSGroupDestroyRemoveFromResponse.Errors attribute)
(GSGroupDestroyResponse.Errors attribute)
(GSGroupKillResponse.Errors attribute)
(GSGroupRemoveFromResponse.Errors attribute)
(GSProcessKillResponse.Errors attribute)
(PoolDescriptor.State attribute)
(ProcessDescriptor.State attribute)
deadline (GatewayMessage attribute)
decode() (B64 method)
DEFAULT (Policy.Distribution attribute)
(Policy.Placement attribute)
(Policy.WaitMode attribute)
(PoolOptions.Placement attribute)
default_alloc_pool (Channel attribute)
default_pool_muid_from_index() (in module dragon.infrastructure.facts)
delete() (DDictAccessor method)
denominator (Policy.Distribution attribute)
(Policy.Placement attribute)
(Policy.WaitMode attribute)
depends_on (PipelineNode attribute)
deregister() (MemoryPool method)
desc (GroupDescriptor.GroupMember attribute)
(GSChannelCreateResponse property)
(GSChannelJoinResponse property)
(GSChannelQueryResponse property)
(GSGroupAddToResponse property)
(GSGroupCreateAddToResponse property)
(GSGroupCreateResponse property)
(GSGroupDestroyRemoveFromResponse property)
(GSGroupDestroyResponse property)
(GSGroupKillResponse property)
(GSGroupQueryResponse property)
(GSGroupRemoveFromResponse property)
(GSNodeQueryResponse property)
(GSPoolCreateResponse property)
(GSPoolQueryResponse property)
(GSProcessCreateResponse property)
(GSProcessQueryResponse property)
description (BaseTool attribute)
(FunctionTool attribute)
deserialize() (CapNProtoMsg class method)
(InfraMsg class method)
destroy() (Barrier method)
(Batch method)
(Channel method)
(CPUWorker method)
(DAGOrchestrator method)
(DDict method)
(DragonBarrier method)
(DragonEvent method)
(DragonLock method)
(DragonQueueProtocol method)
(Event method)
(FIFOLock method)
(FLInterface method)
(GatewayMessage method)
(GreedyLock method)
(in module dragon.globalservices.channel)
(in module dragon.globalservices.group)
(in module dragon.globalservices.pool)
(Inference method)
(MemoryPool method)
(Message method)
(PriorityHeap method)
(Queue method)
(Store method)
destroy_capture_connections() (in module dragon.globalservices.process)
destroy_my_channels() (in module dragon.infrastructure.standalone_conn)
destroy_process_local() (Channel method)
destroy_remove_from() (in module dragon.globalservices.group)
destroy_standalone() (in module dragon.infrastructure.standalone_conn)
detach() (Channel method)
(DDict method)
(DragonLock method)
(FIFOLock method)
(FLInterface method)
(GreedyLock method)
(MemoryAlloc method)
(MemoryPool method)
(PriorityHeap method)
(Store method)
Detector (class in dragon.telemetry.analysis)
device_list (AcceleratorDescriptor attribute)
DEVNULL (Popen attribute)
(ProcessTemplate attribute)
DictTracingProcessor (class in dragon.ai.agent.observability.ddict_tracer)
Directed Graph
disable() (Proxy method)
discard_gateways() (in module dragon.channels)
DISCOVERABLE (NodeDescriptor.State attribute)
dispatch_id (DispatchHeader attribute)
(HumanApprovalRequest attribute)
DispatchHeader (class in dragon.ai.agent.config.dispatch)
Distributed System
distribution (Policy attribute)
DONE (TaskStatus attribute)
DOWN (NodeDescriptor.State attribute)
Dragon Object
dragon.ai.collective_group
module
dragon.channels
module
dragon.dlogging.logger
module
dragon.dtypes
module
dragon.fli
module
dragon.globalservices.api_setup
module
dragon.globalservices.channel
module
dragon.globalservices.group
module
dragon.globalservices.node
module
dragon.globalservices.pool
module
dragon.globalservices.process
module
dragon.infrastructure.channel_desc
module
dragon.infrastructure.facts
module
dragon.infrastructure.gpu_desc
module
dragon.infrastructure.group_desc
module
dragon.infrastructure.messages
module
dragon.infrastructure.node_desc
module
dragon.infrastructure.parameters
module
dragon.infrastructure.pool_desc
module
dragon.infrastructure.process_desc
module
dragon.infrastructure.standalone_conn
module
dragon.infrastructure.util
module
dragon.locks
module
dragon.managed_memory
module
dragon.native.array
module
dragon.native.barrier
module
dragon.native.event
module
dragon.native.lock
module
dragon.native.machine
module
dragon.native.process
module
dragon.native.queue
module
dragon.native.semaphore
module
dragon.native.value
module
dragon.pheap
module
dragon.pmod
module
dragon.telemetry.analysis
module
dragon.telemetry.telemetry
module
dragon.transport
module
dragon.transport.overlay
module
dragon.utils
module
dragon.workflows.data_mover
module
dragon.workflows.parsl_batch_executor
module
dragon.workflows.parsl_executor
module
dragon.workflows.parsl_mpi_app
module
dragon::Barrier (C++ class)
dragon::Barrier::abort (C++ function)
dragon::Barrier::Barrier (C++ function)
,
[1]
dragon::Barrier::broken (C++ function)
dragon::Barrier::n_waiting (C++ function)
dragon::Barrier::parties (C++ function)
dragon::Barrier::reset (C++ function)
dragon::Barrier::serialize (C++ function)
dragon::Barrier::wait (C++ function)
dragon::Barrier::~Barrier (C++ function)
dragon::DDict (C++ class)
dragon::DDict::advance (C++ function)
dragon::DDict::bget (C++ function)
dragon::DDict::bput (C++ function)
dragon::DDict::checkpoint (C++ function)
dragon::DDict::checkpoint_id (C++ function)
dragon::DDict::clear (C++ function)
dragon::DDict::clone (C++ function)
dragon::DDict::contains (C++ function)
dragon::DDict::DDict (C++ function)
,
[1]
,
[2]
dragon::DDict::empty_managers (C++ function)
dragon::DDict::end_batch_put (C++ function)
dragon::DDict::erase (C++ function)
dragon::DDict::freeze (C++ function)
dragon::DDict::is_frozen (C++ function)
dragon::DDict::keys (C++ function)
dragon::DDict::local_keys (C++ function)
dragon::DDict::local_manager (C++ function)
dragon::DDict::local_managers (C++ function)
dragon::DDict::local_size (C++ function)
dragon::DDict::main_manager (C++ function)
dragon::DDict::manager (C++ function)
dragon::DDict::operator[] (C++ function)
dragon::DDict::persist (C++ function)
dragon::DDict::persisted_ids (C++ function)
dragon::DDict::pput (C++ function)
dragon::DDict::restore (C++ function)
dragon::DDict::rollback (C++ function)
dragon::DDict::serialize (C++ function)
dragon::DDict::set_checkpoint_id (C++ function)
dragon::DDict::size (C++ function)
dragon::DDict::start_batch_put (C++ function)
dragon::DDict::sync_to_newest_checkpoint (C++ function)
dragon::DDict::synchronize (C++ function)
dragon::DDict::unfreeze (C++ function)
dragon::DDict::which_manager (C++ function)
dragon::DDict::~DDict (C++ function)
dragon::DerivedSerializable (C++ class)
dragon::DerivedSerializable::DerivedSerializable (C++ function)
dragon::DerivedSerializable::deserialize (C++ function)
dragon::DerivedSerializable::getVal (C++ function)
dragon::DerivedSerializable::serialize (C++ function)
dragon::Queue (C++ class)
dragon::Queue::empty (C++ function)
dragon::Queue::full (C++ function)
dragon::Queue::get (C++ function)
,
[1]
,
[2]
dragon::Queue::get_nowait (C++ function)
dragon::Queue::join (C++ function)
dragon::Queue::poll (C++ function)
dragon::Queue::put (C++ function)
,
[1]
,
[2]
dragon::Queue::put_nowait (C++ function)
dragon::Queue::Queue (C++ function)
,
[1]
dragon::Queue::serialize (C++ function)
dragon::Queue::size (C++ function)
dragon::Queue::task_done (C++ function)
dragon::Queue::~Queue (C++ function)
dragon::Semaphore (C++ class)
dragon::Semaphore::acquire (C++ function)
dragon::Semaphore::get_value (C++ function)
dragon::Semaphore::release (C++ function)
dragon::Semaphore::Semaphore (C++ function)
,
[1]
dragon::Semaphore::serialize (C++ function)
dragon::Semaphore::~Semaphore (C++ function)
dragon::Serializable (C++ class)
dragon::SerializableDouble (C++ class)
dragon::SerializableDouble2DVector (C++ class)
dragon::SerializableDouble2DVector::deserialize (C++ function)
dragon::SerializableDouble2DVector::getVal (C++ function)
dragon::SerializableDouble2DVector::SerializableDouble2DVector (C++ function)
dragon::SerializableDouble2DVector::serialize (C++ function)
dragon::SerializableDouble::deserialize (C++ function)
dragon::SerializableDouble::getVal (C++ function)
dragon::SerializableDouble::SerializableDouble (C++ function)
dragon::SerializableDouble::serialize (C++ function)
dragon::SerializableInt (C++ class)
dragon::SerializableInt::deserialize (C++ function)
dragon::SerializableInt::getVal (C++ function)
dragon::SerializableInt::SerializableInt (C++ function)
dragon::SerializableInt::serialize (C++ function)
dragon::SerializableString (C++ class)
dragon::SerializableString::deserialize (C++ function)
dragon::SerializableString::getVal (C++ function)
dragon::SerializableString::SerializableString (C++ function)
dragon::SerializableString::serialize (C++ function)
dragon_channel_add_event_bcast (C++ function)
dragon_channel_attach (C++ function)
dragon_channel_attr_destroy (C++ function)
dragon_channel_attr_init (C++ function)
dragon_channel_barrier_is_broken (C++ function)
dragon_channel_barrier_waiters (C++ function)
dragon_channel_blocked_receivers (C++ function)
DRAGON_CHANNEL_BLOCKING_NOTIMEOUT (C++ member)
dragon_channel_capacity (C++ function)
dragon_channel_create (C++ function)
dragon_channel_descr_clone (C++ function)
dragon_channel_destroy (C++ function)
dragon_channel_detach (C++ function)
dragon_channel_discard_gateways (C++ function)
dragon_channel_gatewaymessage_attach (C++ function)
dragon_channel_gatewaymessage_client_event_cmplt (C++ function)
dragon_channel_gatewaymessage_client_get_cmplt (C++ function)
dragon_channel_gatewaymessage_client_send_cmplt (C++ function)
dragon_channel_gatewaymessage_destroy (C++ function)
dragon_channel_gatewaymessage_detach (C++ function)
dragon_channel_gatewaymessage_event_create (C++ function)
dragon_channel_gatewaymessage_get_create (C++ function)
dragon_channel_gatewaymessage_get_debug (C++ function)
dragon_channel_gatewaymessage_send_create (C++ function)
dragon_channel_gatewaymessage_serial_free (C++ function)
dragon_channel_gatewaymessage_serialize (C++ function)
dragon_channel_gatewaymessage_transport_check_event_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_check_get_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_check_send_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_event_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_get_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_send_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_start_event_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_start_get_cmplt (C++ function)
dragon_channel_gatewaymessage_transport_start_send_cmplt (C++ function)
dragon_channel_get_attr (C++ function)
dragon_channel_get_hostid (C++ function)
dragon_channel_get_pool (C++ function)
dragon_channel_get_uid (C++ function)
dragon_channel_is_local (C++ function)
dragon_channel_message_attr_destroy (C++ function)
dragon_channel_message_attr_init (C++ function)
dragon_channel_message_count (C++ function)
dragon_channel_message_destroy (C++ function)
dragon_channel_message_get_mem (C++ function)
dragon_channel_message_get_ptr_info (C++ function)
dragon_channel_message_getattr (C++ function)
dragon_channel_message_init (C++ function)
dragon_channel_message_setattr (C++ function)
dragon_channel_notify_on_destroy (C++ function)
dragon_channel_poll (C++ function)
dragon_channel_pool_get_uid_fname (C++ function)
dragon_channel_recv_attr_destroy (C++ function)
dragon_channel_recv_attr_init (C++ function)
dragon_channel_recvh (C++ function)
dragon_channel_register_gateway (C++ function)
dragon_channel_register_gateways_from_env (C++ function)
dragon_channel_remove_event_bcast (C++ function)
dragon_channel_send_attr_destroy (C++ function)
dragon_channel_send_attr_init (C++ function)
DRAGON_CHANNEL_SEND_NO_COPY_READ_ONLY (C++ member)
DRAGON_CHANNEL_SEND_TRANSFER_OWNERSHIP (C++ member)
dragon_channel_sendh (C++ function)
dragon_channel_serial_free (C++ function)
dragon_channel_serialize (C++ function)
dragon_channel_ta_update_nodes (C++ function)
DRAGON_CHANNEL_TRYONCE_TIMEOUT (C++ member)
dragon_channel_unregister_gateway (C++ function)
dragon_channel_update_event_mask (C++ function)
dragon_channelset_attr_init (C++ function)
dragon_channelset_create (C++ function)
dragon_channelset_destroy (C++ function)
dragon_channelset_get_channels (C++ function)
dragon_channelset_get_event_mask (C++ function)
dragon_channelset_notify_callback (C++ function)
dragon_channelset_notify_signal (C++ function)
dragon_channelset_poll (C++ function)
dragon_channelset_reset (C++ function)
dragon_channelset_set_event_mask (C++ function)
dragon_chrecv_close (C++ function)
dragon_chrecv_get_attr (C++ function)
dragon_chrecv_get_msg (C++ function)
dragon_chrecv_get_msg_blocking (C++ function)
dragon_chrecv_get_msg_notify (C++ function)
dragon_chrecv_open (C++ function)
dragon_chrecv_peek_msg (C++ function)
dragon_chrecv_pop_msg (C++ function)
dragon_chsend_close (C++ function)
dragon_chsend_get_attr (C++ function)
dragon_chsend_open (C++ function)
dragon_chsend_send_msg (C++ function)
dragon_chsend_set_attr (C++ function)
DRAGON_CONFIG (TransportAgentOptions attribute)
dragon_ddict_advance (C++ function)
dragon_ddict_attach (C++ function)
dragon_ddict_bget (C++ function)
dragon_ddict_bput (C++ function)
dragon_ddict_checkpoint (C++ function)
dragon_ddict_checkpoint_id (C++ function)
dragon_ddict_clear (C++ function)
dragon_ddict_clone (C++ function)
dragon_ddict_contains (C++ function)
dragon_ddict_create_request (C++ function)
dragon_ddict_detach (C++ function)
dragon_ddict_empty_managers (C++ function)
dragon_ddict_end_batch_put (C++ function)
dragon_ddict_finalize_request (C++ function)
dragon_ddict_free_required (C++ function)
dragon_ddict_freeze (C++ function)
dragon_ddict_get (C++ function)
dragon_ddict_is_frozen (C++ function)
dragon_ddict_keys (C++ function)
dragon_ddict_length (C++ function)
dragon_ddict_local_keys (C++ function)
dragon_ddict_local_length (C++ function)
dragon_ddict_local_manager (C++ function)
dragon_ddict_local_managers (C++ function)
dragon_ddict_main_manager (C++ function)
dragon_ddict_manager (C++ function)
dragon_ddict_persist (C++ function)
dragon_ddict_persisted_ids (C++ function)
dragon_ddict_pop (C++ function)
dragon_ddict_pput (C++ function)
dragon_ddict_put (C++ function)
dragon_ddict_read_bytes (C++ function)
dragon_ddict_read_bytes_into (C++ function)
dragon_ddict_read_mem (C++ function)
dragon_ddict_request_key_sendh (C++ function)
dragon_ddict_request_recvh (C++ function)
dragon_ddict_request_value_sendh (C++ function)
dragon_ddict_restore (C++ function)
dragon_ddict_rollback (C++ function)
dragon_ddict_serialize (C++ function)
dragon_ddict_set_checkpoint_id (C++ function)
dragon_ddict_start_batch_put (C++ function)
dragon_ddict_stats (C++ function)
dragon_ddict_sync_to_newest_checkpoint (C++ function)
dragon_ddict_synchronize (C++ function)
dragon_ddict_unfreeze (C++ function)
dragon_ddict_which_manager (C++ function)
dragon_ddict_write_bytes (C++ function)
dragon_fli_attach (C++ function)
dragon_fli_attr_init (C++ function)
dragon_fli_close_recv_handle (C++ function)
dragon_fli_close_send_handle (C++ function)
dragon_fli_create (C++ function)
dragon_fli_create_readable_fd (C++ function)
dragon_fli_create_writable_fd (C++ function)
dragon_fli_destroy (C++ function)
dragon_fli_detach (C++ function)
dragon_fli_finalize_readable_fd (C++ function)
dragon_fli_finalize_writable_fd (C++ function)
dragon_fli_full (C++ function)
dragon_fli_get_available_streams (C++ function)
dragon_fli_get_buffered_bytes (C++ function)
dragon_fli_is_buffered (C++ function)
dragon_fli_join (C++ function)
dragon_fli_new_task (C++ function)
dragon_fli_num_msgs (C++ function)
dragon_fli_open_recv_handle (C++ function)
dragon_fli_open_send_handle (C++ function)
dragon_fli_poll (C++ function)
dragon_fli_recv_attr_init (C++ function)
dragon_fli_recv_bytes (C++ function)
dragon_fli_recv_bytes_into (C++ function)
dragon_fli_recv_mem (C++ function)
dragon_fli_reset_free_flag (C++ function)
dragon_fli_send_attr_init (C++ function)
dragon_fli_send_bytes (C++ function)
dragon_fli_send_mem (C++ function)
dragon_fli_serial_free (C++ function)
dragon_fli_serialize (C++ function)
dragon_fli_set_free_flag (C++ function)
dragon_fli_stream_received (C++ function)
dragon_fli_task_create (C++ function)
dragon_fli_task_done (C++ function)
dragon_memory_alloc (C++ function)
dragon_memory_alloc_blocking (C++ function)
dragon_memory_alloc_type (C++ function)
dragon_memory_alloc_type_blocking (C++ function)
dragon_memory_attach (C++ function)
dragon_memory_attr_destroy (C++ function)
dragon_memory_attr_init (C++ function)
dragon_memory_clear (C++ function)
dragon_memory_copy (C++ function)
dragon_memory_copy_size (C++ function)
dragon_memory_copy_to_pool (C++ function)
dragon_memory_descr_clone (C++ function)
dragon_memory_detach (C++ function)
dragon_memory_equal (C++ function)
dragon_memory_free (C++ function)
dragon_memory_from_id (C++ function)
dragon_memory_get_alloc_memdescr (C++ function)
dragon_memory_get_attr (C++ function)
dragon_memory_get_pointer (C++ function)
dragon_memory_get_pool (C++ function)
dragon_memory_get_ptr_info (C++ function)
dragon_memory_get_size (C++ function)
dragon_memory_hash (C++ function)
dragon_memory_id (C++ function)
dragon_memory_is (C++ function)
dragon_memory_max_serialized_len (C++ function)
dragon_memory_modify_size (C++ function)
dragon_memory_pool_allocation_exists (C++ function)
dragon_memory_pool_allocations_destroy (C++ function)
dragon_memory_pool_attach (C++ function)
dragon_memory_pool_attach_default (C++ function)
dragon_memory_pool_attach_from_env (C++ function)
dragon_memory_pool_create (C++ function)
dragon_memory_pool_descr_clone (C++ function)
dragon_memory_pool_destroy (C++ function)
dragon_memory_pool_detach (C++ function)
dragon_memory_pool_get_allocations (C++ function)
dragon_memory_pool_get_free_blocks (C++ function)
dragon_memory_pool_get_free_size (C++ function)
dragon_memory_pool_get_hostid (C++ function)
dragon_memory_pool_get_num_block_sizes (C++ function)
dragon_memory_pool_get_pointer (C++ function)
dragon_memory_pool_get_rt_uid (C++ function)
dragon_memory_pool_get_size (C++ function)
dragon_memory_pool_get_total_size (C++ function)
dragon_memory_pool_get_type_allocations (C++ function)
dragon_memory_pool_get_uid_fname (C++ function)
dragon_memory_pool_get_utilization_pct (C++ function)
dragon_memory_pool_is_local (C++ function)
dragon_memory_pool_max_serialized_len (C++ function)
dragon_memory_pool_muid (C++ function)
dragon_memory_pool_process_local_register_with_gpu (C++ function)
dragon_memory_pool_process_local_unregister_with_gpu (C++ function)
dragon_memory_pool_runtime_is_local (C++ function)
dragon_memory_pool_serial_free (C++ function)
dragon_memory_pool_serialize (C++ function)
dragon_memory_serial_free (C++ function)
dragon_memory_serialize (C++ function)
DRAGON_MSG (MessageTypes attribute)
DragonAgent (class in dragon.ai.agent.core.base)
DragonArray (class in dragon.mpbridge.sharedctypes)
DragonBarrier (class in dragon.mpbridge.synchronize)
DragonBatchPoolExecutor (class in dragon.workflows.parsl_batch_executor)
DragonBoundedSemaphore (class in dragon.mpbridge.synchronize)
dragonChannelAttr_t (C++ struct)
dragonChannelAttr_t::barrier_count (C++ member)
dragonChannelAttr_t::blocked_receivers (C++ member)
dragonChannelAttr_t::blocked_senders (C++ member)
dragonChannelAttr_t::bounded (C++ member)
dragonChannelAttr_t::broken_barrier (C++ member)
dragonChannelAttr_t::buffer_pool (C++ member)
dragonChannelAttr_t::bytes_per_msg_block (C++ member)
dragonChannelAttr_t::c_uid (C++ member)
dragonChannelAttr_t::capacity (C++ member)
dragonChannelAttr_t::fc_type (C++ member)
dragonChannelAttr_t::flags (C++ member)
dragonChannelAttr_t::initial_sem_value (C++ member)
dragonChannelAttr_t::lock_type (C++ member)
dragonChannelAttr_t::max_event_bcasts (C++ member)
dragonChannelAttr_t::max_spinners (C++ member)
dragonChannelAttr_t::num_avail_blocks (C++ member)
dragonChannelAttr_t::num_msgs (C++ member)
dragonChannelAttr_t::oflag (C++ member)
dragonChannelAttr_t::semaphore (C++ member)
dragonChannelDescr_t (C++ struct)
dragonChannelEvent_t (C++ enum)
dragonChannelEvent_t::DRAGON_CHANNEL_CLEANUP (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLBARRIER_ABORT (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLBARRIER_ISBROKEN (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLBARRIER_RELEASE (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLBARRIER_WAIT (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLBARRIER_WAITERS (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLBLOCKED_RECEIVERS (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLCAPACITY (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLEMPTY (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLFULL (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLIN (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLINOUT (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLNOTHING (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLOUT (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLRESET (C++ enumerator)
dragonChannelEvent_t::DRAGON_CHANNEL_POLLSIZE (C++ enumerator)
dragonChannelEvent_t::DRAGON_SEMAPHORE_P (C++ enumerator)
dragonChannelEvent_t::DRAGON_SEMAPHORE_PEEK (C++ enumerator)
dragonChannelEvent_t::DRAGON_SEMAPHORE_V (C++ enumerator)
dragonChannelEvent_t::DRAGON_SEMAPHORE_Z (C++ enumerator)
dragonChannelEventNotification_t (C++ struct)
dragonChannelEventNotification_t::revent (C++ member)
dragonChannelEventNotification_t::user_token (C++ member)
dragonChannelFC_t (C++ enum)
dragonChannelFC_t::DRAGON_CHANNEL_FC_MEMORY (C++ enumerator)
dragonChannelFC_t::DRAGON_CHANNEL_FC_MSGS (C++ enumerator)
dragonChannelFC_t::DRAGON_CHANNEL_FC_NONE (C++ enumerator)
dragonChannelFC_t::DRAGON_CHANNEL_FC_RESOURCES (C++ enumerator)
dragonChannelFlags_t (C++ enum)
dragonChannelFlags_t::DRAGON_CHANNEL_FLAGS_MASQUERADE_AS_REMOTE (C++ enumerator)
dragonChannelFlags_t::DRAGON_CHANNEL_FLAGS_NONE (C++ enumerator)
dragonChannelOFlag_t (C++ enum)
dragonChannelOFlag_t::DRAGON_CHANNEL_EXCLUSIVE (C++ enumerator)
dragonChannelOFlag_t::DRAGON_CHANNEL_NONEXCLUSIVE (C++ enumerator)
dragonChannelRecvAttr_t (C++ struct)
dragonChannelRecvAttr_t::default_notif_type (C++ member)
dragonChannelRecvAttr_t::default_timeout (C++ member)
dragonChannelRecvAttr_t::signal (C++ member)
dragonChannelRecvAttr_t::wait_mode (C++ member)
dragonChannelRecvh_t (C++ struct)
dragonChannelRecvNotif_t (C++ enum)
dragonChannelRecvNotif_t::DRAGON_RECV_SYNC_MANUAL (C++ enumerator)
dragonChannelRecvNotif_t::DRAGON_RECV_SYNC_SIGNAL (C++ enumerator)
dragonChannelSendAttr_t (C++ struct)
dragonChannelSendAttr_t::debug (C++ member)
dragonChannelSendAttr_t::default_timeout (C++ member)
dragonChannelSendAttr_t::return_mode (C++ member)
dragonChannelSendAttr_t::sendhid (C++ member)
dragonChannelSendAttr_t::wait_mode (C++ member)
dragonChannelSendh_t (C++ struct)
dragonChannelSerial_t (C++ struct)
dragonChannelSerial_t::len (C++ member)
DragonCondition (class in dragon.mpbridge.synchronize)
DragonContext (class in dragon.mpbridge.context)
DragonContext.AuthenticationError
DragonContext.BufferTooShort
DragonContext.ProcessError
DragonContext.TimeoutError
DragonDataset (class in dragon.ai.torch)
dragonDDictDescr_t (C++ struct)
dragonDDictKey_t (C++ struct)
dragonDDictRequestDescr_t (C++ struct)
DragonEvent (class in dragon.mpbridge.synchronize)
DragonException
dragonFLIAttr_t (C++ struct)
dragonFLIDescr_t (C++ struct)
DragonFLIEOT
DragonFLIError
DragonFLIFull
DragonFLIObjectDestroyed
DragonFLIOutOfMemoryError
dragonFLIRecvAttr_t (C++ struct)
dragonFLIRecvAttr_t::dest_pool (C++ member)
DragonFLIRecvdMsgDestroyedError
dragonFLIRecvHandleDescr_t (C++ struct)
dragonFLISendAttr_t (C++ struct)
dragonFLISendAttr_t::allow_strm_term (C++ member)
dragonFLISendAttr_t::debug (C++ member)
dragonFLISendAttr_t::dest_pool (C++ member)
dragonFLISendAttr_t::flush (C++ member)
dragonFLISendAttr_t::turbo_mode (C++ member)
dragonFLISendHandleDescr_t (C++ struct)
dragonFLISerial_t (C++ struct)
dragonFLISerial_t::len (C++ member)
DragonFLITimeoutError
dragonGatewayMessage_t (C++ struct)
dragonGatewayMessage_t::deadline (C++ member)
dragonGatewayMessage_t::event_mask (C++ member)
dragonGatewayMessage_t::get_dest_mem_descr_ser (C++ member)
dragonGatewayMessage_t::msg_kind (C++ member)
dragonGatewayMessage_t::send_dest_mem_descr_ser (C++ member)
dragonGatewayMessage_t::send_payload_message (C++ member)
dragonGatewayMessage_t::send_return_mode (C++ member)
dragonGatewayMessage_t::target_ch_ser (C++ member)
dragonGatewayMessage_t::target_hostid (C++ member)
dragonGatewayMessageHeader_t (C++ struct)
dragonGatewayMessageHeader_t::client_cmplt (C++ member)
dragonGatewayMessageHeader_t::client_pid (C++ member)
dragonGatewayMessageHeader_t::client_puid (C++ member)
dragonGatewayMessageHeader_t::cmplt_bcast_offset (C++ member)
dragonGatewayMessageHeader_t::deadline_nsec (C++ member)
dragonGatewayMessageHeader_t::deadline_sec (C++ member)
dragonGatewayMessageHeader_t::debug (C++ member)
dragonGatewayMessageHeader_t::dest_mem_descr_ser_nbytes (C++ member)
dragonGatewayMessageHeader_t::dest_mem_descr_ser_offset (C++ member)
dragonGatewayMessageHeader_t::event_mask (C++ member)
dragonGatewayMessageHeader_t::has_deadline (C++ member)
dragonGatewayMessageHeader_t::has_dest_mem_descr (C++ member)
dragonGatewayMessageHeader_t::msg_kind (C++ member)
dragonGatewayMessageHeader_t::op_rc (C++ member)
dragonGatewayMessageHeader_t::send_clientid (C++ member)
dragonGatewayMessageHeader_t::send_hints (C++ member)
dragonGatewayMessageHeader_t::send_payload_buffered (C++ member)
dragonGatewayMessageHeader_t::send_payload_cleanup_required (C++ member)
dragonGatewayMessageHeader_t::send_payload_nbytes (C++ member)
dragonGatewayMessageHeader_t::send_payload_offset (C++ member)
dragonGatewayMessageHeader_t::send_return_mode (C++ member)
dragonGatewayMessageHeader_t::sendhid (C++ member)
dragonGatewayMessageHeader_t::target_ch_ser_nbytes (C++ member)
dragonGatewayMessageHeader_t::target_ch_ser_offset (C++ member)
dragonGatewayMessageHeader_t::target_hostid (C++ member)
dragonGatewayMessageHeader_t::transport_cmplt_timestamp (C++ member)
dragonGatewayMessageKind_t (C++ enum)
dragonGatewayMessageKind_t::DRAGON_GATEWAY_MESSAGE_EVENT (C++ enumerator)
dragonGatewayMessageKind_t::DRAGON_GATEWAY_MESSAGE_GET (C++ enumerator)
dragonGatewayMessageKind_t::DRAGON_GATEWAY_MESSAGE_SEND (C++ enumerator)
dragonGatewayMessageSerial_t (C++ struct)
dragonGatewayMessageSerial_t::data (C++ member)
dragonGatewayMessageSerial_t::len (C++ member)
dragonHeapStatsAllocationItem_t (C++ struct)
dragonHeapStatsAllocationItem_t::block_size (C++ member)
dragonHeapStatsAllocationItem_t::num_blocks (C++ member)
DragonJoinableQueue (class in dragon.mpbridge.queues)
DragonLock (class in dragon.locks)
(class in dragon.mpbridge.synchronize)
DragonLoggingError
DragonLoggingError.Errors (class in dragon.dlogging.logger)
dragonMemoryAllocationType_t (C++ enum)
dragonMemoryAllocationType_t::DRAGON_MEMORY_ALLOC_BOOTSTRAP (C++ enumerator)
dragonMemoryAllocationType_t::DRAGON_MEMORY_ALLOC_CHANNEL (C++ enumerator)
dragonMemoryAllocationType_t::DRAGON_MEMORY_ALLOC_CHANNEL_BUFFER (C++ enumerator)
dragonMemoryAllocationType_t::DRAGON_MEMORY_ALLOC_DATA (C++ enumerator)
dragonMemoryDescr_t (C++ struct)
DragonMemoryError
dragonMemoryPoolAllocations_t (C++ struct)
dragonMemoryPoolAttr_t (C++ struct)
dragonMemoryPoolAttr_t::allocatable_data_size (C++ member)
dragonMemoryPoolAttr_t::data_min_block_size (C++ member)
dragonMemoryPoolAttr_t::free_space (C++ member)
dragonMemoryPoolAttr_t::growth_type (C++ member)
dragonMemoryPoolAttr_t::manifest_allocated_size (C++ member)
dragonMemoryPoolAttr_t::manifest_entries (C++ member)
dragonMemoryPoolAttr_t::manifest_heap_size (C++ member)
dragonMemoryPoolAttr_t::manifest_table_size (C++ member)
dragonMemoryPoolAttr_t::max_allocatable_block_size (C++ member)
dragonMemoryPoolAttr_t::max_allocations (C++ member)
dragonMemoryPoolAttr_t::max_manifest_entries (C++ member)
dragonMemoryPoolAttr_t::max_size (C++ member)
dragonMemoryPoolAttr_t::mem_type (C++ member)
dragonMemoryPoolAttr_t::mname (C++ member)
dragonMemoryPoolAttr_t::mode (C++ member)
dragonMemoryPoolAttr_t::names (C++ member)
dragonMemoryPoolAttr_t::npre_allocs (C++ member)
dragonMemoryPoolAttr_t::pre_allocs (C++ member)
dragonMemoryPoolAttr_t::segment_size (C++ member)
dragonMemoryPoolAttr_t::total_data_size (C++ member)
dragonMemoryPoolAttr_t::utilization_pct (C++ member)
dragonMemoryPoolAttr_t::waiters_for_manifest (C++ member)
dragonMemoryPoolDescr_t (C++ struct)
dragonMemoryPoolGrowthType_t (C++ enum)
dragonMemoryPoolGrowthType_t::DRAGON_MEMORY_GROWTH_CAPPED (C++ enumerator)
dragonMemoryPoolGrowthType_t::DRAGON_MEMORY_GROWTH_NONE (C++ enumerator)
dragonMemoryPoolGrowthType_t::DRAGON_MEMORY_GROWTH_UNLIMITED (C++ enumerator)
dragonMemoryPoolSerial_t (C++ struct)
dragonMemoryPoolSerial_t::len (C++ member)
dragonMemoryPoolType_t (C++ enum)
dragonMemoryPoolType_t::DRAGON_MEMORY_TYPE_FILE (C++ enumerator)
dragonMemoryPoolType_t::DRAGON_MEMORY_TYPE_GPU (C++ enumerator)
dragonMemoryPoolType_t::DRAGON_MEMORY_TYPE_HUGEPAGE (C++ enumerator)
dragonMemoryPoolType_t::DRAGON_MEMORY_TYPE_PRIVATE (C++ enumerator)
dragonMemoryPoolType_t::DRAGON_MEMORY_TYPE_SHM (C++ enumerator)
dragonMemorySerial_t (C++ struct)
dragonMemorySerial_t::data (C++ member)
dragonMemorySerial_t::len (C++ member)
DragonMemoryTypeError
dragonMessage_t (C++ struct)
dragonMessageAttr_t (C++ struct)
dragonMessageAttr_t::clientid (C++ member)
dragonMessageAttr_t::hints (C++ member)
dragonMessageAttr_t::no_copy_read_only (C++ member)
dragonMessageAttr_t::send_transfer_ownership (C++ member)
dragonMessageAttr_t::sendhid (C++ member)
DragonMPIExecutor (class in dragon.workflows.parsl_mpi_app)
DragonNodeError
dragonNodeMap_t (C++ struct)
dragonNodeMap_t::host_id (C++ member)
dragonNodeMap_t::ip_addr (C++ member)
DragonObjectDestroyed
DragonPool (class in dragon.mpbridge.pool)
DragonPoolAllocationNotAvailable
DragonPoolAttachFail
DragonPoolCreateFail
DragonPoolDetachFail
DragonPoolError
DragonPoolError.Errors (class in dragon.managed_memory)
DragonPoolExecutor (class in dragon.workflows.parsl_executor)
DragonProcess (class in dragon.mpbridge.process)
DragonQueue (class in dragon.mpbridge.queues)
DragonQueueLLMProxy (class in dragon.ai.inference.llm_proxy)
DragonQueueProtocol (class in dragon.ai.agent.communication.dragon_comm)
DragonRawArray (class in dragon.mpbridge.sharedctypes)
DragonRawValue (class in dragon.mpbridge.sharedctypes)
DragonRLock (class in dragon.mpbridge.synchronize)
DragonSemaphore (class in dragon.mpbridge.synchronize)
DragonSimpleQueue (class in dragon.mpbridge.queues)
DragonValue (class in dragon.mpbridge.sharedctypes)
dragonWaitMode_t (C++ enum)
dragonWaitMode_t::DRAGON_ADAPTIVE_WAIT (C++ enumerator)
dragonWaitMode_t::DRAGON_IDLE_WAIT (C++ enumerator)
dragonWaitMode_t::DRAGON_SPIN_WAIT (C++ enumerator)
dstats (DDict property)
(Store property)
dtype (ModelConfig attribute)
dump() (CheckpointPersister method)
(DAOSCheckpointPersister method)
(NULLCheckpointPersister method)
(PosixCheckpointPersister method)
(XNumPy2DPickler method)
(XScalarPickler method)
(XStringPickler method)
dump_metadata() (CheckpointPersister class method)
(DAOSCheckpointPersister class method)
(NULLCheckpointPersister class method)
(PosixCheckpointPersister class method)
dumps() (XNumPy2DPickler method)
(XScalarPickler method)
(XStringPickler method)
dynamic_inf_workers() (CPUWorker method)
dynamic_worker (InferenceConfig attribute)
DynamicBatcher (class in dragon.ai.inference.batching)
DynamicWorkerConfig (class in dragon.ai.inference.config)
E
EARLY (PipeOptions.CreationPolicy attribute)
EMPTY (SHPingBE attribute)
empty() (DragonJoinableQueue method)
(DragonQueue method)
(DragonSimpleQueue method)
(Queue method)
(TimeKeeper method)
empty_managers (DDict property)
(Store property)
empty_pool() (MemoryPool class method)
emptyManagerFLI (DDManagerSync property)
emptyManagers (DDGetManagersResponse property)
enable() (Proxy method)
enable_logging() (in module dragon.infrastructure.util)
enabled (BatchingConfig attribute)
(DynamicWorkerConfig attribute)
(GuardrailsConfig attribute)
encode() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
end_batch_put() (DDict method)
(Store method)
end_time (Span attribute)
(Trace attribute)
endswith() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
enforce_window() (ContextManager method)
entry_point() (CPUWorker static method)
env() (LaunchParameters method)
env_name() (in module dragon.infrastructure.facts)
env_str (AcceleratorDescriptor attribute)
EOT (ChannelAdapterMsgTypes attribute)
err (CapNProtoResponseMsg property)
(DDRegisterManager property)
(InfraMsg property)
errInfo (CapNProtoResponseMsg property)
(DDRegisterManager property)
ERROR (NodeDescriptor.State attribute)
error (Span attribute)
ERROR (TaskStatus attribute)
error_code (GroupDescriptor.GroupMember attribute)
error_complete() (GatewayMessage method)
error_info (GroupDescriptor.GroupMember attribute)
Errors (CapNProtoMsg attribute)
Event (class in dragon.native.event)
Event() (DragonContext method)
event_complete() (GatewayMessage method)
event_mask (GatewayMessage attribute)
EventType (class in dragon.channels)
ExceptionalThread (class in dragon.utils)
EXCEPTIONLESS_ABORT (MessageTypes attribute)
ExceptionlessAbort (class in dragon.infrastructure.messages)
exit_status (ProcessGroup property)
exitcode (DragonProcess property)
expandtabs() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
EXTERNAL (PipeOptions.CreationPolicy attribute)
EXTERNALLY_MANAGED (ConnectionOptions.CreationPolicy attribute)
extract() (PriorityHeap method)
F
FAIL (DragonLoggingError.Errors attribute)
(DragonPoolError.Errors attribute)
(GroupDescriptor.GroupMember.Errors attribute)
(GSChannelCreateResponse.Errors attribute)
(GSGroupAddToResponse.Errors attribute)
(GSGroupDestroyPMIxResponse.Errors attribute)
(GSGroupDestroyRemoveFromResponse.Errors attribute)
(GSGroupRemoveFromResponse.Errors attribute)
(GSPoolCreateResponse.Errors attribute)
(GSPoolDestroyResponse.Errors attribute)
(GSProcessCreateResponse.Errors attribute)
(LAServerModeExit.Errors attribute)
(LSDestroyPMIxResponse.Errors attribute)
(SHAllocBlockResponse.Errors attribute)
(SHChannelCreateResponse.Errors attribute)
(SHChannelDestroyResponse.Errors attribute)
(SHExecMemResponse.Errors attribute)
(SHFwdInputErr.Errors attribute)
(SHMultiProcessCreateResponse.Errors attribute)
(SHMultiProcessKillResponse.Errors attribute)
(SHPoolCreateResponse.Errors attribute)
(SHPoolDestroyResponse.Errors attribute)
(SHProcessCreateResponse.Errors attribute)
(SHProcessKillResponse.Errors attribute)
FAIL_KILL (GSProcessKillResponse.Errors attribute)
fc_type (Channel attribute)
FE_NODE_IDX_BE (MessageTypes attribute)
FE_OVERLAY_TRANSPORT_AGENT_MUID (in module dragon.infrastructure.facts)
Federated System
fence() (Batch method)
FENodeIdxBE (class in dragon.infrastructure.messages)
FIFO (LockType attribute)
(Type attribute)
FIFOLITE (Type attribute)
FIFOLock (class in dragon.locks)
FILE (PoolType attribute)
FileDescriptor (class in dragon.infrastructure.messages)
fileno() (Connection method)
filter() (DDict method)
(Store method)
filter_batch() (GuardrailsProcessor method)
filter_with_guardrails() (InferenceWorker method)
FilterContextManager (class in dragon.data.ddict)
finalize_fd() (FLIRecvH method)
(FLISendH method)
FinalResponse (class in dragon.ai.agent.reasoning.response_parser)
find() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
find_accelerators() (in module dragon.infrastructure.gpu_desc)
find_amd() (in module dragon.infrastructure.gpu_desc)
find_free_port() (in module dragon.ai.inference.llm_engine)
find_intel() (in module dragon.infrastructure.gpu_desc)
find_nvidia() (in module dragon.infrastructure.gpu_desc)
FIRST_BE_MUID (in module dragon.infrastructure.facts)
FIRST_CUID (in module dragon.infrastructure.facts)
FIRST_DEFAULT_MUID (in module dragon.infrastructure.facts)
FIRST_GUID (in module dragon.infrastructure.facts)
FIRST_LOGGING_MUID (in module dragon.infrastructure.facts)
FIRST_LS_MANAGED_MUID (in module dragon.infrastructure.facts)
FIRST_MUID (in module dragon.infrastructure.facts)
FIRST_PUID (in module dragon.infrastructure.facts)
FIRST_TRANSPORT_PUID (in module dragon.infrastructure.facts)
flask_secret_key (InferenceConfig attribute)
FLInterface (class in dragon.fli)
FLIRecvH (class in dragon.fli)
FLISendH (class in dragon.fli)
FlowControl (class in dragon.channels)
flush() (Peer2PeerWritingChannelFile method)
flush_batch() (DynamicBatcher method)
fn (PipelineNode attribute)
format() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
format_map() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
formatted_messages (InferenceRequest attribute)
formatted_prompts (Batch property)
forward (FENodeIdxBE property)
free() (MemoryAlloc method)
free_alloc() (DataMover static method)
(NumPyDataMover static method)
free_blocks (DDictManagerStats attribute)
(MemoryPool attribute)
free_space (MemoryPool attribute)
freeMem (DDGetResponse property)
(DDItemsResponse property)
(DDPopResponse property)
(DDValuesResponse property)
freeze (DDGetFreezeResponse property)
freeze() (DDict method)
(Store method)
freeze_support() (DragonContext method)
from_bytes() (Policy.Distribution class method)
(Policy.Placement class method)
(Policy.WaitMode class method)
from_dict() (InferenceConfig class method)
(Span class method)
(Trace class method)
from_env() (LaunchParameters static method)
from_message() (GatewayMessage static method)
from_sdict() (AcceleratorDescriptor class method)
(CapNProtoMsg class method)
(ChannelDescriptor class method)
(ChannelOptions static method)
(GroupDescriptor class method)
(GroupDescriptor.GroupMember class method)
(InfraMsg class method)
(NodeDescriptor class method)
(Policy class method)
(PoolDescriptor class method)
(PoolOptions static method)
(ProcessDescriptor class method)
(ProcessOptions static method)
(ProcessTemplate class method)
from_str() (B64 class method)
(HighSpeedTransportBackends static method)
(PMIBackend static method)
(TransportAgentOptions static method)
from_template() (Process class method)
fromdict() (PMIGroupInfo class method)
(PMIProcessInfo class method)
FRONTEND_HOSTID (in module dragon.infrastructure.facts)
FULL (MemoryStrategy attribute)
full() (DragonJoinableQueue method)
(DragonQueue method)
(Queue method)
Function (class in dragon.workflows.batch.batch)
function() (Batch method)
FunctionTool (class in dragon.ai.agent.tools.function_tool)
G
g_uid (GroupDescriptor attribute)
GatewayMessage (class in dragon.channels)
generate() (LLMInferenceEngine method)
generate_policies() (CollectorGroup method)
get() (ApplyResult method)
(DDictAccessor method)
(DragonJoinableQueue method)
(DragonQueue method)
(DragonSimpleQueue method)
(Function method)
(Job method)
(MapResult method)
(OutputQueue method)
(PriorityMultiMap method)
(Queue method)
(Store method)
(Task method)
(ToolRegistry method)
(WrappedResult method)
get_allocations() (MemoryPool method)
get_argdata_from_immediate_handshake() (in module dragon.globalservices.process)
get_cached_local_network_conf() (NodeDescriptor class method)
get_class_probabilities() (PromptGuard method)
get_complete() (GatewayMessage method)
get_cpu_count() (in module dragon.utils)
get_create_message() (in module dragon.globalservices.process)
get_create_message_with_argdata() (in module dragon.globalservices.process)
get_data() (AnalysisClient method)
get_dest_mem_descr_ser (GatewayMessage attribute)
get_env() (Proxy method)
get_external_ip_addr() (in module dragon.infrastructure.util)
get_going() (in module dragon.infrastructure.standalone_conn)
get_gs_ret_cuid() (in module dragon.globalservices.api_setup)
get_host_info() (in module dragon.infrastructure.util)
get_hugepage_mount() (in module dragon.utils)
get_indirect_injection_score() (PromptGuard method)
get_indirect_injection_scores_for_texts() (PromptGuard method)
get_input_output_queues() (DataMover method)
get_int_ptr() (MemoryAlloc method)
get_jailbreak_score() (PromptGuard method)
get_jailbreak_scores_for_texts() (PromptGuard method)
get_list() (DDictAccessor method)
(in module dragon.globalservices.channel)
(in module dragon.globalservices.group)
(in module dragon.globalservices.node)
(in module dragon.globalservices.pool)
(in module dragon.globalservices.process)
get_local_kv() (in module dragon.utils)
get_local_network_conf_cache_file_name() (NodeDescriptor class method)
get_local_node_network_conf() (NodeDescriptor class method)
get_local_rt_uid() (in module dragon.utils)
get_localservices_node_conf() (NodeDescriptor class method)
get_logger() (DragonContext method)
get_logging_dict() (LoggingMsg method)
get_malicious_response() (GuardrailsProcessor method)
get_manager_idx() (Function method)
(Job method)
(Task method)
get_memview() (MemoryAlloc method)
get_metrics() (AnalysisClient method)
get_multi_join_failure_puids() (in module dragon.globalservices.process)
get_multi_join_success_puids() (in module dragon.globalservices.process)
get_name() (DDict method)
(Store method)
get_new_id() (in module dragon.infrastructure.standalone_conn)
get_nodes_in_alloc() (Inference method)
get_nowait() (DragonJoinableQueue method)
(DragonQueue method)
(Queue method)
get_num_nics() (PMOD static method)
get_or_default() (DDictAccessor method)
get_original_python_parameters() (ProcessTemplate method)
get_pool() (Channel method)
get_port() (in module dragon.infrastructure.facts)
(in module dragon.infrastructure.util)
get_queues() (DataMovers method)
get_rc_string() (in module dragon.dtypes)
get_refcnt() (in module dragon.globalservices.channel)
get_remaining_data() (Many2ManyReadingChannelFile method)
get_remote_cwd() (Proxy method)
get_remote_python_executable() (Proxy method)
get_scores_for_texts() (PromptGuard method)
get_sdict() (AbnormalTermination method)
(AcceleratorDescriptor method)
(BEHalted method)
(BEHaltOverlay method)
(BEIsUp method)
(BENodeIdxSH method)
(BEPingSH method)
(Breakpoint method)
(CapNProtoMsg method)
(CapNProtoResponseMsg method)
(ChannelDescriptor method)
(ChannelOptions method)
(DDAdvance method)
(DDAdvanceResponse method)
(DDBatchPut method)
(DDBatchPutResponse method)
(DDBPut method)
(DDBPutResponse method)
(DDChkptAvail method)
(DDChkptAvailResponse method)
(DDClear method)
(DDConnectToManager method)
(DDConnectToManagerResponse method)
(DDContains method)
(DDCreate method)
(DDCreateManagerResponse method)
(DDDeregisterClient method)
(DDDestroy method)
(DDDestroyManager method)
(DDEmptyManagers method)
(DDEmptyManagersResponse method)
(DDFreeze method)
(DDGet method)
(DDGetFreeze method)
(DDGetFreezeResponse method)
(DDGetManagers method)
(DDGetManagersResponse method)
(DDGetMetaData method)
(DDGetMetaDataResponse method)
(DDGetResponse method)
(DDItems method)
(DDItemsResponse method)
(DDIterator method)
(DDIteratorNext method)
(DDIteratorResponse method)
(DDKeys method)
(DDLength method)
(DDLengthResponse method)
(DDManagerNewestChkptID method)
(DDManagerNewestChkptIDResponse method)
(DDManagerNodes method)
(DDManagerNodesResponse method)
(DDManagerSetState method)
(DDManagerStats method)
(DDManagerStatsResponse method)
(DDManagerSync method)
(DDMarkDrainedManagers method)
(DDPersist method)
(DDPersistChkpts method)
(DDPersistChkptsResponse method)
(DDPersistedChkptAvail method)
(DDPersistedChkptAvailResponse method)
(DDPop method)
(DDPopResponse method)
(DDPut method)
(DDRandomManager method)
(DDRandomManagerResponse method)
(DDRegisterClient method)
(DDRegisterClientID method)
(DDRegisterClientResponse method)
(DDRegisterManager method)
(DDRegisterManagerResponse method)
(DDRestore method)
(DDSync method)
(DDUnFreeze method)
(DDUnmarkDrainedManagers method)
(DDValues method)
(DDValuesResponse method)
(ExceptionlessAbort method)
(FENodeIdxBE method)
(GroupDescriptor method)
(GroupDescriptor.GroupMember method)
(GSChannelCreate method)
(GSChannelCreateResponse method)
(GSChannelDestroy method)
(GSChannelDestroyResponse method)
(GSChannelDetach method)
(GSChannelDetachResponse method)
(GSChannelGetRecvH method)
(GSChannelGetRecvHResponse method)
(GSChannelGetSendH method)
(GSChannelGetSendHResponse method)
(GSChannelJoin method)
(GSChannelJoinResponse method)
(GSChannelList method)
(GSChannelListResponse method)
(GSChannelQuery method)
(GSChannelQueryResponse method)
(GSChannelRelease method)
(GSDumpState method)
(GSGroupAddTo method)
(GSGroupAddToResponse method)
(GSGroupCreate method)
(GSGroupCreateAddTo method)
(GSGroupCreateAddToResponse method)
(GSGroupCreateResponse method)
(GSGroupDestroy method)
(GSGroupDestroyPMIx method)
(GSGroupDestroyPMIxResponse method)
(GSGroupDestroyRemoveFrom method)
(GSGroupDestroyRemoveFromResponse method)
(GSGroupDestroyResponse method)
(GSGroupKill method)
(GSGroupKillResponse method)
(GSGroupList method)
(GSGroupListResponse method)
(GSGroupQuery method)
(GSGroupQueryResponse method)
(GSGroupRemoveFrom method)
(GSGroupRemoveFromResponse method)
(GSHalted method)
(GSHeadExit method)
(GSIsUp method)
(GSNodeList method)
(GSNodeListResponse method)
(GSNodeQuery method)
(GSNodeQueryAll method)
(GSNodeQueryAllResponse method)
(GSNodeQueryResponse method)
(GSNodeQueryTotalCPUCount method)
(GSNodeQueryTotalCPUCountResponse method)
(GSPingProc method)
(GSPingSH method)
(GSPoolCreate method)
(GSPoolCreateResponse method)
(GSPoolDestroy method)
(GSPoolDestroyResponse method)
(GSPoolList method)
(GSPoolListResponse method)
(GSPoolQuery method)
(GSPoolQueryResponse method)
(GSProcessCreate method)
(GSProcessCreateResponse method)
(GSProcessJoin method)
(GSProcessJoinList method)
(GSProcessJoinListResponse method)
(GSProcessJoinResponse method)
(GSProcessKill method)
(GSProcessKillResponse method)
(GSProcessList method)
(GSProcessListResponse method)
(GSProcessQuery method)
(GSProcessQueryResponse method)
(GSRebootRuntime method)
(GSRebootRuntimeResponse method)
(GSStarted method)
(GSTeardown method)
(GSUnexpected method)
(HaltLoggingInfra method)
(HaltOverlay method)
(InfraMsg method)
(LABroadcast method)
(LAChannelsInfo method)
(LADumpState method)
(LAExit method)
(LAHaltOverlay method)
(LAPassThruBF method)
(LAPassThruFB method)
(LAProcessDict method)
(LAProcessDictResponse method)
(LAServerMode method)
(LAServerModeExit method)
(LogFlushed method)
(LoggingMsg method)
(LoggingMsgList method)
(LSDestroyPMIx method)
(LSDestroyPMIxResponse method)
(NodeDescriptor method)
(OverlayHalted method)
(OverlayPingBE method)
(OverlayPingLA method)
(PGAddProcessTemplates method)
(PGClientResponse method)
(PGClose method)
(PGJoin method)
(PGPuids method)
(PGRegisterClient method)
(PGSetProperties method)
(PGSignal method)
(PGStart method)
(PGState method)
(PGStop method)
(PGStopRestart method)
(PGUnregisterClient method)
(PMIxFenceMsg method)
(Policy method)
(PoolDescriptor method)
(PoolOptions method)
(ProcessDescriptor method)
(ProcessOptions method)
(ProcessTemplate method)
(RebootRuntime method)
(RuntimeDesc method)
(SHAllocBlock method)
(SHAllocBlockResponse method)
(SHAllocMsg method)
(SHAllocMsgResponse method)
(SHChannelCreate method)
(SHChannelCreateResponse method)
(SHChannelDestroy method)
(SHChannelDestroyResponse method)
(SHChannelsUp method)
(SHCreateProcessLocalChannel method)
(SHCreateProcessLocalChannelResponse method)
(SHCreateProcessLocalPool method)
(SHCreateProcessLocalPoolResponse method)
(SHDeregisterProcessLocalPool method)
(SHDestroyProcessLocalChannel method)
(SHDumpState method)
(SHExecMemRequest method)
(SHExecMemResponse method)
(SHFwdInput method)
(SHFwdInputErr method)
(SHFwdOutput method)
(SHGetKV method)
(SHGetKVL method)
(SHGetKVLResponse method)
(SHGetKVResponse method)
(SHHaltBE method)
(SHHalted method)
(SHHaltTA method)
(SHLockChannel method)
(SHLockChannelResponse method)
(SHMultiProcessCreate method)
(SHMultiProcessCreateResponse method)
(SHMultiProcessKill method)
(SHMultiProcessKillResponse method)
(SHPingBE method)
(SHPingGS method)
(SHPoolCreate method)
(SHPoolCreateResponse method)
(SHPoolDestroy method)
(SHPoolDestroyResponse method)
(SHPopKVL method)
(SHProcessCreate method)
(SHProcessCreateResponse method)
(SHProcessExit method)
(SHProcessKill method)
(SHProcessKillResponse method)
(SHPushKVL method)
(SHRegisterProcessLocalPool method)
(SHSetKV method)
(SHTeardown method)
(TAHalted method)
(TAPingSH method)
(TAUp method)
(TAUpdateNodes method)
(UserHaltOOB method)
get_timed_out() (PriorityMultiMap method)
get_timer (Store property)
get_timings() (TimeKeeper method)
get_tokenizer() (LLMInferenceEngine method)
get_value() (DragonBoundedSemaphore method)
(DragonSemaphore method)
(Semaphore method)
getitems() (Store method)
getlasterrstr() (in module dragon.dtypes)
(in module dragon.utils)
getName() (HitlTcpBridge method)
(TraceTcpBridge method)
ghost_close() (Connection method)
global_policy() (Policy class method)
GONE (GSPoolDestroyResponse.Errors attribute)
GPU (PoolType attribute)
gpu_affinity (Policy attribute)
gpu_env_str (Node property)
(Policy attribute)
gpu_policies() (System method)
gpu_vendor (Node property)
gpus (Node property)
GREEDY (LockType attribute)
(Type attribute)
GreedyLock (class in dragon.locks)
Group of resources
GroupDescriptor (class in dragon.infrastructure.group_desc)
GroupDescriptor.GroupMember (class in dragon.infrastructure.group_desc)
GroupDescriptor.GroupMember.Errors (class in dragon.infrastructure.group_desc)
GroupDescriptor.State (class in dragon.infrastructure.group_desc)
GroupError
GS_CHANNEL_CREATE (MessageTypes attribute)
GS_CHANNEL_CREATE_RESPONSE (MessageTypes attribute)
GS_CHANNEL_DESTROY (MessageTypes attribute)
GS_CHANNEL_DESTROY_RESPONSE (MessageTypes attribute)
GS_CHANNEL_DETACH (MessageTypes attribute)
GS_CHANNEL_DETACH_RESPONSE (MessageTypes attribute)
GS_CHANNEL_GET_RECVH (MessageTypes attribute)
GS_CHANNEL_GET_RECVH_RESPONSE (MessageTypes attribute)
GS_CHANNEL_GET_SENDH (MessageTypes attribute)
GS_CHANNEL_GET_SENDH_RESPONSE (MessageTypes attribute)
GS_CHANNEL_JOIN (MessageTypes attribute)
GS_CHANNEL_JOIN_RESPONSE (MessageTypes attribute)
GS_CHANNEL_LIST (MessageTypes attribute)
GS_CHANNEL_LIST_RESPONSE (MessageTypes attribute)
GS_CHANNEL_QUERY (MessageTypes attribute)
GS_CHANNEL_QUERY_RESPONSE (MessageTypes attribute)
GS_CHANNEL_RELEASE (MessageTypes attribute)
GS_DUMP_STATE (MessageTypes attribute)
GS_GROUP_ADD_TO (MessageTypes attribute)
GS_GROUP_ADD_TO_RESPONSE (MessageTypes attribute)
GS_GROUP_CREATE (MessageTypes attribute)
GS_GROUP_CREATE_ADD_TO (MessageTypes attribute)
GS_GROUP_CREATE_ADD_TO_RESPONSE (MessageTypes attribute)
GS_GROUP_CREATE_RESPONSE (MessageTypes attribute)
GS_GROUP_DESTROY (MessageTypes attribute)
GS_GROUP_DESTROY_PMIX (MessageTypes attribute)
GS_GROUP_DESTROY_PMIX_RESPONSE (MessageTypes attribute)
GS_GROUP_DESTROY_REMOVE_FROM (MessageTypes attribute)
GS_GROUP_DESTROY_REMOVE_FROM_RESPONSE (MessageTypes attribute)
GS_GROUP_DESTROY_RESPONSE (MessageTypes attribute)
GS_GROUP_KILL (MessageTypes attribute)
GS_GROUP_KILL_RESPONSE (MessageTypes attribute)
GS_GROUP_LIST (MessageTypes attribute)
GS_GROUP_LIST_RESPONSE (MessageTypes attribute)
GS_GROUP_QUERY (MessageTypes attribute)
GS_GROUP_QUERY_RESPONSE (MessageTypes attribute)
GS_GROUP_REMOVE_FROM (MessageTypes attribute)
GS_GROUP_REMOVE_FROM_RESPONSE (MessageTypes attribute)
GS_HALTED (MessageTypes attribute)
GS_HEAD_EXIT (MessageTypes attribute)
GS_INPUT_CUID (in module dragon.infrastructure.facts)
GS_IS_UP (MessageTypes attribute)
GS_NODE_LIST (MessageTypes attribute)
GS_NODE_LIST_RESPONSE (MessageTypes attribute)
GS_NODE_QUERY (MessageTypes attribute)
GS_NODE_QUERY_ALL (MessageTypes attribute)
GS_NODE_QUERY_ALL_RESPONSE (MessageTypes attribute)
GS_NODE_QUERY_RESPONSE (MessageTypes attribute)
GS_NODE_QUERY_TOTAL_CPU_COUNT (MessageTypes attribute)
GS_NODE_QUERY_TOTAL_CPU_COUNT_RESPONSE (MessageTypes attribute)
GS_PING_PROC (MessageTypes attribute)
GS_PING_SH (MessageTypes attribute)
GS_POOL_CREATE (MessageTypes attribute)
GS_POOL_CREATE_RESPONSE (MessageTypes attribute)
GS_POOL_DESTROY (MessageTypes attribute)
GS_POOL_DESTROY_RESPONSE (MessageTypes attribute)
GS_POOL_LIST (MessageTypes attribute)
GS_POOL_LIST_RESPONSE (MessageTypes attribute)
GS_POOL_QUERY (MessageTypes attribute)
GS_POOL_QUERY_RESPONSE (MessageTypes attribute)
GS_PROCESS_CREATE (MessageTypes attribute)
GS_PROCESS_CREATE_RESPONSE (MessageTypes attribute)
GS_PROCESS_JOIN (MessageTypes attribute)
GS_PROCESS_JOIN_LIST (MessageTypes attribute)
GS_PROCESS_JOIN_LIST_RESPONSE (MessageTypes attribute)
GS_PROCESS_JOIN_RESPONSE (MessageTypes attribute)
GS_PROCESS_KILL (MessageTypes attribute)
GS_PROCESS_KILL_RESPONSE (MessageTypes attribute)
GS_PROCESS_LIST (MessageTypes attribute)
GS_PROCESS_LIST_RESPONSE (MessageTypes attribute)
GS_PROCESS_QUERY (MessageTypes attribute)
GS_PROCESS_QUERY_RESPONSE (MessageTypes attribute)
GS_PUID (in module dragon.infrastructure.facts)
GS_REBOOT_RUNTIME (MessageTypes attribute)
GS_REBOOT_RUNTIME_RESPONSE (MessageTypes attribute)
gs_request() (in module dragon.globalservices.api_setup)
GS_STARTED (MessageTypes attribute)
GS_TEARDOWN (MessageTypes attribute)
GS_UNEXPECTED (MessageTypes attribute)
GSChannelCreate (class in dragon.infrastructure.messages)
GSChannelCreateResponse (class in dragon.infrastructure.messages)
GSChannelCreateResponse.Errors (class in dragon.infrastructure.messages)
GSChannelDestroy (class in dragon.infrastructure.messages)
GSChannelDestroyResponse (class in dragon.infrastructure.messages)
GSChannelDestroyResponse.Errors (class in dragon.infrastructure.messages)
GSChannelDetach (class in dragon.infrastructure.messages)
GSChannelDetachResponse (class in dragon.infrastructure.messages)
GSChannelDetachResponse.Errors (class in dragon.infrastructure.messages)
GSChannelGetRecvH (class in dragon.infrastructure.messages)
GSChannelGetRecvHResponse (class in dragon.infrastructure.messages)
GSChannelGetRecvHResponse.Errors (class in dragon.infrastructure.messages)
GSChannelGetSendH (class in dragon.infrastructure.messages)
GSChannelGetSendHResponse (class in dragon.infrastructure.messages)
GSChannelGetSendHResponse.Errors (class in dragon.infrastructure.messages)
GSChannelJoin (class in dragon.infrastructure.messages)
GSChannelJoinResponse (class in dragon.infrastructure.messages)
GSChannelJoinResponse.Errors (class in dragon.infrastructure.messages)
GSChannelList (class in dragon.infrastructure.messages)
GSChannelListResponse (class in dragon.infrastructure.messages)
GSChannelListResponse.Errors (class in dragon.infrastructure.messages)
GSChannelQuery (class in dragon.infrastructure.messages)
GSChannelQueryResponse (class in dragon.infrastructure.messages)
GSChannelQueryResponse.Errors (class in dragon.infrastructure.messages)
GSChannelRelease (class in dragon.infrastructure.messages)
GSDumpState (class in dragon.infrastructure.messages)
GSGroupAddTo (class in dragon.infrastructure.messages)
GSGroupAddToResponse (class in dragon.infrastructure.messages)
GSGroupAddToResponse.Errors (class in dragon.infrastructure.messages)
GSGroupCreate (class in dragon.infrastructure.messages)
GSGroupCreateAddTo (class in dragon.infrastructure.messages)
GSGroupCreateAddToResponse (class in dragon.infrastructure.messages)
GSGroupCreateAddToResponse.Errors (class in dragon.infrastructure.messages)
GSGroupCreateResponse (class in dragon.infrastructure.messages)
GSGroupDestroy (class in dragon.infrastructure.messages)
GSGroupDestroyPMIx (class in dragon.infrastructure.messages)
GSGroupDestroyPMIxResponse (class in dragon.infrastructure.messages)
GSGroupDestroyPMIxResponse.Errors (class in dragon.infrastructure.messages)
GSGroupDestroyRemoveFrom (class in dragon.infrastructure.messages)
GSGroupDestroyRemoveFromResponse (class in dragon.infrastructure.messages)
GSGroupDestroyRemoveFromResponse.Errors (class in dragon.infrastructure.messages)
GSGroupDestroyResponse (class in dragon.infrastructure.messages)
GSGroupDestroyResponse.Errors (class in dragon.infrastructure.messages)
GSGroupKill (class in dragon.infrastructure.messages)
GSGroupKillResponse (class in dragon.infrastructure.messages)
GSGroupKillResponse.Errors (class in dragon.infrastructure.messages)
GSGroupList (class in dragon.infrastructure.messages)
GSGroupListResponse (class in dragon.infrastructure.messages)
GSGroupListResponse.Errors (class in dragon.infrastructure.messages)
GSGroupQuery (class in dragon.infrastructure.messages)
GSGroupQueryResponse (class in dragon.infrastructure.messages)
GSGroupQueryResponse.Errors (class in dragon.infrastructure.messages)
GSGroupRemoveFrom (class in dragon.infrastructure.messages)
GSGroupRemoveFromResponse (class in dragon.infrastructure.messages)
GSGroupRemoveFromResponse.Errors (class in dragon.infrastructure.messages)
GSHalted (class in dragon.infrastructure.messages)
GSHeadExit (class in dragon.infrastructure.messages)
GSIsUp (class in dragon.infrastructure.messages)
GSNodeList (class in dragon.infrastructure.messages)
GSNodeListResponse (class in dragon.infrastructure.messages)
GSNodeListResponse.Errors (class in dragon.infrastructure.messages)
GSNodeQuery (class in dragon.infrastructure.messages)
GSNodeQueryAll (class in dragon.infrastructure.messages)
GSNodeQueryAllResponse (class in dragon.infrastructure.messages)
GSNodeQueryAllResponse.Errors (class in dragon.infrastructure.messages)
GSNodeQueryResponse (class in dragon.infrastructure.messages)
GSNodeQueryResponse.Errors (class in dragon.infrastructure.messages)
GSNodeQueryTotalCPUCount (class in dragon.infrastructure.messages)
GSNodeQueryTotalCPUCountResponse (class in dragon.infrastructure.messages)
GSNodeQueryTotalCPUCountResponse.Errors (class in dragon.infrastructure.messages)
GSPingProc (class in dragon.infrastructure.messages)
GSPingSH (class in dragon.infrastructure.messages)
GSPoolCreate (class in dragon.infrastructure.messages)
GSPoolCreateResponse (class in dragon.infrastructure.messages)
GSPoolCreateResponse.Errors (class in dragon.infrastructure.messages)
GSPoolDestroy (class in dragon.infrastructure.messages)
GSPoolDestroyResponse (class in dragon.infrastructure.messages)
GSPoolDestroyResponse.Errors (class in dragon.infrastructure.messages)
GSPoolList (class in dragon.infrastructure.messages)
GSPoolListResponse (class in dragon.infrastructure.messages)
GSPoolListResponse.Errors (class in dragon.infrastructure.messages)
GSPoolQuery (class in dragon.infrastructure.messages)
GSPoolQueryResponse (class in dragon.infrastructure.messages)
GSPoolQueryResponse.Errors (class in dragon.infrastructure.messages)
GSProcessCreate (class in dragon.infrastructure.messages)
GSProcessCreateResponse (class in dragon.infrastructure.messages)
GSProcessCreateResponse.Errors (class in dragon.infrastructure.messages)
GSProcessJoin (class in dragon.infrastructure.messages)
GSProcessJoinList (class in dragon.infrastructure.messages)
GSProcessJoinListResponse (class in dragon.infrastructure.messages)
GSProcessJoinListResponse.Errors (class in dragon.infrastructure.messages)
GSProcessJoinResponse (class in dragon.infrastructure.messages)
GSProcessJoinResponse.Errors (class in dragon.infrastructure.messages)
GSProcessKill (class in dragon.infrastructure.messages)
GSProcessKillResponse (class in dragon.infrastructure.messages)
GSProcessKillResponse.Errors (class in dragon.infrastructure.messages)
GSProcessList (class in dragon.infrastructure.messages)
GSProcessListResponse (class in dragon.infrastructure.messages)
GSProcessListResponse.Errors (class in dragon.infrastructure.messages)
GSProcessQuery (class in dragon.infrastructure.messages)
GSProcessQueryResponse (class in dragon.infrastructure.messages)
GSProcessQueryResponse.Errors (class in dragon.infrastructure.messages)
GSRebootRuntime (class in dragon.infrastructure.messages)
GSRebootRuntimeResponse (class in dragon.infrastructure.messages)
GSRebootRuntimeResponse.Errors (class in dragon.infrastructure.messages)
GSStarted (class in dragon.infrastructure.messages)
GSTeardown (class in dragon.infrastructure.messages)
GSUnexpected (class in dragon.infrastructure.messages)
guardrails (InferenceConfig attribute)
GuardrailsConfig (class in dragon.ai.inference.config)
GuardrailsProcessor (class in dragon.ai.inference.guardrails)
gw_cuid_from_index() (in module dragon.infrastructure.facts)
gw_env_vars (LaunchParameters attribute)
H
h_uid (Node property)
(Process property)
HALT_LOGGING_INFRA (MessageTypes attribute)
HALT_OVERLAY (MessageTypes attribute)
HaltLoggingInfra (class in dragon.infrastructure.messages)
HaltOverlay (class in dragon.infrastructure.messages)
hardware (InferenceConfig attribute)
HardwareConfig (class in dragon.ai.inference.config)
has() (ToolRegistry method)
hash() (in module dragon.utils)
header (Message attribute)
hf_token (ModelConfig attribute)
HighSpeedTransportBackends (class in dragon.infrastructure.facts)
hints (Message attribute)
HIP (AccEnvStr attribute)
hitl_address (DAGOrchestrator property)
HITL_APPROVAL (SpanKind attribute)
HITL_EVENT (MsgType attribute)
HITLBridgeError
HitlTcpBridge (class in dragon.ai.agent.hitl.tcp_bridge)
host_id (Policy attribute)
HOST_ID (Policy.Placement attribute)
host_id() (in module dragon.utils)
host_id_from_k8s() (in module dragon.utils)
host_map (PMIGroupInfo attribute)
host_name (Policy attribute)
HOST_NAME (Policy.Placement attribute)
hostID (DDRegisterManager property)
hostname (DDictManagerStats attribute)
(Node property)
hostname_policies() (System method)
HSTA (TransportAgentOptions attribute)
HUGEPAGE (PoolType attribute)
huids (DDManagerNodesResponse property)
HumanApprovalRequest (class in dragon.ai.agent.hitl.models)
HumanApprovalResponse (class in dragon.ai.agent.hitl.models)
I
id (MemoryAlloc attribute)
(Message attribute)
ident (DragonProcess property)
(HitlTcpBridge property)
(TraceTcpBridge property)
IDLE (NodeDescriptor.State attribute)
(Policy.WaitMode attribute)
imag (Policy.Distribution attribute)
(Policy.Placement attribute)
(Policy.WaitMode attribute)
imap() (DragonPool method)
imap_unordered() (DragonPool method)
import_func() (Batch method)
in_error_state (ProcessGroup property)
inactive_puids (ProcessGroup property)
inbound_channel (Connection property)
index() (InferenceRequest method)
(MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
index_from_default_pool_muid() (in module dragon.infrastructure.facts)
index_from_infrastructure_pool_muid() (in module dragon.infrastructure.facts)
index_from_shepherd_cuid() (in module dragon.infrastructure.facts)
Inference (class in dragon.ai.inference.inference_utils)
inference_queue (AgentConfig attribute)
InferenceConfig (class in dragon.ai.inference.config)
InferenceRequest (class in dragon.ai.inference.llm_proxy)
InferenceWorker (class in dragon.ai.inference.inference_worker_utils)
InfraMsg (class in dragon.infrastructure.messages)
InfraMsg.Errors (class in dragon.infrastructure.messages)
infrastructure_pool_muid_from_index() (in module dragon.infrastructure.facts)
init() (DragonLock static method)
(FIFOLock static method)
(GreedyLock static method)
(ProcessGroup method)
init_class_vars() (LaunchParameters class method)
initialize() (CPUWorker method)
(Inference method)
(LLMInferenceEngine method)
input_queue (AgentConfig attribute)
insert() (PriorityHeap method)
INTEL (AccEnvStr attribute)
(AccVendor attribute)
INVALID (InfraMsg.Errors attribute)
ip (Node property)
is_alive (Process property)
is_alive() (DragonProcess method)
(HitlTcpBridge method)
(TraceTcpBridge method)
is_buffered (FLInterface attribute)
is_closed (FLIRecvH attribute)
is_default_pool() (in module dragon.infrastructure.facts)
is_erasable() (Store method)
is_event_kind (GatewayMessage attribute)
is_feedback (HumanApprovalResponse attribute)
is_frozen (DDict property)
(Store property)
is_get_kind (GatewayMessage attribute)
is_listable() (Store method)
is_local (Channel attribute)
(MemoryPool attribute)
is_mine() (DragonLock method)
(DragonRLock method)
(Lock method)
is_pre_defined_pool() (in module dragon.infrastructure.facts)
is_primary (Node property)
is_readable() (Store method)
is_recursive() (DragonLock method)
(DragonRLock method)
(Lock method)
is_send_kind (GatewayMessage attribute)
is_send_return_immediately (GatewayMessage attribute)
is_send_return_when_buffered (GatewayMessage attribute)
is_send_return_when_deposited (GatewayMessage attribute)
is_send_return_when_received (GatewayMessage attribute)
is_set() (DragonEvent method)
(Event method)
is_the_same_as() (MemoryAlloc method)
is_transport_puid() (in module dragon.infrastructure.facts)
is_writeable() (Store method)
isalnum() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isalpha() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isascii() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isDaemon() (HitlTcpBridge method)
(TraceTcpBridge method)
isdecimal() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isdigit() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isidentifier() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
islower() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isnumeric() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isprintable() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isspace() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
istitle() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
isupper() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
item_type (DragonRawValue attribute)
(DragonValue attribute)
(Value attribute)
items() (DDict method)
(PriorityMultiMap method)
(Store method)
iterID (DDIteratorNext property)
(DDIteratorResponse property)
J
Job (class in dragon.workflows.batch.batch)
job() (Batch method)
job_id (PMIGroupInfo attribute)
(PMOD attribute)
join() (Batch method)
(DragonJoinableQueue method)
(DragonPool method)
(DragonProcess method)
(FLInterface method)
(HitlTcpBridge method)
(in module dragon.globalservices.channel)
(in module dragon.globalservices.process)
(MemoryStrategy method)
(MsgType method)
(Pool method)
(Process method)
(ProcessGroup method)
(Queue method)
(SpanKind method)
(TaskStatus method)
(TraceTcpBridge method)
join_thread() (DragonJoinableQueue method)
(DragonQueue method)
JoinableQueue() (DragonContext method)
json_schema_list (Batch property)
K
key (DDContains property)
(DDGet property)
(DDPop property)
(SHGetKV property)
(SHGetKVL property)
(SHPopKVL property)
(SHPushKVL property)
(SHSetKV property)
keys() (DDict method)
(PriorityMultiMap method)
(Store method)
kill() (DragonPool method)
(DragonProcess method)
(in module dragon.globalservices.group)
(in module dragon.globalservices.process)
(Pool method)
(Popen method)
(Process method)
(ProcessGroup method)
kill_by_exception() (ExceptionalThread method)
kind (Span attribute)
L
LA_BROADCAST (MessageTypes attribute)
LA_CHANNELS_INFO (MessageTypes attribute)
LA_DUMP_STATE (MessageTypes attribute)
LA_EXIT (MessageTypes attribute)
LA_HALT_OVERLAY (MessageTypes attribute)
LA_PASS_THRU_BF (MessageTypes attribute)
LA_PASS_THRU_FB (MessageTypes attribute)
LA_PROCESS_DICT (MessageTypes attribute)
LA_PROCESS_DICT_RESPONSE (MessageTypes attribute)
LA_SERVER_MODE (MessageTypes attribute)
LA_SERVER_MODE_EXIT (MessageTypes attribute)
LABroadcast (class in dragon.infrastructure.messages)
LAChannelsInfo (class in dragon.infrastructure.messages)
LADumpState (class in dragon.infrastructure.messages)
LAExit (class in dragon.infrastructure.messages)
LAHaltOverlay (class in dragon.infrastructure.messages)
LAPassThruBF (class in dragon.infrastructure.messages)
LAPassThruFB (class in dragon.infrastructure.messages)
LAProcessDict (class in dragon.infrastructure.messages)
LAProcessDictResponse (class in dragon.infrastructure.messages)
LAProcessDictResponse.Errors (class in dragon.infrastructure.messages)
LAServerMode (class in dragon.infrastructure.messages)
LAServerModeExit (class in dragon.infrastructure.messages)
LAServerModeExit.Errors (class in dragon.infrastructure.messages)
latency_metrics (Batch property)
launcher_cuid_from_index() (in module dragon.infrastructure.facts)
LAUNCHER_PUID (in module dragon.infrastructure.facts)
LaunchParameters (class in dragon.infrastructure.parameters)
length (DDLengthResponse property)
level (Telemetry property)
lib_err (DragonException property)
(PMODError property)
list_tools() (DragonAgent method)
(SubAgent method)
(ToolRegistry method)
listdir() (Store method)
listen() (DragonAgent method)
(SubAgent method)
Listener() (DragonContext method)
LITE (LockType attribute)
ljust() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
LLM_CALL (SpanKind attribute)
LLM_EVENT (MsgType attribute)
llm_inference_entry_point() (InferenceWorker static method)
LLMInferenceEngine (class in dragon.ai.inference.llm_engine)
LLMProxy (class in dragon.ai.inference.llm_proxy)
load() (CheckpointPersister method)
(DAOSCheckpointPersister method)
(NULLCheckpointPersister method)
(PosixCheckpointPersister method)
(XNumPy2DPickler method)
(XScalarPickler method)
(XStringPickler method)
load_cmplt() (Store method)
load_launch_parameter() (in module dragon.globalservices.api_setup)
load_metadata() (CheckpointPersister class method)
(DAOSCheckpointPersister class method)
(NULLCheckpointPersister class method)
(PosixCheckpointPersister class method)
load_model_and_tokenizer() (PromptGuard method)
loaded_bytes (Store property)
loads() (XNumPy2DPickler method)
(XScalarPickler method)
(XStringPickler method)
LOCAL (Policy.Placement attribute)
(PoolOptions.Placement attribute)
local_items() (DDict method)
(Store method)
local_keys() (DDict method)
(Store method)
LOCAL_LAUNCH_TIMEOUT (in module dragon.infrastructure.facts)
local_len() (DDict method)
(Store method)
local_manager (DDict property)
(Store property)
local_managers (DDict property)
(Store property)
local_pool_first_muid() (in module dragon.infrastructure.facts)
local_values() (DDict method)
(Store method)
Lock (class in dragon.native.lock)
Lock() (DragonContext method)
lock() (DragonLock method)
(FIFOLock method)
(GreedyLock method)
lock_type (Channel attribute)
LockType (class in dragon.channels)
LOG_FLUSHED (MessageTypes attribute)
log_to_stderr() (DragonContext method)
LogFlushed (class in dragon.infrastructure.messages)
logger_sdesc (BENodeIdxSH property)
LOGGING_MSG (MessageTypes attribute)
LOGGING_MSG_LIST (MessageTypes attribute)
logging_pool_muid_from_index() (in module dragon.infrastructure.facts)
LoggingMsg (class in dragon.infrastructure.messages)
LoggingMsgList (class in dragon.infrastructure.messages)
lookup() (in module dragon.workflows.runtime)
lower() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
lrank (PMIProcessInfo attribute)
LS_DESTROY_PMIX (MessageTypes attribute)
LS_DESTROY_PMIX_RESPONSE (MessageTypes attribute)
LSDestroyPMIx (class in dragon.infrastructure.messages)
LSDestroyPMIxResponse (class in dragon.infrastructure.messages)
LSDestroyPMIxResponse.Errors (class in dragon.infrastructure.messages)
lstrip() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
M
main() (in module dragon.workflows.parsl_executor)
main_manager (DDict property)
(Store property)
mainFLI (DDRegisterManager property)
make_dispatcher_fn() (in module dragon.ai.agent.core.batch_dispatch)
make_process_local() (Channel class method)
(MemoryPool class method)
MakeTask (class in dragon.workflows.batch.batch)
maketrans() (MemoryStrategy static method)
(MsgType static method)
(SpanKind static method)
(TaskStatus static method)
Managed Object
manager (DDConnectToManagerResponse property)
(DDRandomManagerResponse property)
manager() (DDict method)
Manager() (DragonContext method)
manager() (Store method)
manager_hostnames (BatchTopology attribute)
manager_id (DDictManagerStats attribute)
manager_nodes (DDict property)
(Store property)
managerID (DDBatchPutResponse property)
(DDBPutResponse property)
(DDChkptAvailResponse property)
(DDConnectToManager property)
(DDCreateManagerResponse property)
(DDManagerNewestChkptIDResponse property)
(DDPersistedChkptAvailResponse property)
(DDRandomManagerResponse property)
(DDRegisterClientResponse property)
(DDRegisterManager property)
managerIDs (DDMarkDrainedManagers property)
(DDUnmarkDrainedManagers property)
managerNodes (DDRegisterClientResponse property)
(DDRegisterManagerResponse property)
managers (DDBPut property)
(DDEmptyManagersResponse property)
(DDGetManagersResponse property)
(DDRegisterManagerResponse property)
Many2ManyReadingChannelFile (class in dragon.channels)
Many2ManyWritingChannelFile (class in dragon.channels)
map() (DragonPool method)
map_async() (DragonPool method)
(Pool method)
mapping (DDictItemsView property)
(DDictKeysView property)
(DDictValuesView property)
MapResult (class in dragon.native.pool)
mark_payload_sent() (GatewayMessage method)
MASQUERADE_AS_REMOTE (ChannelFlags attribute)
master_addr (RankInfo property)
master_port (RankInfo property)
MAX (SHFwdInput attribute)
(SHFwdOutput attribute)
max_allocations (MemoryPool attribute)
max_batch_size (BatchingConfig attribute)
max_concurrent_requests (AgentConfig attribute)
max_kept_turns (MemoryConfig attribute)
max_model_len (ModelConfig attribute)
max_pool_allocations (DDictManagerStats attribute)
max_pool_allocations_used (DDictManagerStats attribute)
max_retries (MCPServerConfig attribute)
max_tokens (ModelConfig attribute)
max_tool_call_iterations (AgentConfig attribute)
max_tool_result_chars (MemoryConfig attribute)
max_used_allocations (MemoryPool attribute)
maybe_subset_nodes_gpus() (Inference method)
maybe_summarize() (ContextManager method)
MCPServerClient (class in dragon.ai.agent.tools.mcp_tool)
MCPServerConfig (class in dragon.ai.agent.config.agent_config)
memory (AgentConfig attribute)
MEMORY_ALLOC_REQUEST (SHExecMemRequest.KINDS attribute)
MEMORY_EVENT (MsgType attribute)
MEMORY_FLOW_CONTROL (FlowControl attribute)
MEMORY_POOL_REQUEST (SHExecMemRequest.KINDS attribute)
MEMORY_PRUNE (SpanKind attribute)
MEMORY_SUMMARIZE (SpanKind attribute)
MemoryAlloc (class in dragon.managed_memory)
MemoryAllocations (class in dragon.managed_memory)
MemoryConfig (class in dragon.ai.agent.config.memory_config)
MemoryPool (class in dragon.managed_memory)
MemoryStrategy (class in dragon.ai.agent.config.memory_config)
merge() (Policy class method)
Message (class in dragon.ai.agent.communication.message)
(class in dragon.channels)
messages (InferenceRequest attribute)
MessageTypes (class in dragon.infrastructure.messages)
metadata (TaskResult attribute)
MetricCollector (class in dragon.telemetry.analysis)
MetricsConsolidator (class in dragon.ai.inference.reader_utils)
min_active_workers_per_cpu (DynamicWorkerConfig attribute)
minBlockSize (SHCreateProcessLocalPool property)
mk_all_message_classes_set() (in module dragon.infrastructure.messages)
mk_argmode_from_default() (in module dragon.infrastructure.process_desc)
mk_capture_threads() (in module dragon.globalservices.process)
mk_fifo_debugger() (in module dragon.infrastructure.util)
model (InferenceConfig attribute)
model_name (ModelConfig attribute)
ModelConfig (class in dragon.ai.inference.config)
module
dragon.ai.collective_group
dragon.channels
dragon.dlogging.logger
dragon.dtypes
dragon.fli
dragon.globalservices.api_setup
dragon.globalservices.channel
dragon.globalservices.group
dragon.globalservices.node
dragon.globalservices.pool
dragon.globalservices.process
dragon.infrastructure.channel_desc
dragon.infrastructure.facts
dragon.infrastructure.gpu_desc
dragon.infrastructure.group_desc
dragon.infrastructure.messages
dragon.infrastructure.node_desc
dragon.infrastructure.parameters
dragon.infrastructure.pool_desc
dragon.infrastructure.process_desc
dragon.infrastructure.standalone_conn
dragon.infrastructure.util
dragon.locks
dragon.managed_memory
dragon.native.array
dragon.native.barrier
dragon.native.event
dragon.native.lock
dragon.native.machine
dragon.native.process
dragon.native.queue
dragon.native.semaphore
dragon.native.value
dragon.pheap
dragon.pmod
dragon.telemetry.analysis
dragon.telemetry.telemetry
dragon.transport
dragon.transport.overlay
dragon.utils
dragon.workflows.data_mover
dragon.workflows.parsl_batch_executor
dragon.workflows.parsl_executor
dragon.workflows.parsl_mpi_app
monitor_resources() (DragonBatchPoolExecutor method)
(DragonPoolExecutor method)
mpi_app() (in module dragon.workflows.parsl_mpi_app)
MPIApp (class in dragon.workflows.parsl_mpi_app)
MSGS_FLOW_CONTROL (FlowControl attribute)
MsgType (class in dragon.ai.agent.observability.trace_protocol)
muid (MemoryPool attribute)
(SHCreateProcessLocalChannel property)
multi_join() (in module dragon.globalservices.process)
my_local_rank (RankInfo property)
my_local_world_size (RankInfo property)
my_node_rank (RankInfo property)
my_rank (RankInfo property)
N
n_waiting (Barrier property)
(DragonBarrier property)
name (AgentConfig attribute)
(BaseTool attribute)
(DataMover property)
(DDRegisterClientResponse property)
(DragonProcess property)
(FunctionTool attribute)
(GroupDescriptor attribute)
(HitlTcpBridge property)
(Node property)
(Process property)
(SHCreateProcessLocalPool property)
(Span attribute)
(ToolCall attribute)
(Trace attribute)
(TraceTcpBridge property)
native_id (HitlTcpBridge property)
(TraceTcpBridge property)
new_task() (FLInterface method)
NewlineStreamWrapper (class in dragon.infrastructure.util)
next_deadline() (PriorityMultiMap method)
next_tag() (in module dragon.globalservices.api_setup)
nid (PMIProcessInfo attribute)
(PMOD attribute)
nid_map (PMIGroupInfo attribute)
nnodes (PMIGroupInfo attribute)
(PMOD attribute)
(System property)
no_close_on_exit() (FLIRecvH method)
NO_FLAGS (ChannelFlags attribute)
NO_FLOW_CONTROL (FlowControl attribute)
nocast() (in module dragon.infrastructure.parameters)
nocheck() (in module dragon.infrastructure.parameters)
Node
(class in dragon.native.machine)
node (Process property)
(Queue property)
node_affinity (AgentConfig attribute)
NODE_LOCAL_PARAMS (LaunchParameters attribute)
node_offset (HardwareConfig attribute)
NodeDescriptor (class in dragon.infrastructure.node_desc)
NodeDescriptor.State (class in dragon.infrastructure.node_desc)
nodes (Pipeline attribute)
(System property)
(TAUpdateNodes property)
NONE (ArgMode attribute)
nonnegative() (in module dragon.infrastructure.parameters)
NOT_ATTACHED (GSChannelDetachResponse.Errors attribute)
(GSChannelGetRecvHResponse.Errors attribute)
(GSChannelGetSendHResponse.Errors attribute)
notify() (DragonCondition method)
notify_all() (DragonCondition method)
notify_on_destroy() (Channel method)
now() (TimeKeeper method)
nranks (PMIGroupInfo attribute)
(PMOD attribute)
NULL (NodeDescriptor.State attribute)
NULLCheckpointPersister (class in dragon.data.ddict)
num_allocs (MemoryAllocations attribute)
num_available_streams() (FLInterface method)
num_block_sizes (MemoryPool attribute)
num_cpus (Node property)
num_gpus (HardwareConfig attribute)
(Node property)
num_inf_workers_per_cpu (HardwareConfig attribute)
num_keys (DDictManagerStats attribute)
num_msgs (Channel attribute)
num_nodes (HardwareConfig attribute)
numerator (Policy.Distribution attribute)
(Policy.Placement attribute)
(Policy.WaitMode attribute)
numManagers (DDGetMetaDataResponse property)
(DDRegisterClientResponse property)
numPuts (DDBatchPutResponse property)
(DDBPutResponse property)
NumPyDataMover (class in dragon.workflows.data_mover)
NumPyInputQueue (class in dragon.workflows.data_mover)
NumPyOptimizedDataMover (class in dragon.workflows.data_mover)
NumPyOptimizedInputQueue (class in dragon.workflows.data_mover)
NVIDIA (AccEnvStr attribute)
(AccVendor attribute)
O
OBJ_TO_BYTES (ValueConversion attribute)
Object Name
Object UID
OFI (HighSpeedTransportBackends attribute)
on_span_end() (DictTracingProcessor method)
(TracingProcessor method)
on_span_start() (DictTracingProcessor method)
(TracingProcessor method)
open() (ChannelRecvH method)
(ChannelSendH method)
(Connection method)
(Many2ManyReadingChannelFile method)
(Many2ManyWritingChannelFile method)
(Peer2PeerReadingChannelFile method)
(Peer2PeerWritingChannelFile method)
options (GSChannelCreate property)
(GSPoolCreate property)
(GSProcessCreate property)
(SHChannelCreate property)
(SHProcessCreate property)
OrchestratorConfig (class in dragon.ai.agent.config.agent_config)
outbound_channel (Connection property)
OutputQueue (class in dragon.workflows.data_mover)
OVERLAY_HALTED (MessageTypes attribute)
OVERLAY_PING_BE (MessageTypes attribute)
OVERLAY_PING_LA (MessageTypes attribute)
OverlayHalted (class in dragon.infrastructure.messages)
OverlayPingBE (class in dragon.infrastructure.messages)
OverlayPingLA (class in dragon.infrastructure.messages)
OwnershipOnSend (class in dragon.channels)
P
padding_side (ModelConfig attribute)
parent() (Process method)
parent_id (Span attribute)
parent_process() (DragonContext static method)
ParmError
PARMS (LaunchParameters attribute)
parse() (in module dragon.infrastructure.messages)
parties (Barrier property)
(DragonBarrier property)
partition() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
Peer2PeerReadingChannelFile (class in dragon.channels)
Peer2PeerWritingChannelFile (class in dragon.channels)
PENDING (ChannelDescriptor.State attribute)
(GroupDescriptor.State attribute)
(GSGroupAddToResponse.Errors attribute)
(GSGroupCreateAddToResponse.Errors attribute)
(GSGroupDestroyRemoveFromResponse.Errors attribute)
(GSGroupDestroyResponse.Errors attribute)
(GSGroupKillResponse.Errors attribute)
(GSGroupRemoveFromResponse.Errors attribute)
(GSPoolDestroyResponse.Errors attribute)
(GSProcessJoinListResponse.Errors attribute)
(GSProcessKillResponse.Errors attribute)
(GSRebootRuntimeResponse.Errors attribute)
(NodeDescriptor.State attribute)
(PoolDescriptor.State attribute)
(ProcessDescriptor.State attribute)
persist (DDBatchPut property)
(DDPut property)
persist() (DDict method)
(Store method)
persisted_ids() (DDict method)
(Store method)
PG_ADD_PROCESS_TEMPLATES (MessageTypes attribute)
PG_CLIENT_RESPONSE (MessageTypes attribute)
PG_CLOSE (MessageTypes attribute)
PG_JOIN (MessageTypes attribute)
PG_PUIDS (MessageTypes attribute)
PG_REGISTER_CLIENT (MessageTypes attribute)
PG_SET_PROPERTIES (MessageTypes attribute)
PG_SIGNAL (MessageTypes attribute)
PG_START (MessageTypes attribute)
PG_STATE (MessageTypes attribute)
PG_STOP (MessageTypes attribute)
PG_STOP_RESTART (MessageTypes attribute)
PG_UNREGISTER_CLIENT (MessageTypes attribute)
PGAddProcessTemplates (class in dragon.infrastructure.messages)
PGClientResponse (class in dragon.infrastructure.messages)
PGClose (class in dragon.infrastructure.messages)
PGJoin (class in dragon.infrastructure.messages)
PGPuids (class in dragon.infrastructure.messages)
PGRegisterClient (class in dragon.infrastructure.messages)
PGSetProperties (class in dragon.infrastructure.messages)
PGSignal (class in dragon.infrastructure.messages)
PGStart (class in dragon.infrastructure.messages)
PGState (class in dragon.infrastructure.messages)
PGStop (class in dragon.infrastructure.messages)
PGStopRestart (class in dragon.infrastructure.messages)
PGUnregisterClient (class in dragon.infrastructure.messages)
physical_mem (Node property)
PICKLE_PROT_5 (ChannelAdapterMsgTypes attribute)
pickler() (DDict method)
(Store method)
PickleReadAdapter (class in dragon.fli)
PickleWriteAdapter (class in dragon.fli)
pid (DragonProcess property)
(Popen property)
pid_base (PMIProcessInfo attribute)
PIPE (Popen attribute)
(ProcessTemplate attribute)
Pipe() (DragonContext method)
(in module dragon.infrastructure.connection)
(in module dragon.infrastructure.standalone_conn)
Pipeline (class in dragon.ai.agent.config.pipeline)
PIPELINE (SpanKind attribute)
PipelineNode (class in dragon.ai.agent.config.pipeline)
PipeOptions (class in dragon.infrastructure.connection)
PipeOptions.CreationPolicy (class in dragon.infrastructure.connection)
placement (GroupDescriptor.GroupMember attribute)
(Policy attribute)
PMIBackend (class in dragon.infrastructure.facts)
PMIGroupInfo (class in dragon.infrastructure.messages)
PMIProcessInfo (class in dragon.infrastructure.messages)
PMIX (PMIBackend attribute)
pmix_desc (PMIGroupInfo attribute)
PMIX_FENCE_MSG (MessageTypes attribute)
pmix_nid (PMIProcessInfo attribute)
PMIxFenceMsg (class in dragon.infrastructure.messages)
PMOD (class in dragon.pmod)
pmod_launch_cuid_from_jobinfo() (in module dragon.infrastructure.facts)
PMODError
Policy
(class in dragon.infrastructure.parameters)
(class in dragon.infrastructure.policy)
policy (GroupDescriptor attribute)
Policy.Distribution (class in dragon.infrastructure.policy)
Policy.Placement (class in dragon.infrastructure.policy)
Policy.WaitMode (class in dragon.infrastructure.policy)
poll() (Channel method)
(ChannelSet method)
(Connection method)
(NewlineStreamWrapper method)
(Popen method)
(Queue method)
poll_interval (OrchestratorConfig attribute)
poll_timeout (OrchestratorConfig attribute)
POLLBARRIER (EventType attribute)
POLLBARRIER_ABORT (EventType attribute)
POLLBARRIER_ISBROKEN (EventType attribute)
POLLBARRIER_RELEASE (EventType attribute)
POLLBARRIER_WAITERS (EventType attribute)
POLLBLOCKED_RECEIVERS (EventType attribute)
POLLEMPTY (EventType attribute)
POLLFULL (EventType attribute)
POLLIN (EventType attribute)
POLLINOUT (EventType attribute)
POLLNOTHING (EventType attribute)
POLLOUT (EventType attribute)
POLLRESET (EventType attribute)
PollResult (class in dragon.channels)
POLLSIZE (EventType attribute)
Pool (class in dragon.native.pool)
pool (MemoryAlloc attribute)
Pool() (DragonContext method)
pool_available (DragonQueueLLMProxy property)
(ResponseQueuePool property)
pool_free_space (DDictManagerStats attribute)
pool_hostnames (BatchTopology attribute)
pool_utilization (DDictManagerStats attribute)
PoolDescriptor (class in dragon.infrastructure.pool_desc)
PoolDescriptor.State (class in dragon.infrastructure.pool_desc)
PoolError
PoolOptions (class in dragon.infrastructure.pool_desc)
PoolOptions.Placement (class in dragon.infrastructure.pool_desc)
poolSdesc (DDRegisterManager property)
PoolType (class in dragon.managed_memory)
pop() (DDict method)
(Store method)
Popen (class in dragon.native.process)
popitem() (DDict method)
(Store method)
port_check() (in module dragon.infrastructure.facts)
(in module dragon.infrastructure.util)
position() (CheckpointPersister method)
(DAOSCheckpointPersister method)
(NULLCheckpointPersister method)
(PosixCheckpointPersister method)
positive() (in module dragon.infrastructure.parameters)
PosixCheckpointPersister (class in dragon.data.ddict)
ppn (PMIProcessInfo attribute)
(PMOD attribute)
pput() (DDict method)
(Store method)
PRE_CREATED (ConnectionOptions.CreationPolicy attribute)
preAllocs (SHCreateProcessLocalPool property)
prepare() (CheckpointPersister class method)
(DAOSCheckpointPersister class method)
(NULLCheckpointPersister class method)
(PosixCheckpointPersister class method)
prepare_argdata_for_immediate() (in module dragon.globalservices.process)
preprocess_text_for_promptguard() (PromptGuard method)
preprocessing_entry_point() (InferenceWorker static method)
Primary Object
primary_node (System property)
PriorityHeap (class in dragon.pheap)
PriorityMultiMap (class in dragon.infrastructure.util)
PRIVATE (PoolType attribute)
Process (class in dragon.native.process)
(DragonContext attribute)
process() (Batch method)
(DragonAgent method)
(SubAgent method)
process_local_register_with_gpu() (MemoryPool method)
process_local_unregister_with_gpu() (MemoryPool method)
process_prebatched() (InferenceWorker method)
process_single_prompts() (InferenceWorker method)
process_text_batch() (PromptGuard method)
process_with_batching() (InferenceWorker method)
ProcessDescriptor (class in dragon.infrastructure.process_desc)
ProcessDescriptor.State (class in dragon.infrastructure.process_desc)
ProcessError
ProcessGroup (class in dragon.native.process_group)
PROCESSING (TaskStatus attribute)
ProcessOptions (class in dragon.infrastructure.process_desc)
ProcessTemplate (class in dragon.native.process)
profile() (DDict method)
(Store method)
profile_reset() (DDict method)
(Store method)
prompt_guard_model (GuardrailsConfig attribute)
prompt_guard_sensitivity (GuardrailsConfig attribute)
PromptGuard (class in dragon.ai.inference.prompt_guard_utils)
Proxy (class in dragon.workflows.runtime)
PseudoStructure (class in dragon.native.value)
publish() (in module dragon.workflows.runtime)
puid (Popen property)
(Process property)
(SHCreateProcessLocalChannel property)
(SHCreateProcessLocalPool property)
(SHDeregisterProcessLocalPool property)
(SHDestroyProcessLocalChannel property)
(SHRegisterProcessLocalPool property)
puids (ProcessGroup property)
put() (CuPyInputQueue method)
(DDictAccessor method)
(DragonJoinableQueue method)
(DragonQueue method)
(DragonSimpleQueue method)
(NumPyInputQueue method)
(NumPyOptimizedInputQueue method)
(PriorityMultiMap method)
(Queue method)
put_nowait() (DragonJoinableQueue method)
(DragonQueue method)
(Queue method)
PYTHON_CHANNEL (ArgMode attribute)
PYTHON_IMMEDIATE (ArgMode attribute)
Q
qsize() (DragonJoinableQueue method)
(DragonQueue method)
query() (in module dragon.globalservices.channel)
(in module dragon.globalservices.group)
(in module dragon.globalservices.node)
(in module dragon.globalservices.pool)
(in module dragon.globalservices.process)
(Inference method)
query_all() (in module dragon.globalservices.node)
query_total_cpus() (in module dragon.globalservices.node)
Queue (class in dragon.native.queue)
Queue() (DragonContext method)
QueueError
R
RANGE_BE_CUID (in module dragon.infrastructure.facts)
RANGE_BE_FE_CUID (in module dragon.infrastructure.facts)
RANGE_BE_GW_CUID (in module dragon.infrastructure.facts)
RANGE_BE_LOCAL_CUID (in module dragon.infrastructure.facts)
RANGE_BE_MUID (in module dragon.infrastructure.facts)
range_expr() (in module dragon.infrastructure.util)
RANGE_GW_CUID (in module dragon.infrastructure.facts)
RANGE_LOG_CUID (in module dragon.infrastructure.facts)
RANGE_LS_MUIDS_PER_NODE (in module dragon.infrastructure.facts)
RANGE_PMOD_LAUNCH_CUID (in module dragon.infrastructure.facts)
RANGE_SHEP_CUID (in module dragon.infrastructure.facts)
RANGE_TA_CUID (in module dragon.infrastructure.facts)
RANGE_TRANSPORT_PUID (in module dragon.infrastructure.facts)
RANGE_USER_MANAGED_CUID (in module dragon.infrastructure.facts)
RankInfo (class in dragon.ai.collective_group)
raw (Array property)
(DDictAccessor property)
(DragonArray property)
(DragonRawArray property)
RAW_BYTES (ChannelAdapterMsgTypes attribute)
RawArray() (DragonContext method)
RawValue() (DragonContext method)
rc (DragonFLIError property)
(PollResult property)
read() (Batch method)
(Many2ManyReadingChannelFile method)
(Peer2PeerReadingChannelFile method)
(PickleReadAdapter method)
(ReadWorker method)
read_and_compute() (MetricsConsolidator method)
readable (Connection property)
readinto() (Many2ManyReadingChannelFile method)
(Peer2PeerReadingChannelFile method)
readline() (Many2ManyReadingChannelFile method)
(Peer2PeerReadingChannelFile method)
(PickleReadAdapter method)
ReadWorker (class in dragon.ai.inference.reader_utils)
READY (Connection.State attribute)
(TaskStatus attribute)
ready() (ApplyResult method)
(MapResult method)
(WrappedResult method)
real (Policy.Distribution attribute)
(Policy.Placement attribute)
(Policy.WaitMode attribute)
reason (HumanApprovalResponse attribute)
reboot() (AnalysisClient method)
REBOOT_RUNTIME (MessageTypes attribute)
RebootRuntime (class in dragon.infrastructure.messages)
receive() (CommunicationProtocol method)
(DragonQueueProtocol method)
RECEIVER_CREATES (ConnectionOptions.CreationPolicy attribute)
(PipeOptions.CreationPolicy attribute)
recipient_id (Message attribute)
recipient_serialized_queue (Message attribute)
reconstruct() (CuPyDataMover static method)
(CuPyOptimizedDataMover static method)
(DataMover static method)
(NumPyDataMover static method)
record() (TimeKeeper method)
records (LoggingMsgList property)
recv() (ChannelRecvH method)
(Connection method)
(NewlineStreamWrapper method)
recv_bytes() (ChannelRecvH method)
(Connection method)
(FLIRecvH method)
recv_bytes_into() (Connection method)
(FLIRecvH method)
recv_mem() (FLIRecvH method)
recvh (GSChannelGetRecvHResponse property)
recvh() (Channel method)
(FLInterface method)
RecvNotifType (class in dragon.dtypes)
reducer (DragonContext property)
ref (CapNProtoResponseMsg property)
(InfraMsg property)
refcounted (Policy attribute)
Refcounted Object
register() (MemoryPool method)
(ToolRegistry method)
register_gateways_from_env() (in module dragon.channels)
release() (Array method)
(DragonArray method)
(DragonBoundedSemaphore method)
(DragonLock method)
(DragonRawArray method)
(DragonRLock method)
(DragonSemaphore method)
(DragonValue method)
(Lock method)
(ResponseQueuePool method)
(Semaphore method)
release_refcnt() (in module dragon.globalservices.channel)
reload_this_process() (in module dragon.infrastructure.parameters)
remove() (PriorityMultiMap method)
remove_cached_local_network_conf() (NodeDescriptor class method)
remove_from() (in module dragon.globalservices.group)
remove_node_local_evars() (LaunchParameters class method)
remove_one() (PriorityMultiMap method)
removeprefix() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
removesuffix() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
rename() (Store method)
replace() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
request_human_approval() (in module dragon.ai.agent.hitl.approval)
reset() (Barrier method)
(DragonBarrier method)
(TimeKeeper method)
reset_all() (TimeKeeper method)
reset_get_timer() (Store method)
resilient (GroupDescriptor attribute)
resolve() (MemoryConfig static method)
resolve_args() (in module dragon.transport)
RESOURCES_FLOW_CONTROL (FlowControl attribute)
respFLI (DDAdvance property)
(DDBPut property)
(DDChkptAvail property)
(DDClear property)
(DDCreate property)
(DDDeregisterClient property)
(DDDestroy property)
(DDDestroyManager property)
(DDEmptyManagers property)
(DDFreeze property)
(DDGetManagers property)
(DDGetMetaData property)
(DDItems property)
(DDKeys property)
(DDLength property)
(DDManagerNewestChkptID property)
(DDManagerNodes property)
(DDManagerSetState property)
(DDManagerStats property)
(DDManagerSync property)
(DDMarkDrainedManagers property)
(DDPersist property)
(DDPersistChkpts property)
(DDPersistedChkptAvail property)
(DDRandomManager property)
(DDRegisterClient property)
(DDRegisterClientID property)
(DDRegisterManager property)
(DDRestore property)
(DDSync property)
(DDUnFreeze property)
(DDUnmarkDrainedManagers property)
(DDValues property)
(SHCreateProcessLocalChannel property)
(SHCreateProcessLocalPool property)
(SHDeregisterProcessLocalPool property)
(SHDestroyProcessLocalChannel property)
(SHGetKV property)
(SHGetKVL property)
(SHPopKVL property)
(SHPushKVL property)
(SHRegisterProcessLocalPool property)
(SHSetKV property)
response (ResponseModel attribute)
response_queue (InferenceRequest attribute)
response_queues (Batch property)
ResponseModel (class in dragon.ai.agent.reasoning.response_parser)
ResponseQueuePool (class in dragon.ai.inference.llm_proxy)
restarted (System property)
restore() (DDict method)
(Store method)
retry_delay (MCPServerConfig attribute)
return_when (Policy property)
returncode (Popen property)
(Process property)
ReturnWhen (class in dragon.dtypes)
rfind() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
rindex() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
rjust() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
RLock() (DragonContext method)
rmdir() (Store method)
role (AgentConfig attribute)
rollback() (DDict method)
(Store method)
ROUNDROBIN (Policy.Distribution attribute)
route() (in module dragon.infrastructure.util)
rpartition() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
rsplit() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
rstrip() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
rt_uid (MemoryPool attribute)
rt_uid_from_ip_addrs() (in module dragon.infrastructure.util)
run() (BaseTool method)
(DAGOrchestrator method)
(DataMover method)
(DragonProcess method)
(FunctionTool method)
(HitlTcpBridge method)
(TraceTcpBridge method)
run_llm_inference_module() (InferenceWorker method)
run_pre_processing_module() (InferenceWorker method)
run_type (InferenceConfig attribute)
RUNTIME_DESC (MessageTypes attribute)
runtime_reboot() (in module dragon.globalservices.process)
RuntimeDesc (class in dragon.infrastructure.messages)
S
sacred_hostname (SlowGPUDetector property)
sampling_override (InferenceRequest attribute)
scale_in() (DragonBatchPoolExecutor method)
(DragonPoolExecutor method)
scale_out() (DragonBatchPoolExecutor method)
(DragonPoolExecutor method)
scheduler_hostname (BatchTopology attribute)
scoped_names (MCPServerClient property)
sdesc (ChannelDescriptor property)
(NodeDescriptor property)
(Policy property)
(PoolDescriptor property)
(ProcessTemplate property)
SELF (GSProcessJoinListResponse.Errors attribute)
(GSProcessJoinResponse.Errors attribute)
Semaphore (class in dragon.native.semaphore)
Semaphore() (DragonContext method)
SEMAPHORE_P (EventType attribute)
SEMAPHORE_PEEK (EventType attribute)
SEMAPHORE_V (EventType attribute)
SEMAPHORE_Z (EventType attribute)
send() (AbsorbingChannel method)
(ChannelSendH method)
(CommunicationProtocol method)
(Connection method)
(DragonQueueProtocol method)
(NewlineStreamWrapper method)
send_bytes() (ChannelSendH method)
(Connection method)
(FLISendH method)
send_complete() (GatewayMessage method)
send_desc (FENodeIdxBE property)
send_dest_mem_descr_ser (GatewayMessage attribute)
send_mem() (FLISendH method)
send_mpi_data() (PMOD method)
send_payload_message (GatewayMessage attribute)
send_payload_message_attr_clientid (GatewayMessage attribute)
send_payload_message_attr_hints (GatewayMessage attribute)
send_payload_message_attr_sendhid (GatewayMessage attribute)
send_signal() (Popen method)
(Process method)
(ProcessGroup method)
SENDER_CREATES (ConnectionOptions.CreationPolicy attribute)
(PipeOptions.CreationPolicy attribute)
sender_id (Message attribute)
sendh (GSChannelGetSendHResponse property)
sendh() (Channel method)
(FLInterface method)
sentinel (DragonProcess property)
serialize() (Barrier method)
(CapNProtoMsg method)
(Channel method)
(DDict method)
(DragonBarrier method)
(DragonBoundedSemaphore method)
(DragonSemaphore method)
(FLInterface method)
(InfraMsg method)
(MemoryAlloc method)
(MemoryPool method)
(Queue method)
(Semaphore method)
(Store method)
Serialized Descriptor
serialized_channel (SHCreateProcessLocalChannelResponse property)
serialized_ddict (DAGOrchestrator property)
(DispatchHeader attribute)
(TaskResult attribute)
serialized_pool (SHCreateProcessLocalPoolResponse property)
serialized_pool_uid_fname() (Channel class method)
serialized_uid() (Channel class method)
serialized_uid_fname() (MemoryPool class method)
serializedDdict (DDGetMetaDataResponse property)
serPool (SHDeregisterProcessLocalPool property)
(SHRegisterProcessLocalPool property)
set() (DragonEvent method)
(Event method)
set_adapter_timeout() (Many2ManyReadingChannelFile method)
(Many2ManyWritingChannelFile method)
set_cached_local_network_conf() (NodeDescriptor class method)
set_core_affinity() (in module dragon.utils)
set_executable() (DragonContext method)
set_forkserver_preload() (DragonContext method)
set_host_id() (in module dragon.utils)
set_local_kv() (in module dragon.utils)
set_num_gateways_per_node() (LaunchParameters method)
set_procname() (in module dragon.utils)
set_remote_cwd() (Proxy method)
set_remote_env() (Proxy method)
set_remote_python_executable() (Proxy method)
set_side_buf() (Peer2PeerReadingChannelFile method)
setDaemon() (HitlTcpBridge method)
(TraceTcpBridge method)
setdefault() (Store method)
setName() (HitlTcpBridge method)
(TraceTcpBridge method)
sets (GroupDescriptor attribute)
setup_logging() (DDict method)
(Store method)
SH_ALLOC_BLOCK (MessageTypes attribute)
SH_ALLOC_BLOCK_RESPONSE (MessageTypes attribute)
SH_ALLOC_MSG (MessageTypes attribute)
SH_ALLOC_MSG_RESPONSE (MessageTypes attribute)
SH_CHANNEL_CREATE (MessageTypes attribute)
SH_CHANNEL_CREATE_RESPONSE (MessageTypes attribute)
SH_CHANNEL_DESTROY (MessageTypes attribute)
SH_CHANNEL_DESTROY_RESPONSE (MessageTypes attribute)
SH_CHANNELS_UP (MessageTypes attribute)
SH_CREATE_PROCESS_LOCAL_CHANNEL (MessageTypes attribute)
SH_CREATE_PROCESS_LOCAL_CHANNEL_RESPONSE (MessageTypes attribute)
SH_CREATE_PROCESS_LOCAL_POOL (MessageTypes attribute)
SH_CREATE_PROCESS_LOCAL_POOL_RESPONSE (MessageTypes attribute)
SH_DEREGISTER_PROCESS_LOCAL_POOL (MessageTypes attribute)
SH_DEREGISTER_PROCESS_LOCAL_POOL_RESPONSE (MessageTypes attribute)
SH_DESTROY_PROCESS_LOCAL_CHANNEL (MessageTypes attribute)
SH_DESTROY_PROCESS_LOCAL_CHANNEL_RESPONSE (MessageTypes attribute)
SH_DUMP_STATE (MessageTypes attribute)
SH_EXEC_MEM_REQUEST (MessageTypes attribute)
SH_EXEC_MEM_RESPONSE (MessageTypes attribute)
SH_FWD_INPUT (MessageTypes attribute)
SH_FWD_INPUT_ERR (MessageTypes attribute)
SH_FWD_OUTPUT (MessageTypes attribute)
SH_GET_KV (MessageTypes attribute)
SH_GET_KV_RESPONSE (MessageTypes attribute)
SH_GET_KVL (MessageTypes attribute)
SH_GET_KVL_RESPONSE (MessageTypes attribute)
SH_HALT_BE (MessageTypes attribute)
SH_HALT_TA (MessageTypes attribute)
SH_HALTED (MessageTypes attribute)
SH_LOCK_CHANNEL (MessageTypes attribute)
SH_LOCK_CHANNEL_RESPONSE (MessageTypes attribute)
SH_MULTI_PROCESS_CREATE (MessageTypes attribute)
SH_MULTI_PROCESS_CREATE_RESPONSE (MessageTypes attribute)
SH_MULTI_PROCESS_KILL (MessageTypes attribute)
SH_MULTI_PROCESS_KILL_RESPONSE (MessageTypes attribute)
SH_PING_BE (MessageTypes attribute)
SH_PING_GS (MessageTypes attribute)
SH_POOL_CREATE (MessageTypes attribute)
SH_POOL_CREATE_RESPONSE (MessageTypes attribute)
SH_POOL_DESTROY (MessageTypes attribute)
SH_POOL_DESTROY_RESPONSE (MessageTypes attribute)
SH_POP_KVL (MessageTypes attribute)
SH_POP_KVL_RESPONSE (MessageTypes attribute)
SH_PROCESS_CREATE (MessageTypes attribute)
SH_PROCESS_CREATE_RESPONSE (MessageTypes attribute)
SH_PROCESS_EXIT (MessageTypes attribute)
SH_PROCESS_KILL (MessageTypes attribute)
SH_PROCESS_KILL_RESPONSE (MessageTypes attribute)
SH_PUSH_KVL (MessageTypes attribute)
SH_PUSH_KVL_RESPONSE (MessageTypes attribute)
SH_REGISTER_PROCESS_LOCAL_POOL (MessageTypes attribute)
SH_REGISTER_PROCESS_LOCAL_POOL_RESPONSE (MessageTypes attribute)
SH_SET_KV (MessageTypes attribute)
SH_SET_KV_RESPONSE (MessageTypes attribute)
SH_TEARDOWN (MessageTypes attribute)
SHAllocBlock (class in dragon.infrastructure.messages)
SHAllocBlockResponse (class in dragon.infrastructure.messages)
SHAllocBlockResponse.Errors (class in dragon.infrastructure.messages)
SHAllocMsg (class in dragon.infrastructure.messages)
SHAllocMsgResponse (class in dragon.infrastructure.messages)
SHAllocMsgResponse.Errors (class in dragon.infrastructure.messages)
SHChannelCreate (class in dragon.infrastructure.messages)
SHChannelCreateResponse (class in dragon.infrastructure.messages)
SHChannelCreateResponse.Errors (class in dragon.infrastructure.messages)
SHChannelDestroy (class in dragon.infrastructure.messages)
SHChannelDestroyResponse (class in dragon.infrastructure.messages)
SHChannelDestroyResponse.Errors (class in dragon.infrastructure.messages)
SHChannelsUp (class in dragon.infrastructure.messages)
SHCreateProcessLocalChannel (class in dragon.infrastructure.messages)
SHCreateProcessLocalChannelResponse (class in dragon.infrastructure.messages)
SHCreateProcessLocalPool (class in dragon.infrastructure.messages)
SHCreateProcessLocalPoolResponse (class in dragon.infrastructure.messages)
SHDeregisterProcessLocalPool (class in dragon.infrastructure.messages)
SHDeregisterProcessLocalPoolResponse (class in dragon.infrastructure.messages)
SHDestroyProcessLocalChannel (class in dragon.infrastructure.messages)
SHDestroyProcessLocalChannelResponse (class in dragon.infrastructure.messages)
SHDumpState (class in dragon.infrastructure.messages)
SHEP_CUID_POW (in module dragon.infrastructure.facts)
shepherd_cuid_from_index() (in module dragon.infrastructure.facts)
SHExecMemRequest (class in dragon.infrastructure.messages)
SHExecMemRequest.KINDS (class in dragon.infrastructure.messages)
SHExecMemResponse (class in dragon.infrastructure.messages)
SHExecMemResponse.Errors (class in dragon.infrastructure.messages)
SHFwdInput (class in dragon.infrastructure.messages)
SHFwdInputErr (class in dragon.infrastructure.messages)
SHFwdInputErr.Errors (class in dragon.infrastructure.messages)
SHFwdOutput (class in dragon.infrastructure.messages)
SHFwdOutput.FDNum (class in dragon.infrastructure.messages)
SHGetKV (class in dragon.infrastructure.messages)
SHGetKVL (class in dragon.infrastructure.messages)
SHGetKVLResponse (class in dragon.infrastructure.messages)
SHGetKVResponse (class in dragon.infrastructure.messages)
SHHaltBE (class in dragon.infrastructure.messages)
SHHalted (class in dragon.infrastructure.messages)
SHHaltTA (class in dragon.infrastructure.messages)
SHLockChannel (class in dragon.infrastructure.messages)
SHLockChannelResponse (class in dragon.infrastructure.messages)
SHLockChannelResponse.Errors (class in dragon.infrastructure.messages)
SHM (PoolType attribute)
SHMultiProcessCreate (class in dragon.infrastructure.messages)
SHMultiProcessCreateResponse (class in dragon.infrastructure.messages)
SHMultiProcessCreateResponse.Errors (class in dragon.infrastructure.messages)
SHMultiProcessKill (class in dragon.infrastructure.messages)
SHMultiProcessKillResponse (class in dragon.infrastructure.messages)
SHMultiProcessKillResponse.Errors (class in dragon.infrastructure.messages)
should_check_batch() (DynamicBatcher method)
should_summarize() (ContextManager method)
show_gets (Store property)
SHPingBE (class in dragon.infrastructure.messages)
SHPingGS (class in dragon.infrastructure.messages)
SHPoolCreate (class in dragon.infrastructure.messages)
SHPoolCreateResponse (class in dragon.infrastructure.messages)
SHPoolCreateResponse.Errors (class in dragon.infrastructure.messages)
SHPoolDestroy (class in dragon.infrastructure.messages)
SHPoolDestroyResponse (class in dragon.infrastructure.messages)
SHPoolDestroyResponse.Errors (class in dragon.infrastructure.messages)
SHPopKVL (class in dragon.infrastructure.messages)
SHPopKVLResponse (class in dragon.infrastructure.messages)
SHProcessCreate (class in dragon.infrastructure.messages)
SHProcessCreateResponse (class in dragon.infrastructure.messages)
SHProcessCreateResponse.Errors (class in dragon.infrastructure.messages)
SHProcessExit (class in dragon.infrastructure.messages)
SHProcessExit.Errors (class in dragon.infrastructure.messages)
SHProcessKill (class in dragon.infrastructure.messages)
SHProcessKillResponse (class in dragon.infrastructure.messages)
SHProcessKillResponse.Errors (class in dragon.infrastructure.messages)
SHPushKVL (class in dragon.infrastructure.messages)
SHPushKVLResponse (class in dragon.infrastructure.messages)
SHRegisterProcessLocalPool (class in dragon.infrastructure.messages)
SHRegisterProcessLocalPoolResponse (class in dragon.infrastructure.messages)
SHSetKV (class in dragon.infrastructure.messages)
SHSetKVResponse (class in dragon.infrastructure.messages)
SHTeardown (class in dragon.infrastructure.messages)
SHUTDOWN (MsgType attribute)
shutdown() (DragonBatchPoolExecutor method)
(DragonMPIExecutor method)
(DragonPoolExecutor method)
(DragonQueueLLMProxy method)
(LLMInferenceEngine method)
(LLMProxy method)
(ResponseQueuePool method)
(Telemetry method)
silence_transport_timeouts() (GatewayMessage static method)
SimpleQueue() (DragonContext method)
size (Batch property)
(MemoryAlloc attribute)
(MemoryPool attribute)
(SHCreateProcessLocalPool property)
size() (DragonLock static method)
(FIFOLock static method)
(GreedyLock static method)
(PriorityHeap static method)
(Queue method)
SLIDING_WINDOW (MemoryStrategy attribute)
SlowGPUDetector (class in dragon.telemetry.analysis)
Span (class in dragon.ai.agent.observability.tracer)
SPAN_END (MsgType attribute)
span_id (Span attribute)
SPAN_START (MsgType attribute)
SPAN_UPDATE (MsgType attribute)
SpanKind (class in dragon.ai.agent.observability.trace_protocol)
SPECIFIC (PoolOptions.Placement attribute)
SPIN (Policy.WaitMode attribute)
spin_down_threshold_seconds (DynamicWorkerConfig attribute)
spin_up_prompt_threshold (DynamicWorkerConfig attribute)
spin_up_threshold_seconds (DynamicWorkerConfig attribute)
split() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
splitlines() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
starmap() (DragonPool method)
starmap_async() (DragonPool method)
start() (AnalysisGroupBase method)
(CollectorGroup method)
(DataMovers method)
(Detector method)
(DragonBatchPoolExecutor method)
(DragonMPIExecutor method)
(DragonPoolExecutor method)
(DragonProcess method)
(HitlTcpBridge method)
(MCPServerClient method)
(Process method)
(ProcessGroup method)
(ProcessTemplate method)
(Telemetry method)
(TraceTcpBridge method)
start_batch_put() (DDict method)
(Store method)
start_capturing_child_mp_output() (in module dragon.globalservices.process)
start_inf_workers() (CPUWorker method)
start_overlay_network() (in module dragon.transport.overlay)
start_telemetry() (TimeKeeper method)
start_time (Span attribute)
(Trace attribute)
start_transport_agent() (in module dragon.transport)
startswith() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
state (DDManagerSetState property)
(GroupDescriptor attribute)
(GroupDescriptor.GroupMember attribute)
stats (DDict property)
(Store property)
status (TaskResult attribute)
stderr (FileDescriptor attribute)
(Popen property)
STDERR (SHFwdOutput.FDNum attribute)
(StreamDestination attribute)
stderr_conn (Process property)
stdin (FileDescriptor attribute)
(Popen property)
STDIN (StreamDestination attribute)
stdin_conn (Process property)
stdout (FileDescriptor attribute)
STDOUT (Popen attribute)
stdout (Popen property)
STDOUT (ProcessTemplate attribute)
(SHFwdOutput.FDNum attribute)
(StreamDestination attribute)
stdout_conn (Process property)
stop() (AnalysisGroupBase method)
(CollectorGroup method)
(DataMovers method)
(Detector method)
(DragonDataset method)
(HitlTcpBridge method)
(ProcessGroup method)
(TimeKeeper method)
(TraceTcpBridge method)
stop_capturing_child_mp_output() (in module dragon.globalservices.process)
stop_restart() (ProcessGroup method)
Store (class in dragon.data.zarr)
str_to_bytes() (B64 class method)
strategy (MemoryConfig attribute)
STREAM_CHANNEL_IS_MAIN_FOR_1_1_CONNECTION (C++ member)
STREAM_CHANNEL_IS_MAIN_FOR_BUFFERED_SEND (C++ member)
stream_received (FLIRecvH attribute)
StreamDestination (class in dragon.globalservices.process)
strip() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
strtobool() (in module dragon.utils)
SubAgent (class in dragon.ai.agent.core.sub_agent)
subclass_types (DragonRawValue attribute)
(DragonValue attribute)
(Value attribute)
submit() (DragonBatchPoolExecutor method)
(DragonMPIExecutor method)
(DragonPoolExecutor method)
SubmitAfterCloseError
SUCCESS (DragonLoggingError.Errors attribute)
(DragonPoolError.Errors attribute)
(GroupDescriptor.GroupMember.Errors attribute)
(GSChannelCreateResponse.Errors attribute)
(GSChannelDestroyResponse.Errors attribute)
(GSChannelDetachResponse.Errors attribute)
(GSChannelGetRecvHResponse.Errors attribute)
(GSChannelGetSendHResponse.Errors attribute)
(GSChannelJoinResponse.Errors attribute)
(GSChannelListResponse.Errors attribute)
(GSChannelQueryResponse.Errors attribute)
(GSGroupAddToResponse.Errors attribute)
(GSGroupCreateAddToResponse.Errors attribute)
(GSGroupDestroyPMIxResponse.Errors attribute)
(GSGroupDestroyRemoveFromResponse.Errors attribute)
(GSGroupDestroyResponse.Errors attribute)
(GSGroupKillResponse.Errors attribute)
(GSGroupListResponse.Errors attribute)
(GSGroupQueryResponse.Errors attribute)
(GSGroupRemoveFromResponse.Errors attribute)
(GSNodeListResponse.Errors attribute)
(GSNodeQueryAllResponse.Errors attribute)
(GSNodeQueryResponse.Errors attribute)
(GSNodeQueryTotalCPUCountResponse.Errors attribute)
(GSPoolCreateResponse.Errors attribute)
(GSPoolDestroyResponse.Errors attribute)
(GSPoolListResponse.Errors attribute)
(GSPoolQueryResponse.Errors attribute)
(GSProcessCreateResponse.Errors attribute)
(GSProcessJoinListResponse.Errors attribute)
(GSProcessJoinResponse.Errors attribute)
(GSProcessKillResponse.Errors attribute)
(GSProcessListResponse.Errors attribute)
(GSProcessQueryResponse.Errors attribute)
(GSRebootRuntimeResponse.Errors attribute)
(LAProcessDictResponse.Errors attribute)
(LAServerModeExit.Errors attribute)
(LSDestroyPMIxResponse.Errors attribute)
(SHAllocBlockResponse.Errors attribute)
(SHAllocMsgResponse.Errors attribute)
(SHChannelCreateResponse.Errors attribute)
(SHChannelDestroyResponse.Errors attribute)
(SHExecMemResponse.Errors attribute)
(SHFwdInputErr.Errors attribute)
(SHLockChannelResponse.Errors attribute)
(SHMultiProcessCreateResponse.Errors attribute)
(SHMultiProcessKillResponse.Errors attribute)
(SHPoolCreateResponse.Errors attribute)
(SHPoolDestroyResponse.Errors attribute)
(SHProcessCreateResponse.Errors attribute)
(SHProcessExit.Errors attribute)
(SHProcessKillResponse.Errors attribute)
successful() (ApplyResult method)
(MapResult method)
(WrappedResult method)
SUMMARIZE (MemoryStrategy attribute)
summarize_after_turns (MemoryConfig attribute)
summarizer_inference_queue (AgentConfig attribute)
summarizer_max_content_chars (MemoryConfig attribute)
summarizer_max_tool_chars (MemoryConfig attribute)
survey_dev_shm() (in module dragon.infrastructure.util)
swapcase() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
sync() (DDict method)
(Store method)
sync_to_newest_checkpoint() (DDict method)
(Store method)
synchronize_ddicts() (DDict class method)
(Store class method)
System (class in dragon.native.machine)
System Resource
system_prompt (ModelConfig attribute)
T
TA_HALTED (MessageTypes attribute)
TA_PING_SH (MessageTypes attribute)
TA_UP (MessageTypes attribute)
TA_UPDATE_NODES (MessageTypes attribute)
ta_update_nodes() (Channel class method)
tag (CapNProtoMsg property)
(InfraMsg property)
TAHalted (class in dragon.infrastructure.messages)
TAPingSH (class in dragon.infrastructure.messages)
target_ch_ser (GatewayMessage attribute)
target_hostid (GatewayMessage attribute)
Task (class in dragon.workflows.batch.batch)
task (DispatchHeader attribute)
TASK (SpanKind attribute)
task_description (PipelineNode attribute)
task_done() (DragonJoinableQueue method)
(FLInterface method)
(Queue method)
task_id (HumanApprovalRequest attribute)
(Message attribute)
(TaskResult attribute)
TaskResult (class in dragon.ai.agent.config.pipeline)
TaskStatus (class in dragon.ai.agent.config.pipeline)
TAUp (class in dragon.infrastructure.messages)
TAUpdateNodes (class in dragon.infrastructure.messages)
tc (CapNProtoMsg property)
(InfraMsg property)
TCP (TransportAgentOptions attribute)
tcv() (InfraMsg class method)
Telemetry (class in dragon.telemetry.telemetry)
terminal_nodes() (Pipeline method)
terminate() (Batch method)
(DragonPool method)
(DragonProcess method)
(Pool method)
(Popen method)
(Process method)
(ProcessGroup method)
test_connection_override() (in module dragon.globalservices.api_setup)
thread_policy() (Policy class method)
thread_wait() (Connection method)
(Queue method)
time_left() (PriorityMultiMap method)
TimeKeeper (class in dragon.utils)
TimeKeeper.Recorder (class in dragon.utils)
timekeeper_stats (DDictManagerStats attribute)
timeout (DDRegisterClientResponse property)
(DDSync property)
TIMEOUT (GSChannelJoinResponse.Errors attribute)
(GSProcessJoinListResponse.Errors attribute)
(GSProcessJoinResponse.Errors attribute)
timeout (MCPServerConfig attribute)
timestamp (HumanApprovalRequest attribute)
(HumanApprovalResponse attribute)
(InferenceRequest attribute)
title() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
to attach
to_bytes() (Policy.Distribution method)
(Policy.Placement method)
(Policy.WaitMode method)
to_dict() (Span method)
(Trace method)
to_schema() (BaseTool method)
(FunctionTool method)
to_str() (in module dragon.infrastructure.util)
to_str_iter() (in module dragon.infrastructure.util)
tobytes() (Message method)
token (InferenceConfig attribute)
(MCPServerConfig attribute)
tool() (ToolRegistry method)
tool_args (HumanApprovalRequest attribute)
TOOL_CALL (SpanKind attribute)
tool_calls (ToolRequest attribute)
TOOL_EVENT (MsgType attribute)
tool_name (HumanApprovalRequest attribute)
tool_names() (ToolRegistry method)
ToolCall (class in dragon.ai.agent.reasoning.response_parser)
ToolDispatcher (class in dragon.ai.agent.reasoning.tool_dispatcher)
ToolExecutionError
ToolRegistry (class in dragon.ai.agent.tools.registry)
ToolRequest (class in dragon.ai.agent.reasoning.response_parser)
tools (InferenceRequest attribute)
tools_list (Batch property)
tools_schemas (MCPServerClient property)
top_k (ModelConfig attribute)
top_p (ModelConfig attribute)
topology() (Batch method)
total_bytes (DDictManagerStats attribute)
total_cpus (GSNodeQueryTotalCPUCountResponse property)
total_managers (BatchTopology attribute)
total_nodes (BatchTopology attribute)
total_used_bytes (DDictManagerStats attribute)
tp_args_validator() (Inference method)
tp_size (ModelConfig attribute)
Trace (class in dragon.ai.agent.observability.tracer)
trace_address (DAGOrchestrator property)
TRACE_END (MsgType attribute)
trace_id (Span attribute)
(Trace attribute)
TRACE_START (MsgType attribute)
TraceTcpBridge (class in dragon.ai.agent.observability.tcp_bridge)
tracing (DispatchHeader attribute)
(OrchestratorConfig attribute)
TracingProcessor (class in dragon.ai.agent.observability.tracer)
transfer_ownership_on_send (ChannelSendH attribute)
(OwnershipOnSend attribute)
translate() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
Transparency
transport_cuid_from_index() (in module dragon.infrastructure.facts)
transport_puid_from_index() (in module dragon.infrastructure.facts)
TransportAgentOptions (class in dragon.infrastructure.facts)
trigger_restart() (Detector static method)
truncation_side (ModelConfig attribute)
try_lock() (DragonLock method)
(FIFOLock method)
(GreedyLock method)
tuple_type_list (DragonRawValue attribute)
(DragonValue attribute)
(Value attribute)
Type (class in dragon.locks)
type (FinalResponse attribute)
(ToolRequest attribute)
type_filter() (in module dragon.infrastructure.messages)
typecast() (in module dragon.infrastructure.parameters)
TypedParm (class in dragon.infrastructure.parameters)
U
UCX (HighSpeedTransportBackends attribute)
uid (Function property)
(GroupDescriptor.GroupMember attribute)
(Job property)
(Task property)
UNATTACHED (Connection.State attribute)
UNBACKED (Connection.State attribute)
uncompressed_serialize() (InfraMsg method)
unfreeze() (DDict method)
(Store method)
UNKNOWN (AccVendor attribute)
(GSChannelDestroyResponse.Errors attribute)
(GSChannelDetachResponse.Errors attribute)
(GSChannelGetRecvHResponse.Errors attribute)
(GSChannelGetSendHResponse.Errors attribute)
(GSChannelQueryResponse.Errors attribute)
(GSGroupAddToResponse.Errors attribute)
(GSGroupCreateAddToResponse.Errors attribute)
(GSGroupDestroyRemoveFromResponse.Errors attribute)
(GSGroupDestroyResponse.Errors attribute)
(GSGroupKillResponse.Errors attribute)
(GSGroupQueryResponse.Errors attribute)
(GSGroupRemoveFromResponse.Errors attribute)
(GSNodeQueryAllResponse.Errors attribute)
(GSNodeQueryResponse.Errors attribute)
(GSNodeQueryTotalCPUCountResponse.Errors attribute)
(GSPoolDestroyResponse.Errors attribute)
(GSPoolQueryResponse.Errors attribute)
(GSProcessJoinListResponse.Errors attribute)
(GSProcessJoinResponse.Errors attribute)
(GSProcessKillResponse.Errors attribute)
(GSProcessQueryResponse.Errors attribute)
(GSRebootRuntimeResponse.Errors attribute)
(SHAllocBlockResponse.Errors attribute)
(SHProcessExit.Errors attribute)
UNKNOWN_CHANNEL (GSChannelDestroyResponse.Errors attribute)
(GSChannelDetachResponse.Errors attribute)
(GSChannelGetRecvHResponse.Errors attribute)
(GSChannelGetSendHResponse.Errors attribute)
unlock() (DragonLock method)
(FIFOLock method)
(GreedyLock method)
Unmanaged Object
unregister() (ToolRegistry method)
update() (DDict method)
(Store method)
upper() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)
upstream_agent_ids (DispatchHeader attribute)
url (MCPServerConfig attribute)
USE_CHANNEL_RECVH_DEFAULT (ChannelRecvH attribute)
USE_CHANNEL_SENDH_DEFAULT (ChannelSendH attribute)
USER_HALT_OOB (MessageTypes attribute)
user_print() (in module dragon.infrastructure.util)
user_prompts (Batch property)
UserHaltOOB (class in dragon.infrastructure.messages)
utilization (MemoryPool attribute)
V
validate() (BatchingConfig method)
(DynamicWorkerConfig method)
(GuardrailsConfig method)
(HardwareConfig method)
(ModelConfig method)
validate_all() (InferenceConfig method)
value (Array property)
Value (class in dragon.native.value)
value (DragonArray property)
(DragonRawArray property)
(DragonRawValue property)
(DragonValue property)
(PollResult property)
(RecvNotifType attribute)
(ReturnWhen attribute)
(SHGetKVResponse property)
(SHPopKVL property)
(SHPushKVL property)
(SHSetKV property)
(Value property)
(WaitMode attribute)
Value() (DragonContext method)
ValueConversion (class in dragon.native.value)
values (SHGetKVLResponse property)
values() (DDict method)
(PriorityMultiMap method)
(Store method)
vendor (AcceleratorDescriptor attribute)
vllm_log_level (ModelConfig attribute)
W
wait() (ApplyResult method)
(Barrier method)
(DragonBarrier method)
(DragonCondition method)
(DragonContext static method)
(DragonEvent method)
(Event method)
(in module dragon.globalservices.channel)
(MapResult method)
(Popen method)
(WrappedResult method)
wait_for() (DragonCondition method)
(in module dragon.globalservices.channel)
wait_mode (Policy attribute)
(Policy property)
wait_on_load() (Store method)
WAITING (TaskStatus attribute)
WaitMode (class in dragon.dtypes)
watcher() (Detector class method)
weight (Function property)
(Job property)
(Task property)
which_manager() (DDict method)
(Store method)
with_traceback() (DragonContext.AuthenticationError method)
(DragonContext.BufferTooShort method)
(DragonContext.ProcessError method)
(DragonContext.TimeoutError method)
workers_per_pool (BatchTopology attribute)
Workflow
world_size (RankInfo property)
WrappedResult (class in dragon.mpbridge.pool)
writable (Connection property)
write() (Batch method)
(Many2ManyWritingChannelFile method)
(Peer2PeerWritingChannelFile method)
(PickleWriteAdapter method)
write_eot() (Peer2PeerWritingChannelFile method)
write_event() (DDictAccessor method)
write_raw_header() (Peer2PeerWritingChannelFile method)
X
XNumPy2DPickler (class in dragon.utils)
XScalarPickler (class in dragon.utils)
XStringPickler (class in dragon.utils)
Z
zfill() (MemoryStrategy method)
(MsgType method)
(SpanKind method)
(TaskStatus method)