udb 0.4.21

Universal Data Broker — a Rust gRPC broker over multiple databases (Postgres, MySQL, SQLite, MongoDB, ClickHouse, Cassandra, MSSQL, Redis, Qdrant, S3, Neo4j, …) with per-tenant RLS, 2PC, sagas, and CDC.
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

//! Best-effort versioned dot-topic outbox emission for `CacheService` (mirrors
//! `lock_service`). Gated on the `redis` feature, since cache events are only
//! produced by the Redis-backed handlers.

use super::super::native_helpers::{
    NativeEventContext, enqueue_outbox_event_with_context, native_service_context,
};
use super::CacheServiceImpl;

/// Best-effort versioned dot-topic outbox event (mirrors `lock_service`).
pub(crate) async fn emit_event(
    svc: &CacheServiceImpl,
    metadata: &tonic::metadata::MetadataMap,
    topic: &str,
    tenant_id: &str,
    namespace: &str,
    payload: serde_json::Value,
) {
    let Some(pool) = svc.pg_pool.as_ref() else {
        return;
    };
    let context = native_service_context(metadata, tenant_id, "");
    enqueue_outbox_event_with_context(
        pool,
        svc.outbox_relation.as_deref(),
        topic,
        namespace,
        tenant_id,
        &context.project_id,
        payload,
        NativeEventContext {
            target_resource: namespace.to_string(),
            ..NativeEventContext::default()
        },
        Some(&svc.metrics),
    )
    .await;
}