Struct PubSubBackend 

pub struct PubSubBackend { /* private fields */ }

GCP Pub/Sub backend for job queue operations.

Constructed only after a startup probe confirms every required topic AND subscription exists. Deferred-job scheduling and cron locks reuse the relayer’s existing Redis.

Implementations

impl PubSubBackend

pub async fn new( redis_connections: Arc<RedisConnections>, ) -> Result<Self, QueueBackendError>

Creates a new Pub/Sub backend.

Authenticates via ADC (or targets the emulator when PUBSUB_EMULATOR_HOST is set), builds the topic/subscription maps and cached publishers, and probes that every required topic AND subscription exists — failing fast with a ConfigError naming what is missing. Dead-letter topics are NOT probed.

Errors

Returns ConfigError if PUBSUB_PROJECT_ID is unset, ADC cannot be resolved, or any required topic/subscription is missing/inaccessible.

Trait Implementations

impl Clone for PubSubBackend

fn clone(&self) -> PubSubBackend

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PubSubBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl QueueBackend for PubSubBackend

fn produce_transaction_request<'life0, 'async_trait>( &'life0 self, job: Job<TransactionRequest>, scheduled_on: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<String, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Produces a transaction request job to the queue.

fn produce_transaction_submission<'life0, 'async_trait>( &'life0 self, job: Job<TransactionSend>, scheduled_on: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<String, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Produces a transaction submission job to the queue.

fn produce_transaction_status_check<'life0, 'async_trait>( &'life0 self, job: Job<TransactionStatusCheck>, scheduled_on: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<String, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Produces a transaction status check job to the queue.

fn produce_notification<'life0, 'async_trait>( &'life0 self, job: Job<NotificationSend>, scheduled_on: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<String, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Produces a notification send job to the queue.

fn produce_token_swap_request<'life0, 'async_trait>( &'life0 self, job: Job<TokenSwapRequest>, scheduled_on: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<String, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Produces a token swap request job to the queue.

fn produce_relayer_health_check<'life0, 'async_trait>( &'life0 self, job: Job<RelayerHealthCheck>, scheduled_on: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<String, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Produces a relayer health check job to the queue.

fn initialize_workers<'life0, 'async_trait>( &'life0 self, app_state: Arc<ThinData<DefaultAppState>>, handle: Handle, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkerHandle>, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initializes and starts all worker tasks for this backend.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<QueueHealth>, QueueBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Performs a health check on all queues.

fn backend_type(&self) -> QueueBackendType

Returns the backend type identifier.

fn shutdown(&self)

Signals all workers to shut down gracefully.