Stream Resources

Streams live within basins and are the core data structure in S2. You can have an unlimited amount of streams, and create them instantly (even on first use). Data retention policies (e.g. TTL-based trimming), storage classes, timestamping behavior, are all configurable.

TypeScript
Go
Rust

// List streams
const streams = await basin.streams.list({ prefix: "user-" });

// Create a stream
await basin.streams.create({
	stream: "user-actions",
	config: {
		/* optional configuration */
	},
});

// Get configuration
const streamConfig = await basin.streams.getConfig({ stream: "user-actions" });

// Delete
await basin.streams.delete({ stream: "user-actions" });

// List streams
streams, _ := basin.Streams.List(ctx, &s2.ListStreamsArgs{Prefix: "user-"})

// Create a stream
basin.Streams.Create(ctx, s2.CreateStreamArgs{
	Stream: "user-actions",
	Config: &s2.StreamConfig{ /* optional */ },
})

// Get configuration
config, _ := basin.Streams.GetConfig(ctx, "user-actions")

// Delete
basin.Streams.Delete(ctx, "user-actions")

// List streams
let streams = basin
    .list_streams(ListStreamsInput::new().with_prefix("user-".parse()?))
    .await?;

// Create a stream
basin
    .create_stream(CreateStreamInput::new("user-actions".parse()?))
    .await?;

// Get configuration
let config = basin.get_stream_config("user-actions".parse()?).await?;

// Delete
basin
    .delete_stream(DeleteStreamInput::new("user-actions".parse()?))
    .await?;

See stream configuration for more details on all options.

SDKs