Struct GrpcCompactorProxyClient

pub struct GrpcCompactorProxyClient {
    pub core: Arc<RwLock<GrpcCompactorProxyClientCore>>,
    endpoint: String,
}

Client to proxy server. Cloning the instance is lightweight.

Todo(wcy-fdu): add refresh client interface.

Fields

core: Arc<RwLock<GrpcCompactorProxyClientCore>>

endpoint: String

Implementations

impl GrpcCompactorProxyClient

pub async fn new(endpoint: String) -> Self

async fn recreate_core(&self)

async fn connect_to_endpoint(endpoint: String) -> Channel

pub async fn get_new_sst_ids( &self, request: GetNewSstIdsRequest, ) -> Result<Response<GetNewSstIdsResponse>, Status>

pub async fn report_compaction_task( &self, request: ReportCompactionTaskRequest, ) -> Result<Response<ReportCompactionTaskResponse>, Status>

pub async fn get_system_params( &self, ) -> Result<Response<GetSystemParamsResponse>, Status>

fn get_retry_strategy() -> impl Iterator<Item = Duration>

fn should_retry(status: &Status) -> bool

Trait Implementations

impl Clone for GrpcCompactorProxyClient

fn clone(&self) -> GrpcCompactorProxyClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for GrpcCompactorProxyClient

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

Formats the value using the given formatter.