Struct SqsClient 

pub struct SqsClient { /* private fields */ }

Implementations

impl SqsClient

pub fn new(config: AwsConfig) -> Self

pub async fn list_lambda_triggers( &self, queue_arn: &str, ) -> Result<Vec<LambdaTrigger>>

pub async fn list_queues(&self, prefix: &str) -> Result<Vec<SqsQueue>>

pub async fn list_message_move_tasks( &self, queue_url: &str, ) -> Result<(String, String, String, String, String)>

pub async fn get_queue_arn(&self, queue_url: &str) -> Result<String>

pub async fn list_pipes(&self, queue_arn: &str) -> Result<Vec<EventBridgePipe>>

pub async fn list_tags(&self, queue_arn: &str) -> Result<Vec<QueueTag>>

pub async fn get_queue_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_delayed_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_not_visible_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_visible_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_empty_receives_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_messages_deleted_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_messages_received_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_messages_sent_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>

pub async fn get_queue_sent_message_size_metrics( &self, queue_name: &str, ) -> Result<Vec<(i64, f64)>>