[PR #667] [CLOSED] Adds Mongo broker #1819

Closed
opened 2026-03-07 22:13:22 +03:00 by kerem · 0 comments
Owner

📋 Pull Request Information

Original PR: https://github.com/hibiken/asynq/pull/667
Author: @vladfr
Created: 6/7/2023
Status: Closed

Base: masterHead: mongo


📝 Commits (3)

📊 Changes

5 files changed (+663 additions, -7 deletions)

View changed files

📝 client.go (+25 -3)
📝 go.mod (+2 -0)
📝 go.sum (+105 -1)
internal/mongobroker/mongobroker.go (+498 -0)
📝 server.go (+33 -3)

📄 Description

Adds support for Mongo as a broker with support for enqueue, dequeue, schedules, retries and retention; task cleanup via ttl indexes.

This is a draft to see if there's any interest. It's also waiting for #577.


🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.

## 📋 Pull Request Information **Original PR:** https://github.com/hibiken/asynq/pull/667 **Author:** [@vladfr](https://github.com/vladfr) **Created:** 6/7/2023 **Status:** ❌ Closed **Base:** `master` ← **Head:** `mongo` --- ### 📝 Commits (3) - [`721561d`](https://github.com/hibiken/asynq/commit/721561ddd826dcb114221feb90853bc3f0fd1995) adds mongo broker first commit - [`8598f07`](https://github.com/hibiken/asynq/commit/8598f07e2d605e2af4db66c81f20987c99d67fc3) Merge branch 'master' into mongo - [`a28715d`](https://github.com/hibiken/asynq/commit/a28715d838b2fdf978a604a8dbc1989b6be819f2) update go mod ### 📊 Changes **5 files changed** (+663 additions, -7 deletions) <details> <summary>View changed files</summary> 📝 `client.go` (+25 -3) 📝 `go.mod` (+2 -0) 📝 `go.sum` (+105 -1) ➕ `internal/mongobroker/mongobroker.go` (+498 -0) 📝 `server.go` (+33 -3) </details> ### 📄 Description Adds support for Mongo as a broker with support for enqueue, dequeue, schedules, retries and retention; task cleanup via ttl indexes. This is a draft to see if there's any interest. It's also waiting for #577. --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>
kerem 2026-03-07 22:13:22 +03:00
Sign in to join this conversation.
No milestone
No project
No assignees
1 participant
Notifications
Due date
The due date is invalid or out of range. Please use the format "yyyy-mm-dd".

No due date set.

Dependencies

No dependencies set.

Reference
starred/asynq#1819
No description provided.