pub struct FailoverManager { /* private fields */ }Expand description
Failover manager for endpoint selection and health tracking
Implementations§
Source§impl FailoverManager
impl FailoverManager
Sourcepub fn new(config: FailoverConfig, endpoints: Vec<FailoverEndpoint>) -> Self
pub fn new(config: FailoverConfig, endpoints: Vec<FailoverEndpoint>) -> Self
Create a new failover manager
Sourcepub fn config(&self) -> &FailoverConfig
pub fn config(&self) -> &FailoverConfig
Get the failover configuration
Sourcepub fn endpoints(&self) -> &Vec<FailoverEndpoint>
pub fn endpoints(&self) -> &Vec<FailoverEndpoint>
Get all endpoints
Sourcepub fn update_endpoint_health(
&mut self,
endpoint_id: &str,
health: EndpointHealth,
)
pub fn update_endpoint_health( &mut self, endpoint_id: &str, health: EndpointHealth, )
Update the health of a specific endpoint
Sourcepub fn select_endpoint(
&self,
context: Option<&FailoverContext>,
) -> Option<FailoverEndpoint>
pub fn select_endpoint( &self, context: Option<&FailoverContext>, ) -> Option<FailoverEndpoint>
Get the next endpoint according to the failover strategy
Sourcepub fn healthy_endpoint_count(&self) -> usize
pub fn healthy_endpoint_count(&self) -> usize
Get healthy endpoints count
Sourcepub fn available_endpoint_count(&self) -> usize
pub fn available_endpoint_count(&self) -> usize
Get available endpoints count
Sourcepub fn calculate_retry_delay(&self, attempt: u32) -> Duration
pub fn calculate_retry_delay(&self, attempt: u32) -> Duration
Calculate retry delay with exponential backoff
Trait Implementations§
Auto Trait Implementations§
impl Freeze for FailoverManager
impl RefUnwindSafe for FailoverManager
impl Send for FailoverManager
impl Sync for FailoverManager
impl Unpin for FailoverManager
impl UnwindSafe for FailoverManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<C, E> EntryToVal<C> for Ewhere
C: Collection<Entry = E>,
impl<C, E> EntryToVal<C> for Ewhere
C: Collection<Entry = E>,
Source§type Val = <C as Collection>::Val
type Val = <C as Collection>::Val
The type of values stored in the collection. This might be distinct from
Entry in complex collections.
For example, in a HashMap, while Entry might be a ( key, value ) tuple, Val might only be the value part.Source§fn entry_to_val(self) -> <E as EntryToVal<C>>::Val
fn entry_to_val(self) -> <E as EntryToVal<C>>::Val
Converts an entry into a value representation specific to the type of collection. This conversion is crucial
for handling operations on entries, especially when they need to be treated or accessed as individual values,
such as retrieving the value part from a key-value pair in a hash map.
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<C, Val> ValToEntry<C> for Valwhere
C: CollectionValToEntry<Val>,
impl<C, Val> ValToEntry<C> for Valwhere
C: CollectionValToEntry<Val>,
Source§fn val_to_entry(self) -> <C as CollectionValToEntry<Val>>::Entry
fn val_to_entry(self) -> <C as CollectionValToEntry<Val>>::Entry
Invokes the val_to_entry function of the CollectionValToEntry trait to convert the value to an entry.
Source§type Entry = <C as CollectionValToEntry<Val>>::Entry
type Entry = <C as CollectionValToEntry<Val>>::Entry
Represents the type of entry that corresponds to the value within the collection.
Type
Entry is defined by the Collection trait.