Index

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

A

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.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)
change_worker_cores() (distributed.scheduler.Scheduler method)
cleanup() (distributed.scheduler.Scheduler method)
clear_data_from_workers() (distributed.scheduler.Scheduler method)
Client (class in distributed.client)
client_releases_keys() (distributed.scheduler.Scheduler method)
close() (distributed.deploy.local.LocalCluster method)
(distributed.scheduler.Scheduler method)
close_streams() (distributed.scheduler.Scheduler method)
coerce_address() (distributed.scheduler.Scheduler method)
CompatibleExecutor (class in distributed.client)
compute() (distributed.client.Client method)
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

ensure_occupied() (distributed.scheduler.Scheduler method)
ensure_occupied_queue() (distributed.scheduler.Scheduler method)
ensure_occupied_stacks() (distributed.scheduler.Scheduler method)
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_versions() (distributed.client.Client method)
(distributed.scheduler.Scheduler method)

H

handle_messages() (distributed.scheduler.Scheduler method)
handle_queues() (distributed.scheduler.Scheduler method)
has_what() (distributed.client.Client method)

I

identity() (distributed.scheduler.Scheduler method)
issaturated() (distributed.scheduler.Scheduler method)

L

list_datasets() (distributed.client.Client method)
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

persist() (distributed.client.Client method)
processing() (distributed.client.Client method)
progress() (in module distributed.diagnostics)
publish_dataset() (distributed.client.Client method)

R

read() (in module distributed.core)
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.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)

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.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)
steal_time_ratio() (distributed.scheduler.Scheduler 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_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)

W

wait() (in module distributed.client)
who_has() (distributed.client.Client method)
work_steal() (distributed.scheduler.Scheduler method)
Worker (class in distributed.worker)
worker_stream() (distributed.scheduler.Scheduler method)
workers_list() (distributed.scheduler.Scheduler method)
write() (in module distributed.core)