Stream Resources

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

TypeScript
Python
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 = await basin.list_streams(prefix="user-")

# Create a stream
await basin.create_stream(
    "user-actions",
    # config=StreamConfig(...)  # optional
)

# Get configuration
config = await basin.get_stream_config("user-actions")

# Delete
await basin.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
// Optionally, pass `.with_config(StreamConfig { .. })` to CreateStreamInput.
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.

Configuration

Control Plane

Data Plane

Utilities

Stream Resources