reconfigure_basin/
reconfigure_basin.rs

1use s2::{
2    client::{Client, ClientConfig},
3    types::{BasinConfig, BasinName, ReconfigureBasinRequest, StorageClass, StreamConfig},
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 client = Client::new(config);
11
12    let basin: BasinName = "my-favorite-basin".parse()?;
13
14    let default_stream_config_updates =
15        StreamConfig::new().with_storage_class(StorageClass::Standard);
16    let basin_config_updates = BasinConfig::new()
17        .with_default_stream_config(default_stream_config_updates)
18        .with_create_stream_on_append(true)
19        .with_create_stream_on_read(true);
20
21    let reconfigure_basin_request = ReconfigureBasinRequest::new(basin)
22        .with_config(basin_config_updates)
23        // Field mask specifies which fields to update.
24        .with_mask(vec!["default_stream_config.retention_policy".to_string()]);
25
26    let updated_basin_config = client.reconfigure_basin(reconfigure_basin_request).await?;
27
28    println!("{updated_basin_config:#?}");
29
30    Ok(())
31}
reconfigure_basin/reconfigure_basin.rs

reconfigure_basin/
reconfigure_basin.rs
