Struct pd_client::util::Client

pub struct Client {
    timer: Handle,
    pub(crate) inner: RwLock<Inner>,
    pub feature_gate: FeatureGate,
    enable_forwarding: bool,
}

A leader client doing requests asynchronous.

Fields

timer: Handle

inner: RwLock<Inner>

feature_gate: FeatureGate

enable_forwarding: bool

Implementations

impl Client

pub(crate) fn new(
    env: Arc<Environment>,
    security_mgr: Arc<SecurityManager>,
    client_stub: PdClientStub,
    members: GetMembersResponse,
    target: TargetInfo,
    enable_forwarding: bool
) -> Client

pub fn update_client(
    &self,
    client_stub: PdClientStub,
    target: TargetInfo,
    members: GetMembersResponse
)

pub fn handle_region_heartbeat_response<F>(
    self: &Arc<Self>,
    f: F
) -> PdFuture<()> where
    F: Fn(RegionHeartbeatResponse) + Send + 'static, 

pub fn on_reconnect(&self, f: Box<dyn Fn() + Sync + Send + 'static>)

pub fn request<Req, Resp, F>(
    self: &Arc<Self>,
    req: Req,
    func: F,
    retry: usize
) -> Request<Req, F> where
    Req: Clone + 'static,
    F: FnMut(&Client, Req) -> PdFuture<Resp> + Send + 'static, 

pub fn get_leader(&self) -> Member

pub async fn reconnect(&self, force: bool) -> Result<()>

Re-establishes connection with PD leader in asynchronized fashion.

If force is false, it will reconnect only when members change. Note: Retrying too quickly will return an error due to cancellation. Please always try to reconnect after sending the request first.