Struct DdlServiceClient 

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

Fields

inner: Grpc<T>

Implementations

impl DdlServiceClient<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> DdlServiceClient<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, ) -> DdlServiceClient<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 create_database( &mut self, request: impl IntoRequest<CreateDatabaseRequest>, ) -> Result<Response<CreateDatabaseResponse>, Status>

pub async fn drop_database( &mut self, request: impl IntoRequest<DropDatabaseRequest>, ) -> Result<Response<DropDatabaseResponse>, Status>

pub async fn create_schema( &mut self, request: impl IntoRequest<CreateSchemaRequest>, ) -> Result<Response<CreateSchemaResponse>, Status>

pub async fn drop_schema( &mut self, request: impl IntoRequest<DropSchemaRequest>, ) -> Result<Response<DropSchemaResponse>, Status>

pub async fn create_source( &mut self, request: impl IntoRequest<CreateSourceRequest>, ) -> Result<Response<CreateSourceResponse>, Status>

pub async fn drop_source( &mut self, request: impl IntoRequest<DropSourceRequest>, ) -> Result<Response<DropSourceResponse>, Status>

pub async fn create_sink( &mut self, request: impl IntoRequest<CreateSinkRequest>, ) -> Result<Response<CreateSinkResponse>, Status>

pub async fn create_subscription( &mut self, request: impl IntoRequest<CreateSubscriptionRequest>, ) -> Result<Response<CreateSubscriptionResponse>, Status>

pub async fn drop_sink( &mut self, request: impl IntoRequest<DropSinkRequest>, ) -> Result<Response<DropSinkResponse>, Status>

pub async fn drop_subscription( &mut self, request: impl IntoRequest<DropSubscriptionRequest>, ) -> Result<Response<DropSubscriptionResponse>, Status>

pub async fn create_materialized_view( &mut self, request: impl IntoRequest<CreateMaterializedViewRequest>, ) -> Result<Response<CreateMaterializedViewResponse>, Status>

pub async fn drop_materialized_view( &mut self, request: impl IntoRequest<DropMaterializedViewRequest>, ) -> Result<Response<DropMaterializedViewResponse>, Status>

pub async fn create_table( &mut self, request: impl IntoRequest<CreateTableRequest>, ) -> Result<Response<CreateTableResponse>, Status>

pub async fn create_iceberg_table( &mut self, request: impl IntoRequest<CreateIcebergTableRequest>, ) -> Result<Response<CreateIcebergTableResponse>, Status>

pub async fn create_secret( &mut self, request: impl IntoRequest<CreateSecretRequest>, ) -> Result<Response<CreateSecretResponse>, Status>

pub async fn drop_secret( &mut self, request: impl IntoRequest<DropSecretRequest>, ) -> Result<Response<DropSecretResponse>, Status>

pub async fn alter_secret( &mut self, request: impl IntoRequest<AlterSecretRequest>, ) -> Result<Response<AlterSecretResponse>, Status>

pub async fn alter_name( &mut self, request: impl IntoRequest<AlterNameRequest>, ) -> Result<Response<AlterNameResponse>, Status>

pub async fn alter_source( &mut self, request: impl IntoRequest<AlterSourceRequest>, ) -> Result<Response<AlterSourceResponse>, Status>

pub async fn alter_owner( &mut self, request: impl IntoRequest<AlterOwnerRequest>, ) -> Result<Response<AlterOwnerResponse>, Status>

pub async fn alter_set_schema( &mut self, request: impl IntoRequest<AlterSetSchemaRequest>, ) -> Result<Response<AlterSetSchemaResponse>, Status>

pub async fn alter_parallelism( &mut self, request: impl IntoRequest<AlterParallelismRequest>, ) -> Result<Response<AlterParallelismResponse>, Status>

pub async fn alter_fragment_parallelism( &mut self, request: impl IntoRequest<AlterFragmentParallelismRequest>, ) -> Result<Response<AlterFragmentParallelismResponse>, Status>

pub async fn alter_resource_group( &mut self, request: impl IntoRequest<AlterResourceGroupRequest>, ) -> Result<Response<AlterResourceGroupResponse>, Status>

pub async fn drop_table( &mut self, request: impl IntoRequest<DropTableRequest>, ) -> Result<Response<DropTableResponse>, Status>

pub async fn risectl_list_state_tables( &mut self, request: impl IntoRequest<RisectlListStateTablesRequest>, ) -> Result<Response<RisectlListStateTablesResponse>, Status>

pub async fn create_view( &mut self, request: impl IntoRequest<CreateViewRequest>, ) -> Result<Response<CreateViewResponse>, Status>

pub async fn drop_view( &mut self, request: impl IntoRequest<DropViewRequest>, ) -> Result<Response<DropViewResponse>, Status>

pub async fn create_index( &mut self, request: impl IntoRequest<CreateIndexRequest>, ) -> Result<Response<CreateIndexResponse>, Status>

pub async fn drop_index( &mut self, request: impl IntoRequest<DropIndexRequest>, ) -> Result<Response<DropIndexResponse>, Status>

pub async fn create_function( &mut self, request: impl IntoRequest<CreateFunctionRequest>, ) -> Result<Response<CreateFunctionResponse>, Status>

pub async fn drop_function( &mut self, request: impl IntoRequest<DropFunctionRequest>, ) -> Result<Response<DropFunctionResponse>, Status>

pub async fn replace_job_plan( &mut self, request: impl IntoRequest<ReplaceJobPlanRequest>, ) -> Result<Response<ReplaceJobPlanResponse>, Status>

pub async fn get_table( &mut self, request: impl IntoRequest<GetTableRequest>, ) -> Result<Response<GetTableResponse>, Status>

pub async fn get_ddl_progress( &mut self, request: impl IntoRequest<GetDdlProgressRequest>, ) -> Result<Response<GetDdlProgressResponse>, Status>

pub async fn create_connection( &mut self, request: impl IntoRequest<CreateConnectionRequest>, ) -> Result<Response<CreateConnectionResponse>, Status>

pub async fn list_connections( &mut self, request: impl IntoRequest<ListConnectionsRequest>, ) -> Result<Response<ListConnectionsResponse>, Status>

pub async fn drop_connection( &mut self, request: impl IntoRequest<DropConnectionRequest>, ) -> Result<Response<DropConnectionResponse>, Status>

pub async fn get_tables( &mut self, request: impl IntoRequest<GetTablesRequest>, ) -> Result<Response<GetTablesResponse>, Status>

pub async fn wait( &mut self, request: impl IntoRequest<WaitRequest>, ) -> Result<Response<WaitResponse>, Status>

pub async fn comment_on( &mut self, request: impl IntoRequest<CommentOnRequest>, ) -> Result<Response<CommentOnResponse>, Status>

pub async fn auto_schema_change( &mut self, request: impl IntoRequest<AutoSchemaChangeRequest>, ) -> Result<Response<AutoSchemaChangeResponse>, Status>

pub async fn alter_swap_rename( &mut self, request: impl IntoRequest<AlterSwapRenameRequest>, ) -> Result<Response<AlterSwapRenameResponse>, Status>

pub async fn alter_database_param( &mut self, request: impl IntoRequest<AlterDatabaseParamRequest>, ) -> Result<Response<AlterDatabaseParamResponse>, Status>

pub async fn compact_iceberg_table( &mut self, request: impl IntoRequest<CompactIcebergTableRequest>, ) -> Result<Response<CompactIcebergTableResponse>, Status>

pub async fn expire_iceberg_table_snapshots( &mut self, request: impl IntoRequest<ExpireIcebergTableSnapshotsRequest>, ) -> Result<Response<ExpireIcebergTableSnapshotsResponse>, Status>

pub async fn alter_cdc_table_backfill_parallelism( &mut self, request: impl IntoRequest<AlterCdcTableBackfillParallelismRequest>, ) -> Result<Response<AlterCdcTableBackfillParallelismResponse>, Status>

pub async fn alter_streaming_job_config( &mut self, request: impl IntoRequest<AlterStreamingJobConfigRequest>, ) -> Result<Response<AlterStreamingJobConfigResponse>, Status>

Trait Implementations

impl<T: Clone> Clone for DdlServiceClient<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for DdlServiceClient<T>

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

Formats the value using the given formatter.