Struct QueueService 

pub struct QueueService { /* private fields */ }

Implementations

impl QueueService

pub async fn new(db_path: &str) -> Result<Self>

pub async fn create_queue(&self, queue_name: &str) -> Result<()>

pub async fn create_queue_with_config(&self, config: &QueueConfig) -> Result<()>

pub async fn send_message( &self, queue_name: &str, body: &str, attributes: Option<HashMap<String, MessageAttributeValue>>, deduplication_id: Option<String>, ) -> Result<String>

pub async fn receive_message( &self, queue_name: &str, ) -> Result<Option<ReceivedMessage>>

pub async fn delete_message(&self, receipt_handle: &str) -> Result<bool>

pub async fn delete_queue(&self, queue_name: &str) -> Result<bool>

pub async fn restore_message(&self, message_id: &str) -> Result<bool>

pub async fn list_queues(&self) -> Result<Vec<(String, String)>>

pub async fn get_queue_attributes( &self, queue_name: &str, ) -> Result<Option<QueueAttributes>>

pub async fn get_queue_messages( &self, queue_name: &str, ) -> Result<Vec<(String, String, String, Option<String>, u32, Option<String>, Option<String>)>>

pub async fn get_all_queue_messages( &self, queue_name: &str, ) -> Result<Vec<(String, String, String, Option<String>, u32, Option<String>, Option<String>, String, Option<String>, Option<String>)>>

pub async fn receive_message_with_dlq( &self, queue_name: &str, ) -> Result<Option<ReceivedMessage>>

pub async fn move_message_to_dlq( &self, message_id: &str, failure_reason: &str, ) -> Result<bool>

pub async fn get_dlq_messages( &self, dlq_name: &str, ) -> Result<Vec<(String, String, String, String, Option<String>)>>

pub async fn redrive_dlq_messages( &self, dlq_name: &str, source_queue: &str, max_messages: Option<u32>, ) -> Result<u32>

pub async fn purge_dlq(&self, dlq_name: &str) -> Result<u32>

pub async fn record_metric( &self, queue_name: &str, metric: &QueueMetric, ) -> Result<()>

pub async fn cleanup_expired_messages( &self, retention_config: &RetentionConfig, ) -> Result<u32>

pub async fn get_queue_config( &self, queue_name: &str, ) -> Result<Option<QueueConfig>>

pub async fn set_queue_attributes( &self, queue_name: &str, attributes: HashMap<String, String>, ) -> Result<()>

pub async fn send_message_enhanced( &self, queue_name: &str, body: &str, attributes: Option<HashMap<String, MessageAttributeValue>>, deduplication_id: Option<String>, delay_seconds: u32, ) -> Result<String>

pub async fn send_message_enhanced_with_group( &self, queue_name: &str, body: &str, attributes: Option<HashMap<String, MessageAttributeValue>>, deduplication_id: Option<String>, delay_seconds: u32, message_group_id: Option<String>, ) -> Result<String>

pub async fn receive_messages_enhanced( &self, queue_name: &str, max_messages: u32, wait_time_seconds: u32, ) -> Result<Vec<ReceivedMessage>>

pub async fn send_messages_batch( &self, entries: Vec<(String, String, String, Option<HashMap<String, MessageAttributeValue>>, Option<String>, u32)>, ) -> Result<Vec<Result<String, String>>>

pub async fn delete_messages_batch( &self, message_ids: Vec<String>, ) -> Result<Vec<Result<bool, String>>>

pub async fn receive_messages_batch( &self, queue_name: &str, max_messages: u32, ) -> Result<Vec<ReceivedMessage>>