Struct UdbClient 

pub struct UdbClient { /* private fields */ }

A connected UDB data-plane client bound to one identity.

Implementations

impl UdbClient

pub async fn connect( endpoint: impl Into<String>, meta: Metadata, ) -> Result<Self, Error>

Connect to a broker’s data-plane listener (:50051 by default).

Note the port: UDB runs SEPARATE listeners with different authorization models — the data plane authorizes through Casbin, while the native service listener uses scope-based endpoint security. A credential accepted by one is not automatically accepted by the other, and the mismatch presents as a permissions error rather than a wrong-address error.

pub fn with_channel(channel: Channel, meta: Metadata) -> Self

Wrap an already-configured channel — use this for TLS, custom timeouts, load balancing, or interceptors.

pub fn metadata(&self) -> &Metadata

The connection’s metadata.

pub fn with_audit( &self, purpose: impl Into<String>, correlation_id: impl Into<String>, ) -> Self

A copy of this client carrying request-scoped audit fields.

Identity is intentionally not settable here; see Metadata.

pub fn with_bearer_token(&self, token: impl Into<String>) -> Self

Replace the bearer credential, e.g. after a token refresh.

pub fn request<T>(&self, message: T) -> Result<Request<T>, Status>

Wrap a message in a request carrying this connection’s metadata.

Public so callers can reach an RPC this wrapper does not expose yet without hand-rolling — and without hand-rolling the headers.

pub fn raw(&mut self) -> &mut DataBrokerClient<Channel>

The raw generated client, for RPCs this wrapper does not cover.

Pair it with UdbClient::request so metadata is still applied.

pub fn with_policy(&self, policy: CallPolicy) -> Self

Apply a deadline/retry policy to every call this client makes.

pub async fn select( &mut self, req: SelectRequest, ) -> Result<RecordSet, UdbError>

Read. Retry policy comes from the contract, not this wrapper.

pub async fn upsert( &mut self, req: UpsertRequest, ) -> Result<MutationResponse, UdbError>

Write. The contract declares it replayable, so it retries.

pub async fn update( &mut self, req: UpdateRequest, ) -> Result<MutationResponse, UdbError>

Write. Contract-declared replayable.

pub async fn delete( &mut self, req: DeleteRequest, ) -> Result<MutationResponse, UdbError>

Write. Contract-declared replayable.

pub async fn bulk_cas( &mut self, req: BulkCasRequest, ) -> Result<BulkCasResponse, UdbError>

Compare-and-swap. The contract does NOT declare it replayable: a CAS that timed out may have committed, and a repeat would compare against state its own first attempt wrote.

pub async fn vector_search( &mut self, req: VectorSearchRequest, ) -> Result<VectorSet, UdbError>

Read.

pub async fn vector_upsert( &mut self, req: VectorUpsertRequest, ) -> Result<MutationResponse, UdbError>

Write. Not contract-declared replayable.

Trait Implementations

impl Clone for UdbClient

fn clone(&self) -> UdbClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for UdbClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.