Struct HummockManagerServiceClient

pub struct HummockManagerServiceClient<T> {
    inner: Grpc<T>,
}

Fields

inner: Grpc<T>

Implementations

impl HummockManagerServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<StdError>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> HummockManagerServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> HummockManagerServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn unpin_version_before( &mut self, request: impl IntoRequest<UnpinVersionBeforeRequest>, ) -> Result<Response<UnpinVersionBeforeResponse>, Status>

pub async fn get_current_version( &mut self, request: impl IntoRequest<GetCurrentVersionRequest>, ) -> Result<Response<GetCurrentVersionResponse>, Status>

pub async fn list_version_deltas( &mut self, request: impl IntoRequest<ListVersionDeltasRequest>, ) -> Result<Response<ListVersionDeltasResponse>, Status>

pub async fn replay_version_delta( &mut self, request: impl IntoRequest<ReplayVersionDeltaRequest>, ) -> Result<Response<ReplayVersionDeltaResponse>, Status>

pub async fn get_assigned_compact_task_num( &mut self, request: impl IntoRequest<GetAssignedCompactTaskNumRequest>, ) -> Result<Response<GetAssignedCompactTaskNumResponse>, Status>

pub async fn trigger_compaction_deterministic( &mut self, request: impl IntoRequest<TriggerCompactionDeterministicRequest>, ) -> Result<Response<TriggerCompactionDeterministicResponse>, Status>

pub async fn disable_commit_epoch( &mut self, request: impl IntoRequest<DisableCommitEpochRequest>, ) -> Result<Response<DisableCommitEpochResponse>, Status>

pub async fn get_new_object_ids( &mut self, request: impl IntoRequest<GetNewObjectIdsRequest>, ) -> Result<Response<GetNewObjectIdsResponse>, Status>

pub async fn trigger_manual_compaction( &mut self, request: impl IntoRequest<TriggerManualCompactionRequest>, ) -> Result<Response<TriggerManualCompactionResponse>, Status>

pub async fn trigger_full_gc( &mut self, request: impl IntoRequest<TriggerFullGcRequest>, ) -> Result<Response<TriggerFullGcResponse>, Status>

pub async fn rise_ctl_get_pinned_versions_summary( &mut self, request: impl IntoRequest<RiseCtlGetPinnedVersionsSummaryRequest>, ) -> Result<Response<RiseCtlGetPinnedVersionsSummaryResponse>, Status>

pub async fn rise_ctl_list_compaction_group( &mut self, request: impl IntoRequest<RiseCtlListCompactionGroupRequest>, ) -> Result<Response<RiseCtlListCompactionGroupResponse>, Status>

pub async fn rise_ctl_update_compaction_config( &mut self, request: impl IntoRequest<RiseCtlUpdateCompactionConfigRequest>, ) -> Result<Response<RiseCtlUpdateCompactionConfigResponse>, Status>

pub async fn rise_ctl_pause_version_checkpoint( &mut self, request: impl IntoRequest<RiseCtlPauseVersionCheckpointRequest>, ) -> Result<Response<RiseCtlPauseVersionCheckpointResponse>, Status>

pub async fn rise_ctl_resume_version_checkpoint( &mut self, request: impl IntoRequest<RiseCtlResumeVersionCheckpointRequest>, ) -> Result<Response<RiseCtlResumeVersionCheckpointResponse>, Status>

pub async fn rise_ctl_get_checkpoint_version( &mut self, request: impl IntoRequest<RiseCtlGetCheckpointVersionRequest>, ) -> Result<Response<RiseCtlGetCheckpointVersionResponse>, Status>

pub async fn rise_ctl_rebuild_table_stats( &mut self, request: impl IntoRequest<RiseCtlRebuildTableStatsRequest>, ) -> Result<Response<RiseCtlRebuildTableStatsResponse>, Status>

pub async fn init_metadata_for_replay( &mut self, request: impl IntoRequest<InitMetadataForReplayRequest>, ) -> Result<Response<InitMetadataForReplayResponse>, Status>

pub async fn pin_version( &mut self, request: impl IntoRequest<PinVersionRequest>, ) -> Result<Response<PinVersionResponse>, Status>

pub async fn split_compaction_group( &mut self, request: impl IntoRequest<SplitCompactionGroupRequest>, ) -> Result<Response<SplitCompactionGroupResponse>, Status>

pub async fn rise_ctl_list_compaction_status( &mut self, request: impl IntoRequest<RiseCtlListCompactionStatusRequest>, ) -> Result<Response<RiseCtlListCompactionStatusResponse>, Status>

pub async fn subscribe_compaction_event( &mut self, request: impl IntoStreamingRequest<Message = SubscribeCompactionEventRequest>, ) -> Result<Response<Streaming<SubscribeCompactionEventResponse>>, Status>

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

pub async fn list_branched_object( &mut self, request: impl IntoRequest<ListBranchedObjectRequest>, ) -> Result<Response<ListBranchedObjectResponse>, Status>

pub async fn list_active_write_limit( &mut self, request: impl IntoRequest<ListActiveWriteLimitRequest>, ) -> Result<Response<ListActiveWriteLimitResponse>, Status>

pub async fn list_hummock_meta_config( &mut self, request: impl IntoRequest<ListHummockMetaConfigRequest>, ) -> Result<Response<ListHummockMetaConfigResponse>, Status>

pub async fn get_compaction_score( &mut self, request: impl IntoRequest<GetCompactionScoreRequest>, ) -> Result<Response<GetCompactionScoreResponse>, Status>

pub async fn list_compact_task_assignment( &mut self, request: impl IntoRequest<ListCompactTaskAssignmentRequest>, ) -> Result<Response<ListCompactTaskAssignmentResponse>, Status>

pub async fn list_compact_task_progress( &mut self, request: impl IntoRequest<ListCompactTaskProgressRequest>, ) -> Result<Response<ListCompactTaskProgressResponse>, Status>

pub async fn cancel_compact_task( &mut self, request: impl IntoRequest<CancelCompactTaskRequest>, ) -> Result<Response<CancelCompactTaskResponse>, Status>

pub async fn get_version_by_epoch( &mut self, request: impl IntoRequest<GetVersionByEpochRequest>, ) -> Result<Response<GetVersionByEpochResponse>, Status>

pub async fn merge_compaction_group( &mut self, request: impl IntoRequest<MergeCompactionGroupRequest>, ) -> Result<Response<MergeCompactionGroupResponse>, Status>

pub async fn subscribe_iceberg_compaction_event( &mut self, request: impl IntoStreamingRequest<Message = SubscribeIcebergCompactionEventRequest>, ) -> Result<Response<Streaming<SubscribeIcebergCompactionEventResponse>>, Status>

iceberg

Trait Implementations

impl<T: Clone> Clone for HummockManagerServiceClient<T>

fn clone(&self) -> HummockManagerServiceClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for HummockManagerServiceClient<T>

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

Formats the value using the given formatter.