athena_rs 3.26.1

Hyper performant polyglot Database driver
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use actix_web::web::Data;
use actix_web::{HttpRequest, HttpResponse, post};
use serde_json::json;

use crate::AppState;
use crate::deferred_write::{FlushSummary, flush_pending};

/// Immediately flushes all pending deferred writes to the database.
///
/// Requires that `deferred_writes.enabled: true` in `config.yaml`.
/// When deferred writes are disabled, returns an informational 200 response.
///
/// # Errors
/// Returns a 500 response when the flush executor encounters an internal error.
#[post("/gateway/deferred/flush")]
pub async fn gateway_deferred_flush_route(
    _req: HttpRequest,
    app_state: Data<AppState>,
) -> HttpResponse {
    let Some(ref buf) = app_state.write_buffer else {
        return HttpResponse::Ok().json(json!({
            "status": "success",
            "message": "Deferred writes are not enabled",
            "flushed": 0,
            "failed": 0,
            "total": 0,
        }));
    };

    let summary: FlushSummary = flush_pending(
        buf,
        app_state.wal_manager.as_deref(),
        &app_state.pg_registry,
        &app_state.cache,
    )
    .await;

    HttpResponse::Ok().json(json!({
        "status": "success",
        "total": summary.total,
        "succeeded": summary.succeeded,
        "failed": summary.failed,
        "invalidated_tables": summary.invalidated_tables,
    }))
}