Struct PollPlan 

pub struct PollPlan {
    pub max_polls: u32,
    pub poll_interval: Duration,
    pub partition_concurrency: usize,
    pub row_cap: Option<usize>,
}

How a 202 handle is polled: how many times, and how long to wait between GETs.

Fields

max_polls: u32

Maximum number of poll GETs before LifecycleErrorCode::PollQuotaExhausted.

poll_interval: Duration

Wall-clock delay the async driver waits between successive poll GETs on a still-running (202) handle. The pure machine carries this as data only; the crate::driver performs the cancel-aware sleep. The transport only backs off on retryable statuses (429/5xx); a 202 returns immediately, so without this interval the poll loop would spin with no gap.

partition_concurrency: usize

How many non-inline partitions the driver fetches concurrently once a result set completes (a window; assembly stays in partition order).

row_cap: Option<usize>

Stop fetching further partitions once at least this many rows are assembled. The statement then completes early and reports itself partial (CompletedStatement::is_partial).

Implementations

impl PollPlan

pub fn with_max_polls(max_polls: u32) -> Self

A plan with an explicit poll ceiling (clamped to at least 1), keeping the default inter-poll interval.

pub fn with_poll_interval(self, poll_interval: Duration) -> Self

Set the inter-poll wait, clamped to MIN_POLL_INTERVAL so the 202 poll loop can never become a tight spin.

pub fn effective_poll_interval(&self) -> Duration

The effective inter-poll wait, never below MIN_POLL_INTERVAL even if the public field was set directly.

pub fn with_partition_concurrency(self, concurrency: usize) -> Self

Set the partition fetch window, clamped to 1..=MAX_PARTITION_CONCURRENCY.

pub fn with_row_cap(self, row_cap: Option<usize>) -> Self

Stop fetching partitions once row_cap rows are assembled (None fetches every partition).

pub fn effective_partition_concurrency(&self) -> usize

The effective window size, never zero even if the field was set directly.

Trait Implementations

impl Clone for PollPlan

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PollPlan

impl Debug for PollPlan

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

Formats the value using the given formatter.

impl Default for PollPlan

fn default() -> Self

Returns the “default value” for a type.

impl Eq for PollPlan

impl PartialEq for PollPlan

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for PollPlan