seamless-glance 1.0.0

Fast, read-only AWS TUI for cloud infrastructure visibility and triage
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

use async_trait::async_trait;

use crate::{
    aws::clients::AwsClients,
    models::{
        describable::{shell_quote, DescribableResource},
        service_status::ServiceStatus,
    },
};

#[derive(Debug, Clone)]
pub struct SqsSummary {
    pub queue_count: u32,
    pub dlq_count: u32,
    pub status: ServiceStatus,
}

#[derive(Debug, Clone)]
pub struct SqsQueueInfo {
    pub name: String,
    pub queue_url: String,
    pub is_fifo: bool,
    pub messages_available: i64,
    pub messages_in_flight: i64,
    pub has_dlq: bool,
}

impl SqsQueueInfo {
    pub const HIGH_VISIBLE_THRESHOLD: i64 = 100;
    pub const HIGH_IN_FLIGHT_THRESHOLD: i64 = 50;

    pub fn has_high_visible_messages(&self) -> bool {
        self.messages_available >= Self::HIGH_VISIBLE_THRESHOLD
    }

    pub fn has_high_in_flight_messages(&self) -> bool {
        self.messages_in_flight >= Self::HIGH_IN_FLIGHT_THRESHOLD
    }

    pub fn has_backlog_incident(&self) -> bool {
        self.has_high_visible_messages() || self.has_high_in_flight_messages()
    }

    pub fn backlog_signals(&self) -> Vec<&'static str> {
        let mut signals = Vec::new();

        if self.has_high_visible_messages() {
            signals.push("visible");
        }

        if self.has_high_in_flight_messages() {
            signals.push("in-flight");
        }

        signals
    }
}

#[async_trait]
impl DescribableResource for SqsQueueInfo {
    fn resource_name(&self) -> String {
        self.name.clone()
    }

    async fn describe(&self, clients: &AwsClients) -> anyhow::Result<String> {
        let resp = clients
            .sqs
            .get_queue_attributes()
            .queue_url(&self.queue_url)
            .attribute_names(aws_sdk_sqs::types::QueueAttributeName::All)
            .send()
            .await?;

        Ok(format!("{:#?}", resp))
    }

    fn console_url(&self, region: &str) -> Option<String> {
        Some(format!(
            "https://{}.console.aws.amazon.com/sqs/v3/home?region={}#/queues/{}",
            region, region, self.name
        ))
    }

    fn cli_command(&self, region: &str) -> Option<String> {
        Some(format!(
            "aws sqs get-queue-attributes --queue-url {} --attribute-names All --region {}",
            shell_quote(&self.queue_url),
            shell_quote(region)
        ))
    }
}