Struct TriesDispenser 

pub struct TriesDispenser { /* private fields */ }

Wraps an inner dispenser with a bounded attempt loop over retryable attempt failures, owning the attempt_* metrics and the per-attempt panic catch. Constructed only when a tries budget of 0 or ≥ 2 resolves for the op (see the module doc; 1 / absent skip construction).

Implementations

impl TriesDispenser

pub fn wrap( inner: Arc<dyn OpDispenser>, tries: u32, metrics: Arc<ActivityMetrics>, backoff_base_ms: u64, backoff_max_ms: u64, backoff_ratio: f64, stop: StopView, op_name: String, exemplars: ExemplarSampler, advisory: Option<Arc<AdvisoryGate>>, ) -> Arc<dyn OpDispenser>

Wrap inner with a total-attempts budget, retry pacing, and optional retry-error exemplar sampling.

Trait Implementations

impl ExecEventSubscriber for TriesDispenser

fn submit_exemplar(&self, ex: &ExecExemplar<'_>)

Submit one sampled exemplar to the structured sink.

fn submit_advisory( &self, op_name: &str, cycle: u64, tries_budget: u32, error_class: &str, message: &str, )

Submit one first-sighting retry advisory (default-on signal; the per-phase AdvisoryGate bounds it).

impl OpDispenser for TriesDispenser

fn execute<'a>( &'a self, cycle: u64, ctx: &'a ExecCtx<'a>, ) -> Pin<Box<dyn Future<Output = Result<OpResult, ExecutionError>> + Send + 'a>>

Execute an operation for the given cycle.

fn inner_dispenser(&self) -> Option<&dyn OpDispenser>

Returns the wrapped dispenser when this is a wrapper, None when this is a leaf (the adapter’s base dispenser — e.g. CQL raw / prepared / batch, HTTP, stdout, plotter, …).

fn describe(&self) -> Option<String>

One-line description of the op this dispenser represents — typically the statement text / request shape with bind-point placeholders left unresolved ({table}, {key}, ?, …).

fn describe_resolved(&self, wires: &dyn WireSource) -> Option<String>

Render the actual op the dispenser would fire for the given cycle — the dryrun-equivalent view of the statement after every bind point is interpolated.

fn canonical_kernel(&self) -> Option<&Arc<dyn Kernel>>

SRD-68 invariant I-3 — the dispenser’s canonical Polydat Kernel, established at construction by map_op from its parent — the parent itself, or a kernel bound under it. Any engine: the executor finds the program to bind per fiber by program_id. Returns None for dispensers that don’t own a kernel (adapters with no Polydat needs, or wrappers that delegate to an inner dispenser).

fn adapter_metrics(&self) -> Vec<(String, Labels, MetricValue)>

Snapshot adapter-specific metrics for inclusion in the capture snapshot.

fn status_counters(&self) -> Vec<(&str, u64)>

Adapter-specific status line entries (cumulative, non-destructive read).

fn rows_per_op(&self) -> usize

The op’s uniform per-invocation cursor consumption — how many consecutive wire ordinals one execute call reads and covers.

impl WrappingDispenser for TriesDispenser