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