Paginators

List operations like listBasins, listStreams, and listAccessTokens return paginated results. SDKs provide automatic pagination helpers that handle async fetching of subsequent pages transparently.

Usage

Instead of manually handling hasMore and startAfter cursor parameters, use the paginator variants which return an iterable that automatically fetches pages as needed:

TypeScript
Go
Rust

// Iterate through all streams with automatic pagination
for await (const stream of basin.streams.listAll()) {
	console.log(stream.name);
}

// Iterate through all streams with automatic pagination
iter := basin.Streams.Iter(ctx, nil)
for iter.Next() {
	stream := iter.Value()
	fmt.Println(stream.Name)
}
if err := iter.Err(); err != nil {
	log.Fatal(err)
}

// Iterate through all streams with automatic pagination
let mut stream = basin.list_all_streams(ListAllStreamsInput::new());
while let Some(info) = stream.next().await {
    let info = info?;
    println!("{}", info.name);
}

Filtering

Paginators accept the same filter options as their single-page list analogs:

TypeScript
Go
Rust

// List streams with a prefix filter
for await (const stream of basin.streams.listAll({ prefix: "events/" })) {
	console.log(stream.name);
}

// List streams with a prefix filter
iter := basin.Streams.Iter(ctx, &s2.ListStreamsArgs{Prefix: "events/"})
for iter.Next() {
	fmt.Println(iter.Value().Name)
}

// List streams with a prefix filter
let input = ListAllStreamsInput::new().with_prefix("events/".parse()?);
let mut stream = basin.list_all_streams(input);
while let Some(info) = stream.next().await {
    println!("{}", info?.name);
}

Deleted Resources

Paginators automatically filter out resources that are pending deletion. This is useful because delete operations mark resources for deletion, but actual garbage collection happens asynchronously. To include deleted resources in the results:

TypeScript
Go
Rust

// Include streams that are being deleted
for await (const stream of basin.streams.listAll({ includeDeleted: true })) {
	console.log(stream.name, stream.deletedAt);
}

// Include streams that are being deleted
iter := basin.Streams.Iter(ctx, &s2.ListStreamsArgs{IncludeDeleted: true})
for iter.Next() {
	stream := iter.Value()
	fmt.Println(stream.Name, stream.DeletedAt)
}

// Include streams that are being deleted
let input = ListAllStreamsInput::new().with_include_deleted(true);
let mut stream = basin.list_all_streams(input);
while let Some(info) = stream.next().await {
    let info = info?;
    println!("{} {:?}", info.name, info.deleted_at);
}

SDKs

​Usage

​Filtering

​Deleted Resources

Usage

Filtering

Deleted Resources