list_streams/
list_streams.rs

1use s2::{
2    client::{BasinClient, ClientConfig},
3    types::{BasinName, ListStreamsRequest},
4};
5
6#[tokio::main]
7async fn main() -> Result<(), Box<dyn std::error::Error>> {
8    let token = std::env::var("S2_ACCESS_TOKEN")?;
9    let config = ClientConfig::new(token);
10    let basin: BasinName = "my-favorite-basin".parse()?;
11    let basin_client = BasinClient::new(config, basin);
12
13    let prefix = "my-";
14    let list_streams_request = ListStreamsRequest::new().with_prefix(prefix);
15
16    let list_streams_response = basin_client.list_streams(list_streams_request).await?;
17
18    println!("{list_streams_response:#?}");
19
20    Ok(())
21}

list_streams/list_streams.rs

list_streams/
list_streams.rs