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
22
23
24
25
26
27
28
29
30
31

use s2::{
    client::{Client, ClientConfig},
    types::{
        AccessTokenId, AccessTokenInfo, AccessTokenScope, Operation, PermittedOperationGroups,
        ReadWritePermissions, ResourceSet,
    },
};

#[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 client = Client::new(config);

    let access_token_id: AccessTokenId = "my-access-token".parse()?;
    let access_token_info = AccessTokenInfo::new(access_token_id).with_scope(
        AccessTokenScope::new()
            .with_op_groups(
                PermittedOperationGroups::new()
                    .with_account(ReadWritePermissions::new().with_read(true)),
            )
            .with_op(Operation::CreateStream)
            .with_streams(ResourceSet::Prefix("my-stream-prefix".to_string()))
            .with_basins(ResourceSet::Exact("my-perfect-basin".to_string())),
    );
    let token = client.issue_access_token(access_token_info).await?;

    println!("Access token: {token}");

    Ok(())
}