Struct SqsBackend

pub struct SqsBackend { /* private fields */ }

AWS SQS backend for job queue operations.

Supports both Standard and FIFO queues (auto-detected at startup, or set via SQS_QUEUE_TYPE). FIFO mode provides message ordering and exactly-once delivery; Standard mode offers higher throughput and native per-message delays.

Implementations

impl SqsBackend

pub async fn new() -> Result<Self, QueueBackendError>

Creates a new SQS backend.

Loads AWS configuration from environment and builds queue URLs. Queue type is determined by SQS_QUEUE_TYPE:

• auto (default): probes a reference queue at startup to detect the type
• standard / fifo: uses the specified type directly, skipping probing

Environment Variables

• AWS_REGION - AWS region (required)
• SQS_QUEUE_URL_PREFIX - Optional custom prefix
• AWS_ACCOUNT_ID - Required only when SQS_QUEUE_URL_PREFIX is not set
• SQS_QUEUE_TYPE - Queue type: auto (default), standard, or fifo

Errors

Returns ConfigError if required environment variables are missing or if queue type cannot be determined (no queues found, or both types exist).

Trait Implementations

impl Clone for SqsBackend

fn clone(&self) -> SqsBackend

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SqsBackend

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

Formats the value using the given formatter.

impl QueueBackend for SqsBackend

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>>, ) -> 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.