Struct QueryHandle 

pub struct QueryHandle { /* private fields */ }

RAII admission handle for one native query.

Implementations

impl QueryHandle

pub fn admission_request_id(&self) -> AdmissionRequestId

Stable service-local request id assigned for this admission attempt.

pub fn admission_sequence(&self) -> u64

Monotonic service-local admission sequence assigned when this handle was admitted.

pub fn admission_wait(&self) -> Duration

Time spent waiting in the service admission queue.

pub fn admission_wait_fact(&self) -> Option<AttemptAdmissionWaitFact>

Returns the final controller-owned queue state for this queued admission, when the handle was admitted through the bounded queue. Direct non-queued admission intentionally has no such fact.

pub fn device_budget_bytes(&self) -> u64

Device-memory budget slice assigned to this query.

pub fn device_ordinal(&self) -> usize

CUDA device ordinal selected for this query.

pub fn join_fragment(&self, fragment: &AttemptCapabilityEvidence) -> Result<()>

Joins a fragment planned after this attempt’s claim to its grant.

The fragment runs under the same grant when the granted device provides every capability it requires; its plan identity is then added to what the attempt may execute. The queue and the ledger do not change. A device that lacks a capability, or a released handle, returns a typed error.

pub fn grant_identity(&self) -> Result<GrantIdentity>

Immutable attempt and ledger generation committed for this admission.

pub fn memory_control_policy(&self) -> MemoryControlPolicy

Bounded memory policy this handle will use for native execution.

pub fn source_scheduler_policy(&self) -> SourceSchedulerPolicy

Source scheduler policy copied into the admitted execution context.

pub fn source_chunk_planning_mode(&self) -> SourceChunkPlanningMode

Source chunk planning mode copied into the admitted execution context.

pub fn statistical_aggregate_execution_mode( &self, ) -> StatisticalAggregateExecutionMode

Floating statistical aggregate execution contract assigned to this admitted query.

pub fn aggregate_strategy_execution_options( &self, ) -> AggregateStrategyExecutionOptions

Grouped aggregate strategy execution policy assigned to this admitted query.

pub fn source_chunk_planning_options(&self) -> SourceChunkPlanningOptions

Expert source chunk planning policy assigned to this admitted query.

pub fn acquire_context(&self) -> Result<AdmittedQueryContext>

Acquires an admitted execution context from the service stream pool.

pub async fn acquire_context_with_cancellation_async( self: &Arc<Self>, cancellation: ExecutionCancellation, ) -> Result<AdmittedQueryContext>

Acquires an admitted execution context on this query’s device executor.

pub fn gpu_executor(&self) -> Result<GpuExecutorLease>

Opaque lifecycle-bound executor for synchronous GPU work on this query’s selected device.

pub fn acquire_context_with_cancellation( &self, cancellation: ExecutionCancellation, ) -> Result<AdmittedQueryContext>

Acquires an admitted execution context that observes caller-supplied cooperative cancellation.

Trait Implementations

impl Debug for QueryHandle

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

Formats the value using the given formatter.