Index

A

active_cluster (radical.edge.plugin_xgfabric.WorkflowState attribute) add_route_get() (radical.edge.plugin_base.Plugin method)

add_route_post() (radical.edge.plugin_base.Plugin method) allocate_clusters (radical.edge.plugin_xgfabric.WorkflowState attribute)

B

backend() (radical.edge.plugin_queue_info.QueueInfoClient method) backend_endpoint() (radical.edge.plugin_queue_info.PluginQueueInfo method) backend_name (radical.edge.queue_info.QueueInfo attribute) batch_size (radical.edge.plugin_xgfabric.WorkflowConfig attribute)

body() (radical.edge.service.RequestShim method) bridge_cert (radical.edge.plugin_xgfabric.ResourceConfig attribute) bridge_url (radical.edge.plugin_xgfabric.ResourceConfig attribute) (radical.edge.service.EdgeService property), [1]

C

cancel_all_tasks() (radical.edge.plugin_rhapsody.PluginRhapsody method) (radical.edge.plugin_rhapsody.RhapsodyClient method) (radical.edge.plugin_rhapsody.RhapsodySession method) cancel_job() (radical.edge.plugin_psij.PluginPSIJ method) (radical.edge.plugin_psij.PSIJClient method) (radical.edge.plugin_psij.PSIJSession method) (radical.edge.plugin_queue_info.PluginQueueInfo method) (radical.edge.plugin_queue_info.QueueInfoClient method) (radical.edge.plugin_queue_info.QueueInfoSession method) cancel_task() (radical.edge.plugin_rhapsody.PluginRhapsody method) (radical.edge.plugin_rhapsody.RhapsodyClient method) (radical.edge.plugin_rhapsody.RhapsodySession method) clear_correlation_id() (in module radical.edge.logging_config) client_class (radical.edge.plugin_base.Plugin attribute) (radical.edge.plugin_psij.PluginPSIJ attribute) (radical.edge.plugin_queue_info.PluginQueueInfo attribute) (radical.edge.plugin_rhapsody.PluginRhapsody attribute) (radical.edge.plugin_sysinfo.PluginSysInfo attribute) (radical.edge.plugin_xgfabric.PluginXGFabric attribute)

close() (radical.edge.plugin_psij.PSIJSession method) (radical.edge.plugin_queue_info.QueueInfoSession method) (radical.edge.plugin_rhapsody.RhapsodySession method) (radical.edge.plugin_xgfabric.XGFabricSession method) cluster_configs (radical.edge.plugin_xgfabric.ResourceConfig attribute) cluster_type (radical.edge.plugin_xgfabric.ClusterStatus attribute) ClusterStatus (class in radical.edge.plugin_xgfabric) ColoredFormatter (class in radical.edge.logging_config) completed_simulations (radical.edge.plugin_xgfabric.WorkflowState attribute) config_dir (radical.edge.plugin_xgfabric.WorkflowState attribute) config_name (radical.edge.plugin_xgfabric.WorkflowState attribute) config_to_dict() (in module radical.edge.plugin_xgfabric) configure_logging() (in module radical.edge.logging_config) cspot_limit (radical.edge.plugin_xgfabric.WorkflowConfig attribute) cspot_woof_url (radical.edge.plugin_xgfabric.WorkflowConfig attribute) current_batch (radical.edge.plugin_xgfabric.WorkflowState attribute)

D

delete_config() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) (radical.edge.plugin_xgfabric.XGFabricSession method)

description (radical.edge.plugin_xgfabric.WorkflowConfig attribute) dict_to_config() (in module radical.edge.plugin_xgfabric) dict_to_resource_config() (in module radical.edge.plugin_xgfabric)

E

edge_name (radical.edge.plugin_xgfabric.ClusterStatus attribute) EdgeService (class in radical.edge.service), [1]

end_time (radical.edge.plugin_xgfabric.WorkflowState attribute) error (radical.edge.plugin_xgfabric.WorkflowState attribute) evaluation_task (radical.edge.plugin_xgfabric.WorkflowConfig attribute)

F

format() (radical.edge.logging_config.ColoredFormatter method)

G

get_config_dir() (radical.edge.plugin_xgfabric.XGFabricSession method) get_correlation_id() (in module radical.edge.logging_config) get_default_config() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) get_info() (radical.edge.plugin_queue_info.PluginQueueInfo method) (radical.edge.plugin_queue_info.QueueInfoClient method) (radical.edge.plugin_queue_info.QueueInfoSession method) (radical.edge.queue_info.QueueInfo method) get_job_allocation() (radical.edge.plugin_queue_info.PluginQueueInfo method) get_job_status() (radical.edge.plugin_psij.PluginPSIJ method) (radical.edge.plugin_psij.PSIJClient method) (radical.edge.plugin_psij.PSIJSession method) get_metrics() (radical.edge.plugin_sysinfo.SysInfoClient method) (radical.edge.plugin_sysinfo.SysInfoProvider method) (radical.edge.plugin_sysinfo.SysInfoSession method)

get_metrics_endpoint() (radical.edge.plugin_sysinfo.PluginSysInfo method) get_plugin_class() (radical.edge.plugin_base.Plugin class method) get_plugin_names() (radical.edge.plugin_base.Plugin class method) get_status() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) (radical.edge.plugin_xgfabric.XGFabricSession method) get_task() (radical.edge.plugin_rhapsody.PluginRhapsody method) (radical.edge.plugin_rhapsody.RhapsodyClient method) (radical.edge.plugin_rhapsody.RhapsodySession method) get_test_config() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) get_ui_config() (radical.edge.plugin_base.Plugin method) get_version() (radical.edge.plugin_base.Plugin method) get_workdir() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method)

H

has_gpu (radical.edge.plugin_xgfabric.ClusterStatus attribute) health_check() (radical.edge.plugin_base.Plugin method) homedir() (radical.edge.plugin_sysinfo.SysInfoClient method)

homedir_endpoint() (radical.edge.plugin_sysinfo.PluginSysInfo method) host_role() (radical.edge.plugin_sysinfo.SysInfoClient method) host_role_endpoint() (radical.edge.plugin_sysinfo.PluginSysInfo method)

I

immediate_clusters (radical.edge.plugin_xgfabric.WorkflowState attribute) initialize() (radical.edge.plugin_rhapsody.RhapsodySession method) instance_name (radical.edge.plugin_base.Plugin property) is_bridge (radical.edge.plugin_base.Plugin property) is_compute_node (radical.edge.plugin_base.Plugin property)

is_enabled() (radical.edge.plugin_base.Plugin class method) (radical.edge.plugin_psij.PluginPSIJ class method) (radical.edge.plugin_queue_info.PluginQueueInfo class method) (radical.edge.plugin_rhapsody.PluginRhapsody class method) (radical.edge.plugin_xgfabric.PluginXGFabric class method) is_login_node (radical.edge.plugin_base.Plugin property)

J

job_allocation() (radical.edge.plugin_queue_info.QueueInfoClient method)

job_allocation_endpoint() (radical.edge.plugin_queue_info.PluginQueueInfo method) json() (radical.edge.service.RequestShim method)

L

list_all_jobs() (radical.edge.plugin_queue_info.PluginQueueInfo method) (radical.edge.plugin_queue_info.QueueInfoClient method) (radical.edge.plugin_queue_info.QueueInfoSession method) (radical.edge.queue_info.QueueInfo method) list_allocations() (radical.edge.plugin_queue_info.PluginQueueInfo method) (radical.edge.plugin_queue_info.QueueInfoClient method) (radical.edge.plugin_queue_info.QueueInfoSession method) (radical.edge.queue_info.QueueInfo method) list_configs() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) (radical.edge.plugin_xgfabric.XGFabricSession method) list_jobs() (radical.edge.plugin_psij.PluginPSIJ method) (radical.edge.plugin_psij.PSIJClient method) (radical.edge.plugin_psij.PSIJSession method) (radical.edge.plugin_queue_info.PluginQueueInfo method) (radical.edge.plugin_queue_info.QueueInfoClient method) (radical.edge.plugin_queue_info.QueueInfoSession method) (radical.edge.queue_info.QueueInfo method)

list_sessions() (radical.edge.plugin_base.Plugin method) list_tasks() (radical.edge.plugin_rhapsody.PluginRhapsody method) (radical.edge.plugin_rhapsody.RhapsodyClient method) (radical.edge.plugin_rhapsody.RhapsodySession method) load_config() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) (radical.edge.plugin_xgfabric.XGFabricSession method) local_workspace (radical.edge.plugin_xgfabric.WorkflowConfig attribute) log (radical.edge.plugin_xgfabric.WorkflowState attribute)

M

make_queue_info() (in module radical.edge.queue_info) message (radical.edge.plugin_xgfabric.WorkflowState attribute) mock_sensor_data (radical.edge.plugin_xgfabric.WorkflowConfig attribute) module radical.edge radical.edge.logging_config radical.edge.plugin_psij radical.edge.plugin_queue_info radical.edge.plugin_rhapsody radical.edge.plugin_sysinfo radical.edge.plugin_xgfabric radical.edge.queue_info radical.edge.service

N

name (radical.edge.plugin_xgfabric.ClusterStatus attribute) (radical.edge.plugin_xgfabric.ResourceConfig attribute) (radical.edge.plugin_xgfabric.WorkflowConfig attribute)

namespace (radical.edge.plugin_base.Plugin property) num_simulations (radical.edge.plugin_xgfabric.WorkflowConfig attribute)

O

on_topology_change() (radical.edge.plugin_base.Plugin method) (radical.edge.plugin_xgfabric.PluginXGFabric method)

online (radical.edge.plugin_xgfabric.ClusterStatus attribute)

P

phase (radical.edge.plugin_xgfabric.WorkflowState attribute) pilot_job_id (radical.edge.plugin_xgfabric.ClusterStatus attribute) pilot_jobs (radical.edge.plugin_xgfabric.WorkflowState attribute) pilot_status (radical.edge.plugin_xgfabric.ClusterStatus attribute) Plugin (class in radical.edge.plugin_base) plugin_name (radical.edge.plugin_psij.PluginPSIJ attribute) (radical.edge.plugin_queue_info.PluginQueueInfo attribute) (radical.edge.plugin_rhapsody.PluginRhapsody attribute) (radical.edge.plugin_sysinfo.PluginSysInfo attribute) (radical.edge.plugin_xgfabric.PluginXGFabric attribute)

PluginPSIJ (class in radical.edge.plugin_psij) PluginQueueInfo (class in radical.edge.plugin_queue_info) PluginRhapsody (class in radical.edge.plugin_rhapsody) PluginSysInfo (class in radical.edge.plugin_sysinfo) PluginXGFabric (class in radical.edge.plugin_xgfabric) poll_interval (radical.edge.plugin_psij.PSIJSession attribute) prof (radical.edge.plugin_rhapsody.RhapsodySession property) progress (radical.edge.plugin_xgfabric.WorkflowState attribute) PSIJClient (class in radical.edge.plugin_psij) PSIJSession (class in radical.edge.plugin_psij)

Q

QueueInfo (class in radical.edge.queue_info)

QueueInfoClient (class in radical.edge.plugin_queue_info) QueueInfoSession (class in radical.edge.plugin_queue_info)

R

radical.edge module radical.edge.logging_config module radical.edge.plugin_psij module radical.edge.plugin_queue_info module radical.edge.plugin_rhapsody module radical.edge.plugin_sysinfo module radical.edge.plugin_xgfabric module

radical.edge.queue_info module radical.edge.service module register_session() (radical.edge.plugin_base.Plugin method) (radical.edge.plugin_rhapsody.PluginRhapsody method) (radical.edge.plugin_rhapsody.RhapsodyClient method) RequestShim (class in radical.edge.service) ResourceConfig (class in radical.edge.plugin_xgfabric) RhapsodyClient (class in radical.edge.plugin_rhapsody) RhapsodySession (class in radical.edge.plugin_rhapsody) run() (radical.edge.service.EdgeService method), [1]

S

save_config() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) (radical.edge.plugin_xgfabric.XGFabricSession method) send_notification() (radical.edge.plugin_base.Plugin method) (radical.edge.service.EdgeService method), [1] session_class (radical.edge.plugin_base.Plugin attribute) (radical.edge.plugin_psij.PluginPSIJ attribute) (radical.edge.plugin_queue_info.PluginQueueInfo attribute) (radical.edge.plugin_rhapsody.PluginRhapsody attribute) (radical.edge.plugin_sysinfo.PluginSysInfo attribute) (radical.edge.plugin_xgfabric.PluginXGFabric attribute) session_ttl (radical.edge.plugin_base.Plugin attribute) set_config_dir() (radical.edge.plugin_xgfabric.XGFabricSession method) set_correlation_id() (in module radical.edge.logging_config) set_workdir() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) simulation_task (radical.edge.plugin_xgfabric.WorkflowConfig attribute) start_background() (radical.edge.service.EdgeService method), [1] start_prefetch() (radical.edge.plugin_sysinfo.SysInfoProvider method) (radical.edge.queue_info.QueueInfo method)

start_time (radical.edge.plugin_xgfabric.WorkflowState attribute) start_workflow() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) (radical.edge.plugin_xgfabric.XGFabricSession method) status (radical.edge.plugin_xgfabric.WorkflowState attribute) stop() (radical.edge.service.EdgeService method), [1] stop_workflow() (radical.edge.plugin_xgfabric.PluginXGFabric method) (radical.edge.plugin_xgfabric.XGFabricClient method) (radical.edge.plugin_xgfabric.XGFabricSession method) submit_job() (radical.edge.plugin_psij.PluginPSIJ method) (radical.edge.plugin_psij.PSIJClient method) (radical.edge.plugin_psij.PSIJSession method) submit_tasks() (radical.edge.plugin_rhapsody.PluginRhapsody method) (radical.edge.plugin_rhapsody.RhapsodyClient method) (radical.edge.plugin_rhapsody.RhapsodySession method) submit_tunneled() (radical.edge.plugin_psij.PluginPSIJ method) (radical.edge.plugin_psij.PSIJClient method) SysInfoClient (class in radical.edge.plugin_sysinfo) SysInfoProvider (class in radical.edge.plugin_sysinfo) SysInfoSession (class in radical.edge.plugin_sysinfo)

T

tasks_running (radical.edge.plugin_xgfabric.ClusterStatus attribute) total_batches (radical.edge.plugin_xgfabric.WorkflowState attribute) total_simulations (radical.edge.plugin_xgfabric.WorkflowState attribute)

train_models (radical.edge.plugin_xgfabric.WorkflowConfig attribute) training_tasks (radical.edge.plugin_xgfabric.WorkflowConfig attribute) tunnel_status() (radical.edge.plugin_psij.PluginPSIJ method) (radical.edge.plugin_psij.PSIJClient method)

U

ui_config (radical.edge.plugin_base.Plugin attribute) (radical.edge.plugin_psij.PluginPSIJ attribute) (radical.edge.plugin_queue_info.PluginQueueInfo attribute) (radical.edge.plugin_rhapsody.PluginRhapsody attribute) (radical.edge.plugin_sysinfo.PluginSysInfo attribute) (radical.edge.plugin_xgfabric.PluginXGFabric attribute)

ui_module (radical.edge.plugin_base.Plugin attribute) uid (radical.edge.plugin_base.Plugin property) unregister_session() (radical.edge.plugin_base.Plugin method) update_connected_edges() (radical.edge.plugin_xgfabric.XGFabricSession method)

V

version (radical.edge.plugin_base.Plugin attribute) (radical.edge.plugin_psij.PluginPSIJ attribute) (radical.edge.plugin_queue_info.PluginQueueInfo attribute) (radical.edge.plugin_rhapsody.PluginRhapsody attribute) (radical.edge.plugin_sysinfo.PluginSysInfo attribute) (radical.edge.plugin_xgfabric.PluginXGFabric attribute)

W

wait_tasks() (radical.edge.plugin_rhapsody.PluginRhapsody method) (radical.edge.plugin_rhapsody.RhapsodyClient method) (radical.edge.plugin_rhapsody.RhapsodySession method)

WorkflowConfig (class in radical.edge.plugin_xgfabric) WorkflowState (class in radical.edge.plugin_xgfabric)

X

XGFabricClient (class in radical.edge.plugin_xgfabric)

XGFabricSession (class in radical.edge.plugin_xgfabric)