新增feign接口

data-storage-api/src/main/java/com/huaxing/feign/IDatabaseClientFeign.java

@@ -69,5 +69,63 @@ public interface IDatabaseClientFeign {
 	ResultVo<?> createDfsTable(@RequestBody @Validated TableDTO tableDTO);
 
 
+	/**
+	 * 创建stream表
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(CREATE_STREAM_TABLE)
+	ResultVo<?> createStreamTable(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 创建dfs和stream表并订阅
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(CREATE_DFS_AND_STREAM_TABLE_SUBSCRIBE)
+	ResultVo<?> createDfsAndStreamTableSubscribe(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 创建dfs和stream表不订阅
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(CREATE_DFS_AND_STREAM_TABLE_UNSUBSCRIBE)
+	ResultVo<?> createDfsAndStreamTableUnsubscribe(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 订阅流表
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(SUBSCRIBE_STREAM_TABLE)
+	ResultVo<?> subscribeStreamTable(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 取消订阅流表
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(UNSUBSCRIBE_STREAM_TABLE)
+	ResultVo<?> unsubscribeStreamTable(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 新增dfs表字段
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(ADD_DFS_COLUMNS)
+	ResultVo<?> addDfsColumns(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 新增stream表字段
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(ADD_STREAM_COLUMNS)
+	ResultVo<?> addStreamColumns(@RequestBody @Validated TableDTO tableDTO);
+
+
+
 
 }

data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java

@@ -36,6 +36,41 @@ public class DatabaseFeignFallbackFactory implements FallbackFactory<IDatabaseCl
             public ResultVo<?> createDfsTable(TableDTO tableDTO) {
                 return null;
             }
+
+            @Override
+            public ResultVo<?> createStreamTable(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> createDfsAndStreamTableSubscribe(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> createDfsAndStreamTableUnsubscribe(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> subscribeStreamTable(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> unsubscribeStreamTable(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> addDfsColumns(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> addStreamColumns(TableDTO tableDTO) {
+                return null;
+            }
         };
     }
 }