[PR] [Feature] Introduce cluster management interface [paimon-webui]

[via GitHub]

s7monk opened a new pull request, #200:
URL: https://github.com/apache/paimon-webui/pull/200

   close: https://github.com/apache/paimon-webui/issues/199
   
   ### Purpose
   
   Introduce a cluster management interface to facilitate the creation of 
cluster configurations for the computing engine on the system management page.
   
   ### Tests
   
   ClusterControllerTest.
   
   ### API and Format
   
   ```
   @RestController
   @RequestMapping("/api/cluster")
   public class ClusterController {
   
       @Autowired private ClusterService clusterService;
   
       @SaCheckPermission("system:cluster:query")
       @GetMapping("/{id}")
       public R<ClusterInfo> getCluster(@PathVariable("id") Integer id) {
           ClusterInfo clusterInfo = clusterService.getById(id);
           if (clusterInfo == null) {
               return R.failed(Status.CLUSTER_NOT_EXIST);
           }
           return R.succeed(clusterInfo);
       }
   
       @SaCheckPermission("system:cluster:list")
       @GetMapping("/list")
       public PageR<ClusterInfo> listClusters(ClusterInfo clusterInfo) {
           IPage<ClusterInfo> page = PageSupport.startPage();
           List<ClusterInfo> clusterInfos = clusterService.listUsers(page, 
clusterInfo);
           return PageR.<ClusterInfo>builder()
                   .success(true)
                   .total(page.getTotal())
                   .data(clusterInfos)
                   .build();
       }
   
       @SaCheckPermission("system:cluster:add")
       @PostMapping
       public R<Void> add(@Validated @RequestBody ClusterInfo clusterInfo) {
           if (!clusterService.checkClusterNameUnique(clusterInfo)) {
               return R.failed(Status.CLUSTER_NAME_ALREADY_EXISTS, 
clusterInfo.getClusterName());
           }
   
           return clusterService.save(clusterInfo) ? R.succeed() : R.failed();
       }
   
       @SaCheckPermission("system:cluster:update")
       @PutMapping
       public R<Void> update(@Validated @RequestBody ClusterInfo clusterInfo) {
           if (!clusterService.checkClusterNameUnique(clusterInfo)) {
               return R.failed(Status.CLUSTER_NAME_ALREADY_EXISTS, 
clusterInfo.getClusterName());
           }
   
           return clusterService.updateById(clusterInfo) ? R.succeed() : 
R.failed();
       }
   
       @SaCheckPermission("system:cluster:delete")
       @DeleteMapping("/{clusterIds}")
       public R<Void> delete(@PathVariable Integer[] clusterIds) {
           return clusterService.deleteClusterByIds(clusterIds) > 0 ? 
R.succeed() : R.failed();
       }
   ```
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@paimon.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org