API for richfitz/rrq
Simple Redis Queue
| Global functions | |
|---|---|
| `%&&%` | Source code |
| `%||%` | Source code |
| abort_workers_not_ready | Source code |
| assert_character | Source code |
| assert_file_exists | Source code |
| assert_integer_like | Source code |
| assert_is | Source code |
| assert_logical | Source code |
| assert_named | Source code |
| assert_nonmissing | Source code |
| assert_numeric | Source code |
| assert_scalar | Source code |
| assert_scalar_character | Source code |
| assert_scalar_integer_like | Source code |
| assert_scalar_logical | Source code |
| assert_scalar_numeric | Source code |
| assert_scalar_positive_integer | Source code |
| assert_valid_timeout | Source code |
| bin_to_object_safe | Source code |
| blank | Source code |
| blpop | Source code |
| check_args | Source code |
| check_expression | Source code |
| check_function | Source code |
| cleanup_orphans | Source code |
| collector | Source code |
| controller_info | Source code |
| data_frame | Source code |
| delete_keys | Source code |
| df_rows | Source code |
| df_to_list | Source code |
| expression_eval_safely | Source code |
| expression_find_symbols | Source code |
| expression_prepare | Source code |
| expression_restore_locals | Source code |
| find_vars | Source code |
| first | Source code |
| format.rrq_task_error | Source code |
| format.rrq_task_error_group | Source code |
| format.rrq_worker_info | Source code |
| general_poll | Source code |
| get_controller | Source code |
| hash_data | Source code |
| hash_exists | Source code |
| hash_result_to_character | Source code |
| heartbeat_key_kill | Source code |
| heartbeat_process | Source code |
| heartbeat_thread | Source code |
| heartbeat_time_remaining | Source code |
| hostname | Source code |
| is_call | Source code |
| is_namespaced_call | Source code |
| is_serialized_object | Source code |
| is_task_redirect | Source code |
| last | Source code |
| list_to_character | Source code |
| list_to_numeric | Source code |
| lstrip | Source code |
| match_fun | Source code |
| match_fun_envir | Source code |
| mean.worker_load | Source code |
| message_prepare | Source code |
| message_respond | Source code |
| na_drop | Source code |
| object_store | Man page |
| object_store_offload_disk | Man page |
| print.rrq_controller2 | Source code |
| print.rrq_task_error | Source code |
| print.rrq_worker_info | Source code |
| process_id | Source code |
| process_poll | Source code |
| progress_timeout | Source code |
| queue_dependencies | Source code |
| remote_run_task | Source code |
| response_prepare | Source code |
| rpush_max_length | Source code |
| rrq_bulk_prepare_call | Source code |
| rrq_bulk_prepare_call_x | Source code |
| rrq_bulk_prepare_lapply | Source code |
| rrq_bulk_submit | Source code |
| rrq_bulk_wait | Source code |
| rrq_clean | Source code |
| rrq_configure | Man page Source code |
| rrq_configure_read | Source code |
| rrq_controller | Man page |
| rrq_controller2 | Man page Source code |
| rrq_default_controller_clear | Man page Source code |
| rrq_default_controller_set | Man page Source code |
| rrq_deferred_list | Man page Source code |
| rrq_destroy | Man page Source code |
| rrq_enqueue_bulk | Source code |
| rrq_envir | Man page Source code |
| rrq_heartbeat | Man page |
| rrq_heartbeat_kill | Man page Source code |
| rrq_key_queue | Source code |
| rrq_key_task_complete | Source code |
| rrq_key_task_depends_down | Source code |
| rrq_key_task_depends_up | Source code |
| rrq_key_task_depends_up_original | Source code |
| rrq_key_worker_heartbeat | Source code |
| rrq_key_worker_log | Source code |
| rrq_key_worker_message | Source code |
| rrq_key_worker_response | Source code |
| rrq_keys | Source code |
| rrq_lapply | Source code |
| rrq_message_get_response | Man page Source code |
| rrq_message_has_response | Man page Source code |
| rrq_message_response_ids | Man page Source code |
| rrq_message_send | Man page Source code |
| rrq_message_send_and_wait | Man page Source code |
| rrq_object_store | Source code |
| rrq_queue_length | Man page Source code |
| rrq_queue_list | Man page Source code |
| rrq_queue_remove | Man page Source code |
| rrq_scripts | Source code |
| rrq_scripts_load | Source code |
| rrq_task_cancel | Man page Source code |
| rrq_task_create_bulk_call | Man page Source code |
| rrq_task_create_bulk_expr | Man page Source code |
| rrq_task_create_call | Man page Source code |
| rrq_task_create_expr | Man page Source code |
| rrq_task_data | Man page Source code |
| rrq_task_delete | Man page Source code |
| rrq_task_error | Source code |
| rrq_task_error_group | Source code |
| rrq_task_exists | Man page Source code |
| rrq_task_info | Man page Source code |
| rrq_task_list | Man page Source code |
| rrq_task_overview | Man page Source code |
| rrq_task_position | Man page Source code |
| rrq_task_preceeding | Man page Source code |
| rrq_task_progress | Man page Source code |
| rrq_task_progress_update | Man page Source code |
| rrq_task_result | Man page Source code |
| rrq_task_results | Man page Source code |
| rrq_task_retry | Man page Source code |
| rrq_task_status | Man page Source code |
| rrq_task_times | Man page Source code |
| rrq_task_wait | Man page Source code |
| rrq_version_check | Source code |
| rrq_worker | Man page |
| rrq_worker_config | Man page Source code |
| rrq_worker_config_list | Man page Source code |
| rrq_worker_config_read | Man page Source code |
| rrq_worker_config_save | Man page Source code |
| rrq_worker_config_save2 | Man page Source code |
| rrq_worker_delete_exited | Man page Source code |
| rrq_worker_detect_exited | Man page Source code |
| rrq_worker_envir_set | Man page Source code |
| rrq_worker_exists | Man page Source code |
| rrq_worker_info | Man page Source code |
| rrq_worker_len | Man page Source code |
| rrq_worker_list | Man page Source code |
| rrq_worker_list_exited | Man page Source code |
| rrq_worker_load | Man page Source code |
| rrq_worker_log_tail | Man page Source code |
| rrq_worker_main | Source code |
| rrq_worker_main_args | Source code |
| rrq_worker_process_log | Man page Source code |
| rrq_worker_script | Man page Source code |
| rrq_worker_spawn | Man page Source code |
| rrq_worker_spawn2 | Man page Source code |
| rrq_worker_status | Man page Source code |
| rrq_worker_stop | Man page Source code |
| rrq_worker_stop_condition | Source code |
| rrq_worker_task_id | Man page Source code |
| rrq_worker_wait | Man page Source code |
| rstrip | Source code |
| run_message | Source code |
| run_message_echo | Source code |
| run_message_eval | Source code |
| run_message_info | Source code |
| run_message_pause | Source code |
| run_message_ping | Source code |
| run_message_refresh | Source code |
| run_message_resume | Source code |
| run_message_stop | Source code |
| run_message_timeout_get | Source code |
| run_message_timeout_set | Source code |
| run_message_unknown | Source code |
| run_task_cleanup_failure | Source code |
| run_task_cleanup_success | Source code |
| scan_expire | Source code |
| set_names | Source code |
| show_progress | Source code |
| squote | Source code |
| sys_sleep | Source code |
| task_depends_down | Source code |
| task_depends_up | Source code |
| task_depends_walk | Source code |
| task_follow | Source code |
| task_follow_chain | Source code |
| task_follow_root | Source code |
| task_load_from_store | Source code |
| task_submit | Source code |
| task_submit2 | Source code |
| task_submit_n | Source code |
| task_variables | Source code |
| tasks_wait | Source code |
| throw_task_errors | Source code |
| time_checker | Source code |
| timestamp | Source code |
| username | Source code |
| validate_time_poll | Source code |
| vcapply | Source code |
| verify_dependencies_exist | Source code Source code |
| version_info | Source code |
| viapply | Source code |
| vlapply | Source code |
| vnapply | Source code |
| wait_status_change | Source code |
| wait_success | Source code |
| wait_timeout | Source code |
| worker_banner | Source code |
| worker_catch_error | Source code |
| worker_catch_stop | Source code |
| worker_format | Source code |
| worker_format_failed_logs | Source code |
| worker_info_collect | Source code |
| worker_initialise | Source code |
| worker_log | Source code |
| worker_log_format | Source code |
| worker_log_parse | Source code |
| worker_log_tail_1 | Source code |
| worker_loop | Source code |
| worker_naturalsort | Source code |
| worker_run_task | Source code |
| worker_run_task_local | Source code |
| worker_run_task_local_new | Source code |
| worker_run_task_local_old | Source code |
| worker_run_task_separate_process | Source code |
| worker_run_task_start | Source code |
| worker_step | Source code |
| worker_task_failed | Source code |
| worker_wait_alive | Source code |
| write_bin | Source code |
| write_rrq_worker | Source code |
