Index

_

_initialize_workers() (torchelastic.agent.server.SimpleElasticAgent method) _monitor_workers() (torchelastic.agent.server.SimpleElasticAgent method) _rendezvous() (torchelastic.agent.server.SimpleElasticAgent method)

_restart_workers() (torchelastic.agent.server.SimpleElasticAgent method) _start_workers() (torchelastic.agent.server.SimpleElasticAgent method) _stop_workers() (torchelastic.agent.server.SimpleElasticAgent method)

A

acquire() (torchelastic.timer.TimerClient method)

add() (torchelastic.rendezvous.etcd_rendezvous.EtcdStore method) announce_self_waiting() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

C

check() (torchelastic.rendezvous.etcd_rendezvous.EtcdStore method) clear_timers() (torchelastic.timer.TimerServer method) configure() (in module torchelastic.events) (in module torchelastic.metrics) (in module torchelastic.timer)

confirm_membership() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method) confirm_phase() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method) ConsoleEventHandler (class in torchelastic.events.api) ConsoleMetricHandler (class in torchelastic.metrics.api)

E

ElasticAgent (class in torchelastic.agent.server) EtcdRendezvous (class in torchelastic.rendezvous.etcd_rendezvous) EtcdRendezvousHandler (class in torchelastic.rendezvous.etcd_rendezvous) EtcdServer (class in torchelastic.rendezvous.etcd_server)

EtcdStore (class in torchelastic.rendezvous.etcd_rendezvous) Event (class in torchelastic.events.api) EventHandler (class in torchelastic.events.api) expires() (in module torchelastic.timer)

G

get() (torchelastic.rendezvous.etcd_rendezvous.EtcdStore method) get_expired_timers() (torchelastic.timer.TimerServer method)

get_worker_group() (torchelastic.agent.server.ElasticAgent method) (torchelastic.agent.server.SimpleElasticAgent method)

H

handle_existing_rendezvous() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

handle_join_last_call() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

I

init_phase() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

is_closed() (torchelastic.rendezvous.RendezvousHandler method)

J

join_phase() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

join_rendezvous() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

L

LocalElasticAgent (class in torchelastic.agent.server.local_elastic_agent)

LocalTimerClient (class in torchelastic.timer) LocalTimerServer (class in torchelastic.timer)

M

MetricHandler (class in torchelastic.metrics.api)

MonitorResult (class in torchelastic.agent.server.api)

N

next_rendezvous() (torchelastic.rendezvous.RendezvousHandler method) NullEventHandler (class in torchelastic.events.api)

NullMetricHandler (class in torchelastic.metrics.api) num_nodes_waiting() (torchelastic.rendezvous.RendezvousHandler method)

P

prof() (in module torchelastic.metrics)

put_metric() (in module torchelastic.metrics)

R

record() (in module torchelastic.events) record_event() (in module torchelastic.events) register_timers() (torchelastic.timer.TimerServer method) release() (torchelastic.timer.TimerClient method) rendezvous_barrier() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

RendezvousClosedException (class in torchelastic.rendezvous) RendezvousHandler (class in torchelastic.rendezvous) RendezvousNonRetryableError (class in torchelastic.rendezvous) RendezvousTimeoutException (class in torchelastic.rendezvous) run() (torchelastic.agent.server.ElasticAgent method) (torchelastic.agent.server.SimpleElasticAgent method)

S

set() (torchelastic.rendezvous.etcd_rendezvous.EtcdStore method) set_closed() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method) (torchelastic.rendezvous.RendezvousHandler method)

set_timeout() (torchelastic.rendezvous.etcd_rendezvous.EtcdStore method) SimpleElasticAgent (class in torchelastic.agent.server)

T

TimerClient (class in torchelastic.timer) TimerRequest (class in torchelastic.timer) TimerServer (class in torchelastic.timer) torchelastic.agent (module) torchelastic.agent.server (module) torchelastic.distributed (module)

torchelastic.distributed.launch (module) torchelastic.events (module) torchelastic.metrics (module) torchelastic.rendezvous (module) torchelastic.timer (module) try_create_rendezvous() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

W

wait() (torchelastic.rendezvous.etcd_rendezvous.EtcdStore method) wait_for_final() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method) wait_for_peers() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method) wait_for_rendezvous_to_free() (torchelastic.rendezvous.etcd_rendezvous.EtcdRendezvous method)

Worker (class in torchelastic.agent.server) WorkerGroup (class in torchelastic.agent.server) WorkerSpec (class in torchelastic.agent.server) WorkerState (class in torchelastic.agent.server)