Package: liteq 1.1.0
Gábor Csárdi
liteq: Lightweight Portable Message Queue Using 'SQLite'
Temporary and permanent message queues for R. Built on top of 'SQLite' databases. 'SQLite' provides locking, and makes it possible to detect crashed consumers. Crashed jobs can be automatically marked as "failed", or put in the queue again, potentially a limited number of times.
Authors:
liteq_1.1.0.tar.gz
liteq_1.1.0.zip(r-4.5)liteq_1.1.0.zip(r-4.4)liteq_1.1.0.zip(r-4.3)
liteq_1.1.0.tgz(r-4.4-any)liteq_1.1.0.tgz(r-4.3-any)
liteq_1.1.0.tar.gz(r-4.5-noble)liteq_1.1.0.tar.gz(r-4.4-noble)
liteq_1.1.0.tgz(r-4.4-emscripten)liteq_1.1.0.tgz(r-4.3-emscripten)
liteq.pdf |liteq.html✨
liteq/json (API)
NEWS
| # Install liteq in R: |
| install.packages('liteq', repos = c('https://r-lib.r-universe.dev', 'https://cloud.r-project.org')) |
Bug tracker:https://github.com/r-lib/liteq/issues
Last updated 8 months agofrom:961b352e41
Exports:ackconsumecreate_queuedefault_dbdelete_queueensure_queueis_emptylist_failed_messageslist_messageslist_queuesmessage_countnackpublishremove_failed_messagesrequeue_failed_messagestry_consume
Dependencies:assertthatbitbit64blobcachemclicpp11DBIfastmapgluelifecyclememoisepkgconfigplogrrappdirsrlangRSQLitevctrs
Readme and manuals
Help Manual
| Help page | Topics |
|---|---|
| Acknowledge that the work on a message has finished successfully | ack |
| Consume a message from a queue | consume |
| Create a queue in a database | create_queue |
| The name of the default database | default_db |
| Delete a queue | delete_queue |
| Make sure that a queue exists | ensure_queue |
| Check if a queue is empty | is_empty |
| List failed messages in a queue | list_failed_messages |
| List all messages in a queue | list_messages |
| List all queues in a database | list_queues |
| Lightweight Portable Message Queue Using 'SQLite' | liteq |
| Get the number of messages in a queue. | message_count |
| Report that the work on a message has failed | nack |
| Publish messages in a queue | publish |
| Remove failed messages from the queue | remove_failed_messages |
| Requeue failed messages | requeue_failed_messages |
| Consume a message if there is one available | try_consume |
