Module pubsub 

GCP Pub/Sub queue backend façade and re-exports for the queue abstraction.

Mirrors src/queues/sqs/mod.rs. The backend is anchored to the proven Redis/Apalis semantics (repository is the system of record; scheduling is store-and-run-when-due via Redis; no dead-letter the relayer reads) and uses the SQS module only as a reference for the dumb-pipe plumbing.

Re-exports

pub use crate::queues::backoff_config_for_queue;

pub use crate::queues::filter_relayers_for_swap;

pub use crate::queues::retry_delay_secs;

pub use crate::queues::status_check_retry_delay_secs;

pub use crate::queues::HandlerError;

pub use crate::queues::QueueBackend;

pub use crate::queues::QueueBackendError;

pub use crate::queues::QueueHealth;

pub use crate::queues::QueueType;

pub use crate::queues::WorkerContext;

pub use crate::queues::WorkerHandle;

Modules

backend

GCP Pub/Sub backend implementation.

monitoring

Cloud Monitoring backlog-depth read.

schedule

Redis-backed scheduled-job store and due-sweep for the Pub/Sub backend.

worker

Pub/Sub worker implementation for pulling and processing messages.