Skip to main content

enable_streaming

velesdb_server

Function enable_streaming 

Source 
pub async fn enable_streaming(
    __arg0: State<Arc<AppState>>,
    __arg1: Path<String>,
    __arg2: Json<EnableStreamingRequest>,
) -> impl IntoResponse
Expand description

Enable streaming ingestion on a collection.

Spawns the background drain task so subsequent calls to /collections/{name}/stream/insert accept points instead of returning a 409 Conflict “streaming not configured” error. Omitted body fields fall back to the engine defaults. Calling this again replaces the existing ingester (the old drain task is aborted).

Returns 200 OK on success and 404 Not Found when the collection does not exist.