Expand description
GCP Pub/Sub backend implementation.
Provides a Pub/Sub-backed implementation of the QueueBackend trait. Each of
the 8 queue types maps to a topic (publish) and a subscription (consume).
Deferred/retrying jobs are held in Redis sorted sets and published when due
(store-and-run-when-due), so the topic only ever carries already-due jobs.
Anchored to the proven Redis/Apalis semantics; uses src/queues/sqs/ only as
a reference for the dumb-pipe plumbing.
Structsยง
- PubSub
Backend - GCP Pub/Sub backend for job queue operations.