streamstore 0.21.1

DEPRECATED: Use s2-sdk instead
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use s2::{
    client::{BasinClient, ClientConfig},
    types::{BasinName, ListStreamsRequest},
};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let token = std::env::var("S2_ACCESS_TOKEN")?;
    let config = ClientConfig::new(token);
    let basin: BasinName = "my-favorite-basin".parse()?;
    let basin_client = BasinClient::new(config, basin);

    let prefix = "my-";
    let list_streams_request = ListStreamsRequest::new().with_prefix(prefix);

    let list_streams_response = basin_client.list_streams(list_streams_request).await?;

    println!("{list_streams_response:#?}");

    Ok(())
}