list_streams/
list_streams.rs

1use s2_sdk::{
2    S2,
3    types::{BasinName, ListStreamsInput, S2Config},
4};
5
6#[tokio::main]
7async fn main() -> Result<(), Box<dyn std::error::Error>> {
8    let access_token =
9        std::env::var("S2_ACCESS_TOKEN").map_err(|_| "S2_ACCESS_TOKEN env var not set")?;
10    let basin_name: BasinName = std::env::var("S2_BASIN")
11        .map_err(|_| "S2_BASIN env var not set")?
12        .parse()?;
13
14    let s2 = S2::new(S2Config::new(access_token))?;
15    let basin = s2.basin(basin_name);
16
17    let input = ListStreamsInput::new().with_prefix("my-".parse()?);
18    let page = basin.list_streams(input).await?;
19    println!("{page:#?}");
20
21    Ok(())
22}

list_streams/list_streams.rs

list_streams/
list_streams.rs