Index

A | B | C | D | E | F | G | H | I | L | M | N | P | R | S | T | U | V | W

A

abort() (distributed.comm.Comm method)
add_client() (distributed.scheduler.Scheduler method)
add_done_callback() (distributed.client.Future method)
add_keys() (distributed.scheduler.Scheduler method)
add_plugin() (distributed.scheduler.Scheduler method)
add_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
as_completed() (in module distributed.client)

B

broadcast() (distributed.scheduler.Scheduler method)

C

cancel() (distributed.client.Client method)
(distributed.client.Future method)
cancel_key() (distributed.scheduler.Scheduler method)
cancelled() (distributed.client.Future method)
cleanup() (distributed.scheduler.Scheduler method)
Client (class in distributed.client)
client_releases_keys() (distributed.scheduler.Scheduler method)
close() (distributed.comm.Comm method)
(distributed.deploy.local.LocalCluster method)
(distributed.scheduler.Scheduler method)
close_comms() (distributed.scheduler.Scheduler method)
close_worker() (distributed.scheduler.Scheduler method)
closed() (distributed.comm.Comm method)
coerce_address() (distributed.scheduler.Scheduler method)
coerce_hostname() (distributed.scheduler.Scheduler method)
collections_to_dsk() (distributed.client.Client static method)
Comm (class in distributed.comm)
CompatibleExecutor (class in distributed.client)
compute() (distributed.client.Client method)
connect() (in module distributed.comm)
contact_address (distributed.comm.core.Listener attribute)
correct_time_delay() (distributed.scheduler.Scheduler method)

D

decide_worker() (in module distributed.scheduler)
deserialize() (in module distributed.protocol.serialize)
done() (distributed.client.Future method)

E

exception() (distributed.client.Future method)

F

feed() (distributed.scheduler.Scheduler method)
finished() (distributed.scheduler.Scheduler method)
Future (class in distributed.client)

G

gather() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
get() (distributed.client.Client method)
get_dataset() (distributed.client.Client method)
get_restrictions() (distributed.client.Client static method)
get_versions() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
get_worker_service_addr() (distributed.scheduler.Scheduler method)

H

handle_client() (distributed.scheduler.Scheduler method)
handle_worker() (distributed.scheduler.Scheduler method)
has_what() (distributed.client.Client method)

I

identity() (distributed.scheduler.Scheduler method)

L

list_datasets() (distributed.client.Client method)
listen() (in module distributed.comm)
listen_address (distributed.comm.core.Listener attribute)
Listener (class in distributed.comm.core)
LocalCluster (class in distributed.deploy.local)

M

map() (distributed.client.Client method)
(distributed.client.CompatibleExecutor method)

N

nbytes() (distributed.client.Client method)
ncores() (distributed.client.Client method)
normalize_collection() (distributed.client.Client method)

P

peer_address (distributed.comm.Comm attribute)
persist() (distributed.client.Client method)
processing() (distributed.client.Client method)
progress() (in module distributed.diagnostics)
publish_dataset() (distributed.client.Client method)

R

read() (distributed.comm.Comm method)
rebalance() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
register_serialization() (in module distributed.protocol.serialize)
remove_client() (distributed.scheduler.Scheduler method)
remove_plugin() (distributed.scheduler.Scheduler method)
remove_worker() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
replicate() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
report() (distributed.scheduler.Scheduler method)
restart() (distributed.client.Client method)
(distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
result() (distributed.client.Future method)
rpc (class in distributed.core)
run() (distributed.client.Client method)
run_coroutine() (distributed.client.Client method)
run_function() (distributed.scheduler.Scheduler method)
run_on_scheduler() (distributed.client.Client method)

S

scale_down() (distributed.deploy.local.LocalCluster method)
scale_up() (distributed.deploy.local.LocalCluster method)
scatter() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)
Scheduler (class in distributed.scheduler)
scheduler_info() (distributed.client.Client method)
SchedulerPlugin (class in distributed.diagnostics.plugin)
send_task_to_worker() (distributed.scheduler.Scheduler method)
serialize() (in module distributed.protocol.serialize)
Server (class in distributed.core)
shutdown() (distributed.client.Client method)
stacks() (distributed.client.Client method)
start() (distributed.client.Client method)
(distributed.comm.core.Listener method)
(distributed.scheduler.Scheduler method)
start_diagnostics_server() (distributed.deploy.local.LocalCluster method)
start_ipython() (distributed.scheduler.Scheduler method)
start_ipython_scheduler() (distributed.client.Client method)
start_ipython_workers() (distributed.client.Client method)
start_worker() (distributed.deploy.local.LocalCluster method)
stimulus_cancel() (distributed.scheduler.Scheduler method)
stimulus_missing_data() (distributed.scheduler.Scheduler method)
stimulus_task_erred() (distributed.scheduler.Scheduler method)
stimulus_task_finished() (distributed.scheduler.Scheduler method)
stop() (distributed.comm.core.Listener method)
stop_worker() (distributed.deploy.local.LocalCluster method)
submit() (distributed.client.Client method)

T

traceback() (distributed.client.Future method)
transition() (distributed.scheduler.Scheduler method)
transition_story() (distributed.scheduler.Scheduler method)
transitions() (distributed.scheduler.Scheduler method)

U

unpublish_dataset() (distributed.client.Client method)
update_data() (distributed.scheduler.Scheduler method)
update_graph() (distributed.diagnostics.plugin.SchedulerPlugin method)
(distributed.scheduler.Scheduler method)
upload_file() (distributed.client.Client method)

V

valid_workers() (distributed.scheduler.Scheduler method)

W

wait() (in module distributed.client)
who_has() (distributed.client.Client method)
Worker (class in distributed.worker)
worker_objective() (distributed.scheduler.Scheduler method)
workers_list() (distributed.scheduler.Scheduler method)
workers_to_close() (distributed.scheduler.Scheduler method)
write() (distributed.comm.Comm method)