Skip to main content

stream_insert

velesdb_server

Function stream_insert 

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

Stream-insert a single point via the bounded ingestion channel.

Returns 202 Accepted on success, 429 Too Many Requests when the buffer is full (with Retry-After: 1 header per RFC 7231), 503 Service Unavailable when the drain task has exited, and 404 when the collection is not found.

This handler is async to satisfy Axum’s handler contract; it does not perform any async I/O internally (the channel send is non-blocking).