Thread-Speed 'Async' and Parallel R over Shared Memory


[Up] [Top]

Documentation for package ‘mizu’ version 0.1.0

Help Pages

as.promise.mizu_channel Receive Channel Messages as a Promise or a Stream
as.promise.mizu_map Collect Pool Results as Promises
as.promise.mizu_task Collect Pool Results as Promises
is.promising.mizu_channel Receive Channel Messages as a Promise or a Stream
is.promising.mizu_map Collect Pool Results as Promises
is.promising.mizu_task Collect Pool Results as Promises
mizu_alive Check Whether the Channel Peer Is Alive
mizu_as_arrow Convert a Received Frame to an Arrow Stream
mizu_call Call a Function in Another Language
mizu_cancel Cancel a Task or a Map
mizu_channel Create a Channel and Spawn Its Peer
mizu_channel_info Inspect a Channel
mizu_close Close a Channel
mizu_collect Submit a Task and Collect Its Result
mizu_collect_all Collect the Results of Several Tasks, in Order
mizu_collect_all_async Collect Pool Results as Promises
mizu_collect_any Collect the First Available Result From Several Tasks
mizu_collect_any_async Collect Pool Results as Promises
mizu_collect_async Collect Pool Results as Promises
mizu_current_pool The Evaluating Worker's Own Pool Handle
mizu_default_pool The Process-Wide Default Pool
mizu_error Error Conditions
mizu_error_cancelled Error Conditions
mizu_error_not_portable Error Conditions
mizu_error_python_payload Error Conditions
mizu_error_remote Error Conditions
mizu_error_shm Error Conditions
mizu_error_slots_exhausted Error Conditions
mizu_error_startup Error Conditions
mizu_error_stopped Error Conditions
mizu_error_submit_timeout Error Conditions
mizu_error_task_lost Error Conditions
mizu_error_worker_died Error Conditions
mizu_is_remote_error Remote Errors
mizu_is_sentinel Test for a mizu Sentinel
mizu_launcher Default Child Process Launcher
mizu_local_pool The Process-Wide Default Pool
mizu_map Parallel Map Over a Pool
mizu_map_prepare Prepared Maps: Stage Once, Run Many
mizu_map_run Prepared Maps: Stage Once, Run Many
mizu_pool Create a Task Pool and Spawn Its Workers
mizu_pool_attach Attach to a Pool as a Submitter
mizu_pool_dump Dump the Distributed State of a Pool
mizu_pool_info Inspect a Pool
mizu_pool_stats Cumulative Pool Counters
mizu_pool_stop Stop a Pool
mizu_pool_trace Trace Task Lifecycle Events
mizu_prune Remove Orphaned Shared Memory Regions
mizu_py_launcher Python Launcher
mizu_recv Send and Receive over a Channel
mizu_recv_async Receive Channel Messages as a Promise or a Stream
mizu_recv_batch Batched Send and Receive
mizu_recv_handler Receive Channel Messages as a Promise or a Stream
mizu_retire_worker Grow or Shrink the Worker Set of a Pool
mizu_send Send and Receive over a Channel
mizu_send_batch Batched Send and Receive
mizu_set_default_pool The Process-Wide Default Pool
mizu_spawn_workers Grow or Shrink the Worker Set of a Pool
mizu_submit Submit a Task and Collect Its Result
mizu_submit_batch Submit a Batch of Tasks
mizu_submit_call Call a Function in Another Language
mizu_with_pool The Process-Wide Default Pool
print.mizu_call Print Methods for mizu Objects
print.mizu_channel Print Methods for mizu Objects
print.mizu_error_remote Print Methods for mizu Objects
print.mizu_map Print Methods for mizu Objects
print.mizu_map_prepared Print Methods for mizu Objects
print.mizu_pool Print Methods for mizu Objects
print.mizu_sentinel Print Methods for mizu Objects
print.mizu_task Print Methods for mizu Objects