temp save

risingwavelabs · Nov 29, 2024 · 8d9bbb9 · 8d9bbb9
1 parent 8040c87
commit 8d9bbb9
Show file tree

Hide file tree

Showing 12 changed files with 1,119 additions and 208 deletions.
diff --git a/proto/stream_service.proto b/proto/stream_service.proto
@@ -89,22 +89,39 @@ message StreamingControlStreamRequest {
     uint32 database_id = 2;
   }
 
+  message ResetDatabaseRequest {
+    uint32 database_id = 1;
+    uint32 reset_request_id = 2;
+  }
+
   oneof request {
     InitRequest init = 1;
     InjectBarrierRequest inject_barrier = 2;
     RemovePartialGraphRequest remove_partial_graph = 3;
     CreatePartialGraphRequest create_partial_graph = 4;
+    ResetDatabaseRequest reset_database = 5;
   }
 }
 
 message StreamingControlStreamResponse {
   message InitResponse {}
   message ShutdownResponse {}
+  message ReportDatabaseFailureResponse {
+    uint32 database_id = 1;
+  }
+
+  message ResetDatabaseResponse {
+    uint32 database_id = 1;
+    optional string root_err = 2;
+    uint32 reset_request_id = 3;
+  }
 
   oneof response {
     InitResponse init = 1;
     BarrierCompleteResponse complete_barrier = 2;
     ShutdownResponse shutdown = 3;
+    ReportDatabaseFailureResponse report_database_failure = 4;
+    ResetDatabaseResponse reset_database = 5;
   }
 }