Skip to content

feat: queue worker (durable:subscriber migration) #424

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
guibeira merged 28 commits into from
Jul 7, 2026
Merged

feat: queue worker (durable:subscriber migration) #424

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
6b588b2
feat(queue): scaffold queue worker crate
guibeira Jul 3, 2026
f50685f
feat(queue): worker config with pluggable transport adapter entry
guibeira Jul 3, 2026
f23b4f2
feat(queue): port in-memory and file-backed queue store with retry/DL…
guibeira Jul 3, 2026
ada7bdf
feat(queue): durable:subscriber consumer loops with ack/nack/DLQ parity
guibeira Jul 3, 2026
6702291
feat(queue): queue/DLQ service functions with exact builtin id parity
guibeira Jul 3, 2026
ec4bbed
feat(queue): boot with builtin iii-queue guard and trigger type regis…
guibeira Jul 3, 2026
730fafb
feat(queue): configuration integration with transport hot-swap
guibeira Jul 3, 2026
0650964
feat(queue): binary entry with seed config and manifest output
guibeira Jul 3, 2026
8743910
test(queue): e2e delivery, DLQ redrive, and restart survival
guibeira Jul 3, 2026
e3d0d50
feat(queue): release tag, README, parity checklist
guibeira Jul 3, 2026
d9d7f77
docs(queue): track latency benchmark gate
guibeira Jul 3, 2026
bfc96d6
feat(queue): add published skill and create-tag option
guibeira Jul 3, 2026
884b280
fix(queue): CI fixes — clippy useless_conversion, Null adapter-config…
guibeira Jul 6, 2026
21bd2d1
feat(queue): port QueueAdapter trait from the engine builtin
guibeira Jul 7, 2026
5a86659
fix(queue): restore engine default bodies on QueueAdapter optional me…
guibeira Jul 7, 2026
56cb8a0
feat(queue): full SubscriberQueueConfig parity (fifo, concurrency, pr…
guibeira Jul 7, 2026
35d0973
fix(queue): accept camelCase maxPriority on the serde path
guibeira Jul 7, 2026
28be863
feat(queue): builtin adapter with per-subscriber concurrency and fifo…
guibeira Jul 7, 2026
c45cfde
fix(queue): builtin adapter fan-out per subscriber and engine concurr…
guibeira Jul 7, 2026
5ec5f20
refactor(queue): route trigger and service functions through QueueAda…
guibeira Jul 7, 2026
cb3586b
feat(queue): redis pub/sub adapter (1:1, DLQ-less like the builtin's)
guibeira Jul 7, 2026
9aaa1a1
feat(queue): rabbitmq types and naming (ported)
guibeira Jul 7, 2026
22347e9
wip(queue): rabbitmq topology, retry, publisher, consumer, worker, ad…
guibeira Jul 7, 2026
8a35278
feat(queue): rabbitmq adapter with retry, DLQ, priority parity
guibeira Jul 7, 2026
6a775fc
feat(queue): adapter factory, memory test adapter, hot-swap re-subscribe
guibeira Jul 7, 2026
43252e7
docs(queue): adapter matrix, parity notes, and config examples for al…
guibeira Jul 7, 2026
f03c30b
chore(queue): drop dead SwappableStore and fix rabbitmq maxRetries do…
guibeira Jul 7, 2026
c43e958
docs(queue): note MOT-3904 upstream tracking for the rabbitmq bare-to…
guibeira Jul 7, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .github/workflows/create-tag.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@ on:
- provider-openai
- provider-xai
- pubsub
- queue
- rbac-proxy
- session-manager
- slack
Expand Down
1 change: 1 addition & 0 deletions .github/workflows/release.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ on:
- 'provider-openai/v*'
- 'provider-xai/v*'
- 'pubsub/v*'
- 'queue/v*'
- 'rbac-proxy/v*'
- 'session-manager/v*'
- 'slack/v*'
Expand Down
Loading
Loading