Listening functions in the Radio DuckDB extension
Function category
Listening
4 functionsOpen and manage subscriptions to remote event sources (WebSockets, message buses). Each subscription has a name and an endpoint; incoming messages are buffered for SQL to drain.
Signature
radio_listen(col0: BOOLEAN, col1: INTERVAL) → None
Arguments (Positional)
| Argument | Type | Mode | Description |
|---|---|---|---|
Argument
col0
|
Type
BOOLEAN
|
Mode Positional | Description |
Argument
col1
|
Type
INTERVAL
|
Mode Positional | Description |
Description
Open a listener on a channel — buffers incoming messages so subsequent SELECTs can drain them.
Signature
radio_subscribe(
col0: VARCHAR,
receive_message_capacity := INTEGER,
transmit_retry_initial_delay_ms := INTEGER,
transmit_retry_max_delay_ms := INTEGER,
transmit_retry_multiplier := DOUBLE
) → None
Arguments
| Argument | Type | Mode | Description |
|---|---|---|---|
Argument
col0
|
Type
VARCHAR
|
Mode Positional | Description |
Argument
transmit_retry_max_delay_ms
|
Type
INTEGER
|
Mode Named | Description |
Argument
transmit_retry_multiplier
|
Type
DOUBLE
|
Mode Named | Description |
Argument
transmit_retry_initial_delay_ms
|
Type
INTEGER
|
Mode Named | Description |
Argument
receive_message_capacity
|
Type
INTEGER
|
Mode Named | Description |
Description
Subscribe to a remote endpoint (WebSocket / event bus) under a logical subscription name. Incoming messages flow into the received-messages buffer.
Signature
radio_subscriptions() → None
Description
Table function listing every active subscription with its endpoint and state.
Signature
radio_unsubscribe(col0: VARCHAR) → None
Arguments (Positional)
| Argument | Type | Mode | Description |
|---|---|---|---|
Argument
col0
|
Type
VARCHAR
|
Mode Positional | Description |
Description
Tear down a subscription opened with radio_subscribe.