openzeppelin_relayer/queues/pubsub/mod.rs
1//! GCP Pub/Sub queue backend façade and re-exports for the queue abstraction.
2//!
3//! Mirrors `src/queues/sqs/mod.rs`. The backend is anchored to the proven
4//! Redis/Apalis semantics (repository is the system of record; scheduling is
5//! store-and-run-when-due via Redis; no dead-letter the relayer reads) and uses
6//! the SQS module only as a reference for the dumb-pipe plumbing.
7pub use crate::queues::{
8 backoff_config_for_queue, filter_relayers_for_swap, retry_delay_secs,
9 status_check_retry_delay_secs, HandlerError, QueueBackend, QueueBackendError, QueueHealth,
10 QueueType, WorkerContext, WorkerHandle,
11};
12
13pub mod backend;
14pub mod monitoring;
15pub mod schedule;
16pub mod worker;