udb 0.3.1

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

from __future__ import annotations

import grpc


class UdbError(Exception):
    """Base exception for the UDB Python SDK."""


class UdbConfigurationError(UdbError):
    """Raised when client configuration is invalid."""


class UdbRpcError(UdbError):
    """Raised when the broker returns a non-OK gRPC status."""

    def __init__(self, rpc_name: str, error: grpc.RpcError):
        self.rpc_name = rpc_name
        self.raw = error
        self.code = error.code()
        self.details = error.details() or ""
        super().__init__(
            f"UDB {rpc_name} failed: gRPC status={self.code.name} details={self.details}"
        )