Build durable streams for real-time data subscriptions.
Delete a value from a stream
Group within the stream that owns the item.
Identifier of the item to delete.
Name of the stream that owns the item.
The value before the update (None if key didn't exist)
Get a value from a stream
Group within the stream to read from.
Identifier of the item to fetch.
Name of the stream to read from.
List all items in a stream group
Group within the stream whose items should be listed.
Name of the stream whose items should be listed.
List all available stream with metadata
List all groups in a stream
Name of the stream whose groups should be listed.
Send a custom event to stream subscribers
JSON payload delivered to subscribers.
Group within the stream to broadcast to.
Optional subscriber ID to target a single subscriber instead of the whole group.
Name of the stream to broadcast to.
Event type label sent alongside the payload.
Set a value in a stream
JSON value to store at the given location.
Group within the stream that owns the item.
Identifier of the item within the group.
Name of the stream that owns the item.
The value after the update
The value before the update (None if key didn't exist)
Atomically update a stream value with multiple operations
Group within the stream that owns the item.
Identifier of the item to update.
Ordered list of update operations applied atomically to the existing value.
Name of the stream that owns the item.
Errors encountered while applying ops. Successfully applied ops are still reflected in `new_value`. Field is omitted from JSON when empty for backward compatibility.
The value after the update
The value before the update (None if key didn't exist)
Stream leave trigger
Optional function ID to evaluate before invoking handler
Stream name to watch
Event type (stream:join or stream:leave)
Group ID
Peer ID
Stream name
Event timestamp (ms)
Stream join trigger
Optional function ID to evaluate before invoking handler
Stream name to watch
Event type (stream:join or stream:leave)
Group ID
Peer ID
Stream name
Event timestamp (ms)
Stream trigger
Optional function ID to evaluate before invoking handler
Group ID filter
Item ID filter
Stream name to watch
Event-specific data (create/update/delete/sync payload)
Stream event type (create, update, delete, sync)
Group ID
Item ID
Stream name
Event timestamp (ms)