Package: rrq 0.7.15

Rich FitzJohn

rrq: Simple Redis Queue

Simple Redis queue in R.

Authors:Rich FitzJohn [aut, cre], Robert Ashton [aut], Imperial College of Science, Technology and Medicine [cph]

rrq_0.7.15.tar.gz
rrq_0.7.15.zip(r-4.5)rrq_0.7.15.zip(r-4.4)rrq_0.7.15.zip(r-4.3)
rrq_0.7.15.tgz(r-4.4-any)rrq_0.7.15.tgz(r-4.3-any)
rrq_0.7.15.tar.gz(r-4.5-noble)rrq_0.7.15.tar.gz(r-4.4-noble)
rrq_0.7.15.tgz(r-4.4-emscripten)rrq_0.7.15.tgz(r-4.3-emscripten)
rrq.pdf |rrq.html
rrq/json (API)
NEWS

# Install 'rrq' in R:
install.packages('rrq', repos = c('https://mrc-ide.r-universe.dev', 'https://cloud.r-project.org'))

Peer review:

Bug tracker:https://github.com/mrc-ide/rrq/issues

On CRAN:

clusterinfrastructure

64 exports 23 stars 2.76 score 24 dependencies 3 dependents

Last updated 2 months agofrom:7d3d32153e (on master)

Exports:object_storerrq_configurerrq_controllerrrq_controller2rrq_default_controller_clearrrq_default_controller_setrrq_deferred_listrrq_destroyrrq_envirrrq_heartbeatrrq_heartbeat_killrrq_message_get_responserrq_message_has_responserrq_message_response_idsrrq_message_sendrrq_message_send_and_waitrrq_queue_lengthrrq_queue_listrrq_queue_removerrq_task_cancelrrq_task_create_bulk_callrrq_task_create_bulk_exprrrq_task_create_callrrq_task_create_exprrrq_task_datarrq_task_deleterrq_task_existsrrq_task_inforrq_task_listrrq_task_overviewrrq_task_positionrrq_task_preceedingrrq_task_progressrrq_task_progress_updaterrq_task_resultrrq_task_resultsrrq_task_retryrrq_task_statusrrq_task_timesrrq_task_waitrrq_workerrrq_worker_configrrq_worker_config_listrrq_worker_config_readrrq_worker_config_saverrq_worker_config_save2rrq_worker_delete_exitedrrq_worker_detect_exitedrrq_worker_envir_setrrq_worker_existsrrq_worker_inforrq_worker_lenrrq_worker_listrrq_worker_list_exitedrrq_worker_loadrrq_worker_log_tailrrq_worker_process_logrrq_worker_scriptrrq_worker_spawnrrq_worker_spawn2rrq_worker_statusrrq_worker_stoprrq_worker_task_idrrq_worker_wait

Dependencies:askpasscallrclicrayondigestdocoptgluehmsidslifecyclelogwatchopensslpkgconfigprettyunitsprocessxprogresspsR6reduxrlangstorrsysuuidvctrs

Fault tolerance

Rendered fromfault-tolerance.Rmdusingknitr::rmarkdownon Jun 29 2024.

Last update: 2024-04-25
Started: 2023-03-20

messages

Rendered frommessages.Rmdusingknitr::rmarkdownon Jun 29 2024.

Last update: 2024-04-25
Started: 2021-06-09

rrq

Rendered fromrrq.Rmdusingknitr::rmarkdownon Jun 29 2024.

Last update: 2024-04-25
Started: 2021-06-09

Readme and manuals

Help Manual

Help pageTopics
rrq object storeobject_store
Disk-based offloadobject_store_offload_disk
Configure rrqrrq_configure
Create rrq controllerrrq_controller
Register default controllerrrq_default_controller_clear rrq_default_controller_set
List deferred tasksrrq_deferred_list
Destroy queuerrq_destroy
Create simple worker environmentsrrq_envir
Create a heartbeat instancerrq_heartbeat
Kill a process running a heartbeatrrq_heartbeat_kill
Get message responserrq_message_get_response
Detect if message has responserrq_message_has_response
Return ids for messages with responses for a particular worker.rrq_message_response_ids
Send message to workersrrq_message_send
Send a message and wait for responserrq_message_send_and_wait
Queue lengthrrq_queue_length
List queue contentsrrq_queue_list
Remove task ids from a queuerrq_queue_remove
Cancel a taskrrq_task_cancel
Create bulk tasks from a callrrq_task_create_bulk_call
Create bulk tasks from an expressionrrq_task_create_bulk_expr
Create a task from a callrrq_task_create_call
Create a task based on an expressionrrq_task_create_expr
Fetch internal task datarrq_task_data
Delete tasksrrq_task_delete
Test if tasks existrrq_task_exists
Fetch task informationrrq_task_info
List all tasksrrq_task_list
High level task overciewrrq_task_overview
Find task position in queuerrq_task_position
List tasks ahead of a taskrrq_task_preceeding
Fetch task progress informationrrq_task_progress
Post task updaterrq_task_progress_update
Fetch single task resultrrq_task_result
Get the results of a group of tasks, returning them as a list. See rrq_task_result for getting the result of a single task.rrq_task_results
Retry tasksrrq_task_retry
Fetch task statusesrrq_task_status
Fetch task timesrrq_task_times
Wait for group of tasksrrq_task_wait
rrq queue workerrrq_worker
Create worker configurationrrq_worker_config
List worker configurationsrrq_worker_config_list
Read worker configurationrrq_worker_config_read
Save worker configurationrrq_worker_config_save
Clean up exited workersrrq_worker_delete_exited
Detect exited workersrrq_worker_detect_exited
Set worker environmentrrq_worker_envir_set
Test if a worker existsrrq_worker_exists
Worker informationrrq_worker_info
Number of active workersrrq_worker_len
List active workersrrq_worker_list
List exited workersrrq_worker_list_exited
Report on worker loadrrq_worker_load
Returns the last (few) elements in the worker log, in a programmatically useful format (see Value).rrq_worker_log_tail
Read worker process logrrq_worker_process_log
Write worker runner scriptrrq_worker_script
Spawn a workerrrq_worker_spawn
Worker statusesrrq_worker_status
Stop workersrrq_worker_stop
Current task id for workersrrq_worker_task_id
Wait for workersrrq_worker_wait