vantage-aws 0.4.2

AWS API persistence backend for Vantage framework — incubating
Documentation 
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

use serde::{Deserialize, Serialize};
use vantage_table::table::Table;

use crate::{AwsAccount, eq};

use super::event::{LogEvent, events_table};

/// One CloudWatch Logs stream from `DescribeLogStreams`. Field names
/// match the wire shape.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct LogStream {
    #[serde(rename = "logStreamName")]
    pub log_stream_name: String,
    #[serde(default)]
    pub arn: String,
    #[serde(rename = "creationTime", default)]
    pub creation_time: i64,
    #[serde(rename = "firstEventTimestamp", default)]
    pub first_event_timestamp: i64,
    #[serde(rename = "lastEventTimestamp", default)]
    pub last_event_timestamp: i64,
    #[serde(rename = "lastIngestionTime", default)]
    pub last_ingestion_time: i64,
    #[serde(rename = "storedBytes", default)]
    pub stored_bytes: i64,
    #[serde(rename = "uploadSequenceToken", default)]
    pub upload_sequence_token: String,
}

/// `DescribeLogStreams` table. AWS requires `logGroupName` before it
/// will list anything, so add `eq("logGroupName", "...")` first.
///
/// ```no_run
/// # use vantage_aws::{AwsAccount, eq};
/// # use vantage_aws::models::logs::streams_table;
/// # async fn run() -> vantage_core::Result<()> {
/// # let aws = AwsAccount::from_default()?;
/// let mut streams = streams_table(aws);
/// streams.add_condition(eq("logGroupName", "/aws/lambda/foo"));
/// # Ok(()) }
/// ```
pub fn streams_table(aws: AwsAccount) -> Table<AwsAccount, LogStream> {
    Table::new(
        "json1/logStreams:logs/Logs_20140328.DescribeLogStreams",
        aws,
    )
    .with_id_column("logStreamName")
    .with_column_of::<String>("arn")
    .with_column_of::<i64>("creationTime")
    .with_column_of::<i64>("firstEventTimestamp")
    .with_column_of::<i64>("lastEventTimestamp")
    .with_column_of::<i64>("lastIngestionTime")
    .with_column_of::<i64>("storedBytes")
    .with_column_of::<String>("uploadSequenceToken")
}

impl LogStream {
    /// The owning log group's name, parsed out of [`Self::arn`].
    /// Stream ARNs have the shape
    /// `arn:aws:logs:<region>:<account>:log-group:<group>:log-stream:<stream>`.
    pub fn log_group_name(&self) -> Option<&str> {
        let after = self.arn.split(":log-group:").nth(1)?;
        after.split(":log-stream:").next()
    }

    /// Events table pre-filtered to *this* stream. The log group is
    /// pulled from this stream's ARN; if the ARN is empty, pass it
    /// in via [`Self::ref_events_in`] instead.
    pub fn ref_events(&self, aws: AwsAccount) -> Option<Table<AwsAccount, LogEvent>> {
        let group = self.log_group_name()?;
        Some(self.ref_events_in(aws, group))
    }

    /// Events table pre-filtered to *this* stream within the given
    /// log group. Use when the stream ARN isn't populated (e.g.
    /// streams synthesised by hand).
    pub fn ref_events_in(
        &self,
        aws: AwsAccount,
        log_group_name: &str,
    ) -> Table<AwsAccount, LogEvent> {
        let mut t = events_table(aws);
        t.add_condition(eq("logGroupName", log_group_name));
        t.add_condition(eq("logStreamNamePrefix", self.log_stream_name.clone()));
        t
    }
}