marvin-j97/corinth

📬 Portable message queue written in Rust

corinth's Issues

Dependabot couldn't find a package.json for this project

Dependabot couldn't find a package.json for this project.

Dependabot requires a package.json to evaluate your project's current JavaScript dependencies. It had expected to find one at the path: /test/package.json.

If this isn't a JavaScript project, or if it is a library, you may wish to disable updates for it from within Dependabot.

View the update logs.

Test: Metadata file updating after PATCH

Compact route

Queue persistence (optional)

• Store items
• Load items
• Store queue metadata
• Apply stored queue metadata
• Auto detect existing queues on startup
• Unit tests

Error logging

Use eprintln everywhere

Optional queue max length

Optimize docker image size

Use separate build context

Message updatedAt timestamp

Cleanup dedup map

Build release scripts/workflows

Add optional queue description property

POST /queue/<id>/<msg>/ack

Acknowledge reception of a message

GET /queue/:name: return ack & dedup times

DELETE /queue/<id>

Deletes a queue

Support batch /dequeue

PATCH /queue/<id> to change times (and possibly other future settings)

Unit test DELETE & PURGE

Basic access management

GET /queues

List names & number of queues

Update README, documentation, code (comments)

Use Path::join

Use ActixWeb?

Redeliver attempts counter in Message

Webhook events

Remove on-the-fly queue creation on enqueue

• Remove logic
• Update API
• Adjust unit tests

Priority queue

POST /queue/<id>/enqueue

Enqueue a new item to a queue

?deduplication_id (optional)

message gets internal ID no matter what

GET /queue/<id>/peek

Return the queue head. Don't dequeue queue head though.

Diagnostics (read/write times, size over time), show in dashboard as graphs

Support batch /enqueue

DELETE /queue/<id>/dequeue

Removes and returns the queue head.

?ack=true (optional): Automatically confirm reception, increments done counter
otherwise: add message to ack map, if reception is not confirmed, it will be added back to the queue

DELETE /queue/<id>/purge

Removes all items from a queue
Clear deduplication set & ack map
Rewrite files

?reset_stats=true

Management console

• Create app folder with a Vue 3 Vite app.
• Serve index.html, js & css files over server.
• Create button component
• Create input component
• Queue details page
• -> Link to DLQ if it exists
• optionally poll for data changes
• Purge queue button
• Delete queue button
• Edit queue (description, deduplication time & requeue time)
• Create queue with DLQ
• Create queue with description
• Create queue with custom requeue, deduplication time, max size
• In queue listing, optionally poll for data changes or refresh button
• Show queue's disk & memory size in listing
• Server info page (index page)
• Enqueue message(s)
• Dequeue message(s)
• Peek queue head
• Finishing touches/refactor

dockerfile

Deduplication on enqueue

Dead letter queue rerouting when msg requeue threshold reached

MessageState -> Failed

dead_letter_target
dead_letter_threshold

queues designated as dead letter queues cannot be deleted

Add assets folder to workflows & Dockerfile

Fix tests

Benchmark Vec vs VecDeque vs LinkedList

PUT /queue/<id>

Create a queue

dequeue DELETE -> POST

API docs

Don't allow max length to change after creation

Benchmarks

Auto-compact interval

• Start interval for new queues
• Start interval for queues loaded from disk
• CORINTH_COMPACT_INTERVAL environment variable
• Unit tests

Add queue disk size & lastCompactedAt properties