Struct RetryPolicy 

pub struct RetryPolicy { /* private fields */ }

How often, and how patiently, a failed request is repeated.

The default is five attempts with a doubling delay from one second, capped at ten — about fifteen seconds of patience, which covers a proxy restart or a scheduler reconnect without making a genuinely broken cluster feel hung.

Implementations

impl RetryPolicy

pub fn new( attempts: u32, initial_backoff: Duration, max_backoff: Duration, ) -> Self

attempts tries in total, waiting initial_backoff after the first failure and doubling up to max_backoff.

attempts is clamped to at least one: zero attempts would mean never sending the request at all.

pub fn none() -> Self

Send once, report whatever comes back.

pub fn quiet(self) -> Self

The same policy, retrying without saying so.

A retry normally announces itself on stderr, so a launcher that pauses for fifteen seconds says why rather than looking hung. Inside a job that same stream is the cluster’s diagnostic channel — a bounded buffer the operation UI shows, and the one the job’s own messages go to — so a worker that talks to the cluster while a proxy is flaky would fill it with retry chatter.

With the tracing feature on the announcement is a WARN event rather than a line on stderr, and this mutes that too. Same reason: a subscriber installed inside a job is, more often than not, writing to the very buffer this exists to protect. RetryPolicy::loud puts the messages back whichever form they take.

A Client built inside a job is quiet already; this is for choosing it anywhere else:

use ytsaurus_client::{Client, RetryPolicy};

let client = Client::new("http://localhost:8000")
    .with_retries(RetryPolicy::default().quiet());

pub fn loud(self) -> Self

The same policy, announcing each retry.

The default outside a job, and what puts the messages back inside one — a job whose stderr nobody else is using may well want them, and so does one whose subscriber ships them somewhere other than stderr.

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RetryPolicy

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.

impl Eq for RetryPolicy

impl PartialEq for RetryPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RetryPolicy