Package: rrq 0.7.23

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.23.tar.gz
rrq_0.7.23.zip(r-4.7)rrq_0.7.23.zip(r-4.6)rrq_0.7.23.zip(r-4.5)
rrq_0.7.23.tgz(r-4.6-any)rrq_0.7.23.tgz(r-4.5-any)
rrq_0.7.23.tar.gz(r-4.7-any)rrq_0.7.23.tar.gz(r-4.6-any)
rrq_0.7.23.tgz(r-4.6-emscripten)
manual.pdf |manual.html✨
card.svg |card.png
rrq/json (API)
NEWS

# Install 'rrq' in R:

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

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

Pkgdown/docs site:https://mrc-ide.github.io

On CRAN:

cluster infrastructure

6.31 score 25 stars 2 packages 15 scripts 66 exports 24 dependencies

Last updated from:5ff431a3c9 (on master). Checks:9 OK. Indexed: yes.

Target	Result	Time
linux-devel-x86_64	OK	124
source / vignettes	OK	176
linux-release-x86_64	OK	133
macos-release-arm64	OK	107
macos-oldrel-arm64	OK	111
windows-devel	OK	118
windows-release	OK	95
windows-oldrel	OK	103
wasm-release	OK	112

Exports:object_store rrq_configure rrq_controller rrq_controller2 rrq_default_controller_clear rrq_default_controller_set rrq_deferred_list rrq_destroy rrq_envir rrq_heartbeat rrq_heartbeat_kill rrq_message_get_response rrq_message_has_response rrq_message_response_ids rrq_message_send rrq_message_send_and_wait rrq_queue_length rrq_queue_list rrq_queue_remove rrq_task_cancel rrq_task_create_bulk_call rrq_task_create_bulk_expr rrq_task_create_call rrq_task_create_expr rrq_task_data rrq_task_delete rrq_task_exists rrq_task_info rrq_task_list rrq_task_log rrq_task_overview rrq_task_position rrq_task_preceeding rrq_task_progress rrq_task_progress_update rrq_task_result rrq_task_results rrq_task_retry rrq_task_status rrq_task_times rrq_task_wait rrq_worker rrq_worker_config rrq_worker_config_list rrq_worker_config_read rrq_worker_config_save rrq_worker_config_save2 rrq_worker_delete_exited rrq_worker_detect_exited rrq_worker_envir_refresh rrq_worker_envir_set rrq_worker_exists rrq_worker_info rrq_worker_len rrq_worker_list rrq_worker_list_exited rrq_worker_load rrq_worker_log_tail rrq_worker_process_log rrq_worker_script rrq_worker_spawn rrq_worker_spawn2 rrq_worker_status rrq_worker_stop rrq_worker_task_id rrq_worker_wait

Dependencies:askpass callr cli crayon digest docopt glue hms ids lifecycle logwatch openssl pkgconfig prettyunits processx progress ps R6 redux rlang storr sys uuid vctrs

Fault tolerance

Rendered fromfault-tolerance.Rmdusingknitr::rmarkdownon May 20 2026.

Last update: 2024-11-11
Started: 2023-03-20

messages

Rendered frommessages.Rmdusingknitr::rmarkdownon May 20 2026.

Last update: 2024-11-11
Started: 2021-06-09

rrq

Rendered fromrrq.Rmdusingknitr::rmarkdownon May 20 2026.

Last update: 2024-11-11
Started: 2021-06-09

Citation

Development and contributors

Readme and manuals

Help Manual

Help page	Topics
rrq object store	object_store
Disk-based offload	object_store_offload_disk
Create rrq controller	rrq_controller
Register default controller	rrq_default_controller_clear rrq_default_controller_set
List deferred tasks	rrq_deferred_list
Destroy queue	rrq_destroy
Create simple worker environments	rrq_envir
Create a heartbeat instance	rrq_heartbeat
Kill a process running a heartbeat	rrq_heartbeat_kill
Get message response	rrq_message_get_response
Detect if message has response	rrq_message_has_response
Return ids for messages with responses for a particular worker.	rrq_message_response_ids
Send message to workers	rrq_message_send
Send a message and wait for response	rrq_message_send_and_wait
Queue length	rrq_queue_length
List queue contents	rrq_queue_list
Remove task ids from a queue	rrq_queue_remove
Cancel a task	rrq_task_cancel
Create bulk tasks from a call	rrq_task_create_bulk_call
Create bulk tasks from an expression	rrq_task_create_bulk_expr
Create a task from a call	rrq_task_create_call
Create a task based on an expression	rrq_task_create_expr
Fetch internal task data	rrq_task_data
Delete tasks	rrq_task_delete
Test if tasks exist	rrq_task_exists
Fetch task information	rrq_task_info
List all tasks	rrq_task_list
Fetch task logs	rrq_task_log
High level task overview	rrq_task_overview
Find task position in queue	rrq_task_position
List tasks ahead of a task	rrq_task_preceeding
Fetch task progress information	rrq_task_progress
Post task update	rrq_task_progress_update
Fetch single task result	rrq_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 tasks	rrq_task_retry
Fetch task statuses	rrq_task_status
Fetch task times	rrq_task_times
Wait for group of tasks	rrq_task_wait
rrq queue worker	rrq_worker
Create worker configuration	rrq_worker_config
List worker configurations	rrq_worker_config_list
Read worker configuration	rrq_worker_config_read
Save worker configuration	rrq_worker_config_save
Clean up exited workers	rrq_worker_delete_exited
Detect exited workers	rrq_worker_detect_exited
Set worker environment	rrq_worker_envir_refresh rrq_worker_envir_set
Test if a worker exists	rrq_worker_exists
Worker information	rrq_worker_info
Number of active workers	rrq_worker_len
List active workers	rrq_worker_list
List exited workers	rrq_worker_list_exited
Report on worker load	rrq_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 log	rrq_worker_process_log
Write worker runner script	rrq_worker_script
Spawn a worker	rrq_worker_spawn
Worker statuses	rrq_worker_status
Stop workers	rrq_worker_stop
Current task id for workers	rrq_worker_task_id
Wait for workers	rrq_worker_wait