Struct scylla::transport::downgrading_consistency_retry_policy::DowngradingConsistencyRetryPolicy

pub struct DowngradingConsistencyRetryPolicy;

Expand description

Downgrading consistency retry policy - retries with lower consistency level if it knows
that the initial CL is unreachable. Also, it behaves as DefaultRetryPolicy when it believes that the initial CL is reachable. Behaviour based on [DataStax Java Driver]
(https://docs.datastax.com/en/drivers/java/3.11/com/datastax/driver/core/policies/DowngradingConsistencyRetryPolicy.html)

Implementations§

impl DowngradingConsistencyRetryPolicy

pub fn new() -> DowngradingConsistencyRetryPolicy

Trait Implementations§

impl Debug for DowngradingConsistencyRetryPolicy

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

Formats the value using the given formatter. Read more

impl Default for DowngradingConsistencyRetryPolicy

fn default() -> DowngradingConsistencyRetryPolicy

Returns the “default value” for a type. Read more

impl RetryPolicy for DowngradingConsistencyRetryPolicy

fn new_session(&self) -> Box<dyn RetrySession>

Called for each new query, starts a session of deciding about retries

fn clone_boxed(&self) -> Box<dyn RetryPolicy>

Used to clone this RetryPolicy

Auto Trait Implementations§

impl RefUnwindSafe for DowngradingConsistencyRetryPolicy

impl Send for DowngradingConsistencyRetryPolicy

impl Sync for DowngradingConsistencyRetryPolicy

impl Unpin for DowngradingConsistencyRetryPolicy

impl UnwindSafe for DowngradingConsistencyRetryPolicy

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more