delete_stream/
delete_stream.rs

1use s2_sdk::{
2    S2,
3    types::{BasinName, DeleteStreamInput, S2Config, StreamName},
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    let stream_name: StreamName = std::env::var("S2_STREAM")
14        .map_err(|_| "S2_STREAM env var not set")?
15        .parse()?;
16
17    let s2 = S2::new(S2Config::new(access_token))?;
18    let basin = s2.basin(basin_name);
19
20    let input = DeleteStreamInput::new(stream_name);
21    basin.delete_stream(input).await?;
22    println!("Deletion requested");
23
24    Ok(())
25}

delete_stream/delete_stream.rs

delete_stream/
delete_stream.rs