type_bridge.crud.rust_manager

rust_manager

Rust-backed manager facade.

RustTypeDBManager

RustTypeDBManager(connection, model_class)

Manager that delegates CRUD and query execution to Rust.

Source code in type_bridge/crud/rust_manager.py

def __init__(self, connection: Connection, model_class: type[T]):
    self._connection = connection
    self.model_class = model_class
    self._descriptor = register_model_descriptor(model_class)
    self._manager_instance: Any | None = None
    if issubclass(model_class, Entity):
        self._kind = "entity"
    elif issubclass(model_class, Relation):
        self._kind = "relation"
    else:
        raise TypeError(f"Unsupported model type: {model_class}")
    self._hook_runner = HookRunner()

RustTypeDBQuery

RustTypeDBQuery(manager, filters, expressions=())

Rust-backed chainable query using the typed dynamic query surface.

Source code in type_bridge/crud/rust_manager.py

def __init__(
    self,
    manager: _RustQueryManager[T],
    filters: dict[str, Any],
    expressions: tuple[Any, ...] = (),
):
    self._manager = manager
    self._filters = dict(filters)
    self._expressions = list(expressions)
    self._order_fields: list[tuple[str, bool]] = []
    self._limit_value: int | None = None
    self._offset_value: int | None = None

RustTypeDBGroupByQuery

RustTypeDBGroupByQuery(manager, filters, expressions, group_fields)

Rust-backed grouped aggregation query for exact-match Phase 3 filters.

Source code in type_bridge/crud/rust_manager.py

def __init__(
    self,
    manager: _RustQueryManager[T],
    filters: dict[str, Any],
    expressions: list[Any],
    group_fields: list[str],
):
    self._manager = manager
    self._filters = dict(filters)
    self._expressions = list(expressions)
    self._group_fields = group_fields