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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

from .client import UdbAsyncClient, UdbClient, decode_records, to_record_json, to_struct
from .exceptions import UdbConfigurationError, UdbError, UdbRpcError
from .metadata import Metadata, UDB_PROTOCOL_VERSION
from .negotiation import (
    ENCODING_RECORD_BATCH_V2,
    ENCODING_RECORD_SET_V1,
    Negotiator,
    client_supported_encodings,
)

# Generated robustness layer (rendered by `udb sdk generate` into
# generated_client.py). Imported defensively so a checkout without the generated
# file still works with the hand-written client.
try:  # pragma: no cover - presence depends on codegen having run
    from .generated_client import (
        GeneratedClient,
        RetryPolicy,
        UdbDetailedRpcError,
    )

    _HAS_GENERATED = True
except ImportError:  # pragma: no cover
    _HAS_GENERATED = False

__all__ = [
    "ENCODING_RECORD_BATCH_V2",
    "ENCODING_RECORD_SET_V1",
    "Metadata",
    "Negotiator",
    "UDB_PROTOCOL_VERSION",
    "UdbAsyncClient",
    "UdbClient",
    "UdbConfigurationError",
    "UdbError",
    "UdbRpcError",
    "client_supported_encodings",
    "decode_records",
    "to_record_json",
    "to_struct",
]

if _HAS_GENERATED:
    __all__ += ["GeneratedClient", "RetryPolicy", "UdbDetailedRpcError"]