Index

A

add_to_whitelist() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method)

add_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method)

B

BadRegistration bar() (in module funcx.serialize.concretes) BaseStrategy (class in funcx.strategies) (class in funcx.strategies.base)

batch_run() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) broker (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

C

cancel() (funcx.providers.kubernetes.kube.KubernetesProvider method) (funcx.providers.KubernetesProvider method) (funcx.sdk.utils.futures.FuncXFuture method) check() (funcx.serialize.base.fxPicker_shared method) check_logged_in() (in module funcx.sdk.config) check_pidfile() (in module funcx.endpoint.endpoint) chomp() (funcx.serialize.base.fxPicker_shared method) cli_run() (in module funcx.endpoint.endpoint) (in module funcx.executors.high_throughput.funcx_manager) (in module funcx.executors.high_throughput.funcx_worker) (in module funcx.executors.high_throughput.interchange) CLIENT_ID (funcx.sdk.client.FuncXClient attribute) close() (funcx.executors.high_throughput.zmq_pipes.CommandClient method) (funcx.executors.high_throughput.zmq_pipes.ResultsIncoming method) (funcx.executors.high_throughput.zmq_pipes.TasksOutgoing method) (funcx.strategies.BaseStrategy method) (funcx.strategies.base.BaseStrategy method) (funcx.strategies.base.Timer method)

code_pickle (class in funcx.serialize.concretes) code_text_dill (class in funcx.serialize.concretes) code_text_inspect (class in funcx.serialize.concretes) CommandClient (class in funcx.executors.high_throughput.zmq_pipes) complete_endpoint_name() (in module funcx.endpoint.endpoint) Config (class in funcx.config) configure_endpoint() (in module funcx.endpoint.endpoint) connect() (funcx.queues.base.FuncxQueue method) (funcx.queues.RedisQueue method) (funcx.queues.redis.redis_q.RedisQueue method) connected_workers (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute) connection_info (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute) (funcx.mock_broker.forwarder.Forwarder attribute) create_batch() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) create_reg_message() (funcx.executors.high_throughput.funcx_manager.Manager method) ctx (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

D

DEBUG (funcx.endpoint.endpoint.State attribute) DEFAULT_MAX_REQUEST_SIZE (funcx.sdk.utils.throttling.ThrottledBaseClient attribute) DEFAULT_MAX_REQUESTS (funcx.sdk.utils.throttling.ThrottledBaseClient attribute) delete_endpoint() (in module funcx.endpoint.endpoint) delete_from_whitelist() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) DeserializationError deserialize() (funcx.serialize.base.fxPicker_enforcer method) (funcx.serialize.concretes.code_pickle method) (funcx.serialize.concretes.code_text_dill method) (funcx.serialize.concretes.code_text_inspect method) (funcx.serialize.concretes.json_base64 method) (funcx.serialize.concretes.pickle_base64 method) (funcx.serialize.facade.FuncXSerializer method)

destroy() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) dispatch() (in module funcx.executors.high_throughput.interchange_task_dispatch) double() (in module funcx.mock_broker.forwarder) (in module funcx.mock_broker.test) dump() (in module funcx.endpoint.utils.zhelpers)

E

execute_task() (funcx.executors.high_throughput.funcx_worker.FuncXWorker method)

executor_starter() (in module funcx.executors.high_throughput.executor) expect_reply (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

F

fail() (in module funcx.mock_broker.test) failer() (in module funcx.mock_broker.forwarder) format_output() (in module funcx.sdk.config) Forwarder (class in funcx.mock_broker.forwarder) funcx (module) funcx.config (module) funcx.endpoint (module) funcx.endpoint.auth (module) funcx.endpoint.config (module) funcx.endpoint.endpoint (module) funcx.endpoint.utils (module) funcx.endpoint.utils.MDP (module) funcx.endpoint.utils.zhelpers (module) funcx.endpoint.utils.zmq_worker (module) funcx.endpoint.version (module) funcx.errors (module) funcx.executors (module) funcx.executors.high_throughput (module) funcx.executors.high_throughput.container_sched (module) funcx.executors.high_throughput.default_config (module) funcx.executors.high_throughput.executor (module) funcx.executors.high_throughput.funcx_manager (module) funcx.executors.high_throughput.funcx_worker (module) funcx.executors.high_throughput.global_config (module) funcx.executors.high_throughput.interchange (module) funcx.executors.high_throughput.interchange_task_dispatch (module) funcx.executors.high_throughput.worker_map (module) funcx.executors.high_throughput.zmq_pipes (module) funcx.mock_broker (module) funcx.mock_broker.forwarder (module) funcx.mock_broker.mock_broker (module) funcx.mock_broker.mock_tester (module) funcx.mock_broker.test (module) funcx.providers (module) funcx.providers.kubernetes (module)

funcx.providers.kubernetes.kube (module) funcx.providers.kubernetes.template (module) funcx.queues (module) funcx.queues.base (module) funcx.queues.redis (module) funcx.queues.redis.redis_q (module) funcx.sdk (module) funcx.sdk.client (module) funcx.sdk.config (module) funcx.sdk.utils (module) funcx.sdk.utils.futures (module) funcx.sdk.utils.throttling (module) funcx.sdk.version (module) funcx.serialize (module) funcx.serialize.base (module) funcx.serialize.concretes (module) funcx.serialize.facade (module) funcx.strategies (module) funcx.strategies.base (module) funcx.strategies.kube_simple (module) funcx.strategies.simple (module) funcx.version (module) FUNCX_CONFIG (funcx.endpoint.endpoint.State attribute) FUNCX_CONFIG_FILE (funcx.endpoint.endpoint.State attribute) FUNCX_DEFAULT_CONFIG_TEMPLATE (funcx.endpoint.endpoint.State attribute) FUNCX_DIR (funcx.endpoint.endpoint.State attribute) FuncXClient (class in funcx) (class in funcx.sdk.client) FuncxError FuncXFuture (class in funcx.sdk.utils.futures) FuncxQueue (class in funcx.queues.base) FuncXSerializer (class in funcx.serialize.facade) FuncXUnreachable FuncXWorker (class in funcx.executors.high_throughput.funcx_worker) fxPicker_enforcer (class in funcx.serialize.base) fxPicker_shared (class in funcx.serialize.base)

G

get() (funcx.executors.high_throughput.zmq_pipes.ResultsIncoming method) (funcx.queues.RedisQueue method) (funcx.queues.base.FuncxQueue method) (funcx.queues.redis.redis_q.RedisQueue method) get_batch_result() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_batch_status() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_container() (funcx.executors.high_throughput.interchange.Interchange method) (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_containers() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_endpoint_status() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method)

get_next_worker_q() (funcx.executors.high_throughput.worker_map.WorkerMap method) get_outstanding_breakdown() (funcx.executors.high_throughput.interchange.Interchange method) get_result() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_status_report() (funcx.executors.high_throughput.interchange.Interchange method) get_task() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_tasks() (funcx.executors.high_throughput.interchange.Interchange method) get_tasks_hard() (in module funcx.executors.high_throughput.interchange_task_dispatch) get_tasks_soft() (in module funcx.executors.high_throughput.interchange_task_dispatch) get_total_live_workers() (funcx.executors.high_throughput.interchange.Interchange method) get_total_tasks_outstanding() (funcx.executors.high_throughput.interchange.Interchange method) get_whitelist() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) get_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method) get_worker_counts() (funcx.executors.high_throughput.worker_map.WorkerMap method)

H

handle_app_update() (funcx.mock_broker.forwarder.Forwarder method) heartbeat (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) heartbeat_at (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) HEARTBEAT_LIVENESS (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

HighThroughputExecutor (class in funcx.executors) (class in funcx.executors.high_throughput.executor) hold_manager() (funcx.executors.high_throughput.interchange.Interchange method) hold_worker() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method)

I

identifier (funcx.serialize.base.fxPicker_shared attribute) init_endpoint() (in module funcx.endpoint.endpoint) init_endpoint_dir() (in module funcx.endpoint.endpoint) initialize_scaling() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method)

Interchange (class in funcx.executors.high_throughput.interchange) internal_auth_client() (in module funcx.sdk.config) is_connected (funcx.queues.base.FuncxQueue attribute) (funcx.queues.RedisQueue attribute) (funcx.queues.redis.redis_q.RedisQueue attribute)

J

json_base64 (class in funcx.serialize.concretes)

K

KubernetesProvider (class in funcx.providers) (class in funcx.providers.kubernetes.kube)

KubeSimpleStrategy (class in funcx.strategies) (class in funcx.strategies.kube_simple)

L

label (funcx.providers.kubernetes.kube.KubernetesProvider attribute) (funcx.providers.KubernetesProvider attribute) list_endpoints() (in module funcx.endpoint.endpoint) list_mappings() (in module funcx.mock_broker.mock_broker) liveness (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute)

load_auth_client() (in module funcx.endpoint.auth) load_config() (funcx.executors.high_throughput.interchange.Interchange method) logout() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) lookup_option() (in module funcx.sdk.config)

M

main() (in module funcx.endpoint.endpoint) make_callback() (funcx.strategies.base.BaseStrategy method) (funcx.strategies.BaseStrategy method) (funcx.strategies.base.Timer method) MalformedResponse Manager (class in funcx.executors.high_throughput.funcx_manager)

ManagerLost map_run() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) MaxRequestsExceeded MaxRequestSizeExceeded migrate_tasks_to_internal() (funcx.executors.high_throughput.interchange.Interchange method)

N

naive_interchange_task_dispatch() (in module funcx.executors.high_throughput.interchange_task_dispatch) naive_scheduler() (in module funcx.executors.high_throughput.container_sched)

NotConnected notify() (funcx.strategies.base.BaseStrategy method) (funcx.strategies.BaseStrategy method)

O

outstanding (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute)

P

pack_buffers() (funcx.serialize.facade.FuncXSerializer method) pickle_base64 (class in funcx.serialize.concretes) provider_status() (funcx.executors.high_throughput.interchange.Interchange method) pull_tasks() (funcx.executors.high_throughput.funcx_manager.Manager method) push_results() (funcx.executors.high_throughput.funcx_manager.Manager method)

put() (funcx.executors.high_throughput.zmq_pipes.TasksOutgoing method) (funcx.queues.RedisQueue method) (funcx.queues.base.FuncxQueue method) (funcx.queues.redis.redis_q.RedisQueue method) put_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method)

R

ready_worker_count() (funcx.executors.high_throughput.worker_map.WorkerMap method) reconnect (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) reconnect_to_broker() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) recv() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) RedisQueue (class in funcx.queues) (class in funcx.queues.redis.redis_q) register() (in module funcx.mock_broker.mock_broker) register_container() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) register_endpoint() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) (in module funcx.endpoint.endpoint) register_function() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) register_with_hub() (in module funcx.endpoint.endpoint) register_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method)

registration_message() (funcx.executors.high_throughput.funcx_worker.FuncXWorker method) RegistrationError RemoteExceptionWrapper (class in funcx.serialize.base) remove_option() (in module funcx.sdk.config) remove_worker() (funcx.executors.high_throughput.worker_map.WorkerMap method) remove_worker_init() (funcx.executors.high_throughput.funcx_manager.Manager method) reply_to (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) request_close() (funcx.executors.high_throughput.zmq_pipes.ResultsIncoming method) reraise() (funcx.serialize.base.RemoteExceptionWrapper method) restart_endpoint() (in module funcx.endpoint.endpoint) ResultsIncoming (class in funcx.executors.high_throughput.zmq_pipes) run() (funcx.executors.high_throughput.zmq_pipes.CommandClient method) (funcx.FuncXClient method) (funcx.mock_broker.forwarder.Forwarder method) (funcx.sdk.client.FuncXClient method) running() (funcx.sdk.utils.futures.FuncXFuture method)

S

safeprint() (in module funcx.sdk.config) scale_in() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.executors.high_throughput.interchange.Interchange method) scale_out() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.executors.high_throughput.interchange.Interchange method) scaling_enabled (funcx.executors.high_throughput.executor.HighThroughputExecutor attribute) (funcx.executors.HighThroughputExecutor attribute) search_endpoint() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) search_function() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) send() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) send_heartbeat() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) send_to_broker() (funcx.endpoint.utils.zmq_worker.ZMQWorker method) serialize() (funcx.serialize.base.fxPicker_enforcer method) (funcx.serialize.concretes.code_pickle method) (funcx.serialize.concretes.code_text_dill method) (funcx.serialize.concretes.code_text_inspect method) (funcx.serialize.concretes.json_base64 method) (funcx.serialize.concretes.pickle_base64 method) (funcx.serialize.facade.FuncXSerializer method) SerializerError (class in funcx.serialize.base) service (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) set_file_logger() (in module funcx) set_id() (in module funcx.endpoint.utils.zhelpers) set_stream_logger() (in module funcx) shutdown() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) ShutdownRequest

SimpleStrategy (class in funcx.strategies) (class in funcx.strategies.simple) socket_set_hwm() (in module funcx.endpoint.utils.zhelpers) spawn_forwarder() (in module funcx.mock_broker.forwarder) spin_down_workers() (funcx.executors.high_throughput.worker_map.WorkerMap method) spin_up_workers() (funcx.executors.high_throughput.worker_map.WorkerMap method) start() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.executors.high_throughput.funcx_manager.Manager method) (funcx.executors.high_throughput.funcx_worker.FuncXWorker method) (funcx.executors.high_throughput.interchange.Interchange method) (funcx.strategies.BaseStrategy method) (funcx.strategies.base.BaseStrategy method) start_endpoint() (in module funcx.endpoint.endpoint) start_file_logger() (in module funcx.executors.high_throughput.interchange) starter() (in module funcx.executors.high_throughput.interchange) State (class in funcx.endpoint.endpoint) status() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.providers.KubernetesProvider method) (funcx.providers.kubernetes.kube.KubernetesProvider method) stop() (funcx.executors.high_throughput.interchange.Interchange method) stop_endpoint() (in module funcx.endpoint.endpoint) strategize() (funcx.strategies.base.BaseStrategy method) (funcx.strategies.BaseStrategy method) (funcx.strategies.KubeSimpleStrategy method) (funcx.strategies.SimpleStrategy method) (funcx.strategies.kube_simple.KubeSimpleStrategy method) (funcx.strategies.simple.SimpleStrategy method) submit() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) (funcx.providers.KubernetesProvider method) (funcx.providers.kubernetes.kube.KubernetesProvider method)

T

TasksOutgoing (class in funcx.executors.high_throughput.zmq_pipes) test() (in module funcx.mock_broker.mock_tester) (in module funcx.queues.redis.redis_q) test_1() (in module funcx.mock_broker.test) test_2() (in module funcx.mock_broker.test) test_3() (in module funcx.mock_broker.test) throttle_max_requests() (funcx.sdk.utils.throttling.ThrottledBaseClient method)

throttle_request_size() (funcx.sdk.utils.throttling.ThrottledBaseClient method) ThrottledBaseClient (class in funcx.sdk.utils.throttling) ThrottlingException timeout (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) Timer (class in funcx.strategies.base) TOKEN_DIR (funcx.sdk.client.FuncXClient attribute) TOKEN_FILENAME (funcx.sdk.client.FuncXClient attribute)

U

unpack_and_deserialize() (funcx.serialize.facade.FuncXSerializer method) unpack_buffers() (funcx.serialize.facade.FuncXSerializer method) update_function() (funcx.sdk.client.FuncXClient method)

update_table() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method) update_worker_idle() (funcx.executors.high_throughput.worker_map.WorkerMap method)

V

verbose (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) version_callback() (in module funcx.endpoint.endpoint)

version_check() (funcx.FuncXClient method) (funcx.sdk.client.FuncXClient method)

W

wait_for_endpoint() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method) weakref_cb() (funcx.executors.high_throughput.executor.HighThroughputExecutor method) (funcx.executors.HighThroughputExecutor method)

worker (funcx.endpoint.utils.zmq_worker.ZMQWorker attribute) WorkerMap (class in funcx.executors.high_throughput.worker_map) write_option() (in module funcx.sdk.config)

Z

ZMQWorker (class in funcx.endpoint.utils.zmq_worker)

zpipe() (in module funcx.endpoint.utils.zhelpers)