pub trait DdlService:
Send
+ Sync
+ 'static {
Show 39 methods
// Required methods
fn create_database<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateDatabaseRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateDatabaseResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_database<'life0, 'async_trait>(
&'life0 self,
request: Request<DropDatabaseRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropDatabaseResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_schema<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateSchemaRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateSchemaResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_schema<'life0, 'async_trait>(
&'life0 self,
request: Request<DropSchemaRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropSchemaResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_source<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateSourceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateSourceResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_source<'life0, 'async_trait>(
&'life0 self,
request: Request<DropSourceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropSourceResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_sink<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateSinkRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateSinkResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_subscription<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateSubscriptionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateSubscriptionResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_sink<'life0, 'async_trait>(
&'life0 self,
request: Request<DropSinkRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropSinkResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_subscription<'life0, 'async_trait>(
&'life0 self,
request: Request<DropSubscriptionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropSubscriptionResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_materialized_view<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateMaterializedViewRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateMaterializedViewResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_materialized_view<'life0, 'async_trait>(
&'life0 self,
request: Request<DropMaterializedViewRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropMaterializedViewResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_table<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateTableRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateTableResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_secret<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateSecretRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateSecretResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_secret<'life0, 'async_trait>(
&'life0 self,
request: Request<DropSecretRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropSecretResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn alter_name<'life0, 'async_trait>(
&'life0 self,
request: Request<AlterNameRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AlterNameResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn alter_source<'life0, 'async_trait>(
&'life0 self,
request: Request<AlterSourceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AlterSourceResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn alter_owner<'life0, 'async_trait>(
&'life0 self,
request: Request<AlterOwnerRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AlterOwnerResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn alter_set_schema<'life0, 'async_trait>(
&'life0 self,
request: Request<AlterSetSchemaRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AlterSetSchemaResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn alter_parallelism<'life0, 'async_trait>(
&'life0 self,
request: Request<AlterParallelismRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AlterParallelismResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_table<'life0, 'async_trait>(
&'life0 self,
request: Request<DropTableRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropTableResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn risectl_list_state_tables<'life0, 'async_trait>(
&'life0 self,
request: Request<RisectlListStateTablesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<RisectlListStateTablesResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_view<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateViewRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateViewResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_view<'life0, 'async_trait>(
&'life0 self,
request: Request<DropViewRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropViewResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_index<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateIndexResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_index<'life0, 'async_trait>(
&'life0 self,
request: Request<DropIndexRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropIndexResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_function<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateFunctionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateFunctionResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_function<'life0, 'async_trait>(
&'life0 self,
request: Request<DropFunctionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropFunctionResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn replace_table_plan<'life0, 'async_trait>(
&'life0 self,
request: Request<ReplaceTablePlanRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ReplaceTablePlanResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn get_table<'life0, 'async_trait>(
&'life0 self,
request: Request<GetTableRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetTableResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn get_ddl_progress<'life0, 'async_trait>(
&'life0 self,
request: Request<GetDdlProgressRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetDdlProgressResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn create_connection<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateConnectionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateConnectionResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn list_connections<'life0, 'async_trait>(
&'life0 self,
request: Request<ListConnectionsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListConnectionsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn drop_connection<'life0, 'async_trait>(
&'life0 self,
request: Request<DropConnectionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DropConnectionResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn get_tables<'life0, 'async_trait>(
&'life0 self,
request: Request<GetTablesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetTablesResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn wait<'life0, 'async_trait>(
&'life0 self,
request: Request<WaitRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<WaitResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn comment_on<'life0, 'async_trait>(
&'life0 self,
request: Request<CommentOnRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CommentOnResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn auto_schema_change<'life0, 'async_trait>(
&'life0 self,
request: Request<AutoSchemaChangeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AutoSchemaChangeResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn alter_swap_rename<'life0, 'async_trait>(
&'life0 self,
request: Request<AlterSwapRenameRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AlterSwapRenameResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
}Expand description
Generated trait containing gRPC methods that should be implemented for use with DdlServiceServer.