Struct CallBuilder 

pub struct CallBuilder<'a, K, S = ClientOneShot> { /* private fields */ }

Implementations

impl<'a, K> CallBuilder<'a, K, ClientOneShot>

pub fn with_implicit_session(self) -> Self

Execute with an empty session_id (server-side implicit session) instead of leasing from the driver pool.

impl<'a, K, S> CallBuilder<'a, K, S>

pub fn param(self, name: impl Into<String>, value: impl Into<Value>) -> Self

pub fn params(self, params: HashMap<String, Value>) -> Self

pub fn timeout(self, timeout: Duration) -> Self

Wall-clock limit for the call. Retries transient errors until this deadline when combined with .idempotent(true). Without .timeout(), retries continue until a non-retryable error.

For QueryStream the timeout bounds opening the gRPC stream and any retries; iterating result sets is not bounded by this value.

Inside retry_tx, per-call .timeout() is capped by the remaining retry_tx deadline.

pub fn idempotent(self, idempotent: bool) -> Self

pub fn collect_stats(self) -> Self

pub fn with_commit(self, commit: bool) -> Self

Override auto-commit (commit_tx in Query Service TxControl).

One-shot defaults depend on Self::with_tx_mode: implicit mode relies on the server; explicit modes default to commit_tx: true. Interactive transactions default to commit_tx: false unless [Self::with_commit(true)] is set on the last query.

When using [Self::query] with with_commit(true) inside a transaction, you must fully drain the stream and call QueryStream::close — dropping the stream early cancels the gRPC call and does not commit.

pub fn with_tx_mode(self, mode: TxMode) -> Self

Set transaction isolation for this call.

Default on [QueryClient] is TxMode::Implicit (no tx_control; the server infers isolation from the SQL). Interactive transactions use the mode from [TransactionOptions] unless overridden here.

TxMode::Implicit inside [Transaction] returns a runtime error — DDL and other non-transactional statements must run on [QueryClient], not inside a transaction.

pub fn implicit_tx(self) -> Self

Shorthand for Self::with_tx_mode (ImplicitTx / NoTx).

TxMode::Implicit inside [Transaction] returns a runtime error — DDL and other non-transactional statements must run on [QueryClient], not inside a transaction.

impl<'a, T, S> CallBuilder<'a, OneRow<T>, S>

pub fn typed<U: FromYdbRow>(self) -> CallBuilder<'a, OneRow<U>, S>

pub fn optional(self) -> CallBuilder<'a, OptionalRow<T>, S>

Trait Implementations

impl<'a, S> IntoFuture for CallBuilder<'a, ExecCall, S>

type Output = Result<(), YdbError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <CallBuilder<'a, ExecCall, S> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.

impl<'a, T: FromYdbRow + 'a, S> IntoFuture for CallBuilder<'a, OneRow<T>, S>

type Output = Result<T, YdbError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <CallBuilder<'a, OneRow<T>, S> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.

impl<'a, T: FromYdbRow + 'a, S> IntoFuture for CallBuilder<'a, OptionalRow<T>, S>

type Output = Result<Option<T>, YdbError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <CallBuilder<'a, OptionalRow<T>, S> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.

impl<'a, S> IntoFuture for CallBuilder<'a, OneResultSet, S>

type Output = Result<ResultSet, YdbError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <CallBuilder<'a, OneResultSet, S> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.

impl<'a, S> IntoFuture for CallBuilder<'a, Streamed, S>

type Output = Result<QueryStream<'a>, YdbError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <CallBuilder<'a, Streamed, S> as IntoFuture>::Output> + Send + 'a>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.