Trait qiniu_http_client::Chooser

pub trait Chooser: Debug + Sync + Send {
    fn choose(
        &self,
        ips: &[IpAddrWithPort],
        opts: ChooseOptions<'_>
    ) -> ChosenResults;
    fn feedback(&self, feedback: ChooserFeedback<'_>);

    fn async_choose<'a>(
        &'a self,
        ips: &'a [IpAddrWithPort],
        opts: ChooseOptions<'a>
    ) -> BoxFuture<'a, ChosenResults> { ... }
    fn async_feedback<'a>(
        &'a self,
        feedback: ChooserFeedback<'a>
    ) -> BoxFuture<'a, ()> { ... }
}

选择 IP 地址接口

还提供了对选择结果的反馈接口，用以修正自身选择逻辑，优化选择结果

同时提供阻塞接口和异步接口，异步接口则需要启用 async 功能

Required Methods

fn choose(&self, ips: &[IpAddrWithPort], opts: ChooseOptions<'_>) -> ChosenResults

选择 IP 地址列表

fn feedback(&self, feedback: ChooserFeedback<'_>)

反馈选择的 IP 地址列表的结果

Provided Methods

fn async_choose<'a>(
    &'a self,
    ips: &'a [IpAddrWithPort],
    opts: ChooseOptions<'a>
) -> BoxFuture<'a, ChosenResults>

Available on crate feature async only.

异步选择 IP 地址列表

该方法的异步版本为 Self::async_choose。

fn async_feedback<'a>(
    &'a self,
    feedback: ChooserFeedback<'a>
) -> BoxFuture<'a, ()>

Available on crate feature async only.

异步反馈选择的 IP 地址列表的结果

Implementations on Foreign Types

impl<'b, T: 'b + Chooser + ?Sized> Chooser for &'b Twhere
    &'b T: Debug + Sync + Send,

fn choose(&self, ips: &[IpAddrWithPort], opts: ChooseOptions<'_>) -> ChosenResults

fn feedback(&self, feedback: ChooserFeedback<'_>)

fn async_choose<'a>(
    &'a self,
    ips: &'a [IpAddrWithPort],
    opts: ChooseOptions<'a>
) -> BoxFuture<'a, ChosenResults>

Available on crate feature async only.

fn async_feedback<'a>(
    &'a self,
    feedback: ChooserFeedback<'a>
) -> BoxFuture<'a, ()>

Available on crate feature async only.

impl<'b, T: 'b + Chooser + ?Sized> Chooser for &'b mut Twhere
    &'b mut T: Debug + Sync + Send,

fn choose(&self, ips: &[IpAddrWithPort], opts: ChooseOptions<'_>) -> ChosenResults

fn feedback(&self, feedback: ChooserFeedback<'_>)

fn async_choose<'a>(
    &'a self,
    ips: &'a [IpAddrWithPort],
    opts: ChooseOptions<'a>
) -> BoxFuture<'a, ChosenResults>

Available on crate feature async only.

fn async_feedback<'a>(
    &'a self,
    feedback: ChooserFeedback<'a>
) -> BoxFuture<'a, ()>

Available on crate feature async only.

impl<T: Chooser + ?Sized> Chooser for Box<T>where
    Box<T>: Debug + Sync + Send,

fn choose(&self, ips: &[IpAddrWithPort], opts: ChooseOptions<'_>) -> ChosenResults

fn feedback(&self, feedback: ChooserFeedback<'_>)

fn async_choose<'a>(
    &'a self,
    ips: &'a [IpAddrWithPort],
    opts: ChooseOptions<'a>
) -> BoxFuture<'a, ChosenResults>

Available on crate feature async only.

fn async_feedback<'a>(
    &'a self,
    feedback: ChooserFeedback<'a>
) -> BoxFuture<'a, ()>

Available on crate feature async only.

impl<T: Chooser + ?Sized> Chooser for Rc<T>where
    Rc<T>: Debug + Sync + Send,

fn choose(&self, ips: &[IpAddrWithPort], opts: ChooseOptions<'_>) -> ChosenResults

fn feedback(&self, feedback: ChooserFeedback<'_>)

fn async_choose<'a>(
    &'a self,
    ips: &'a [IpAddrWithPort],
    opts: ChooseOptions<'a>
) -> BoxFuture<'a, ChosenResults>

Available on crate feature async only.

fn async_feedback<'a>(
    &'a self,
    feedback: ChooserFeedback<'a>
) -> BoxFuture<'a, ()>

Available on crate feature async only.

impl<T: Chooser + ?Sized> Chooser for Arc<T>where
    Arc<T>: Debug + Sync + Send,

fn choose(&self, ips: &[IpAddrWithPort], opts: ChooseOptions<'_>) -> ChosenResults

fn feedback(&self, feedback: ChooserFeedback<'_>)

fn async_choose<'a>(
    &'a self,
    ips: &'a [IpAddrWithPort],
    opts: ChooseOptions<'a>
) -> BoxFuture<'a, ChosenResults>

Available on crate feature async only.

fn async_feedback<'a>(
    &'a self,
    feedback: ChooserFeedback<'a>
) -> BoxFuture<'a, ()>

Available on crate feature async only.

Implementors

impl Chooser for DirectChooser

impl Chooser for IpChooser

impl Chooser for SubnetChooser

impl<C: Chooser> Chooser for NeverEmptyHandedChooser<C>

impl<C: Chooser> Chooser for ShuffledChooser<C>