[incubator-inlong] branch master updated: [INLONG-3598][TubeMQ] Add broker modify method (#3619)

[do...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 0675a6cdd [INLONG-3598][TubeMQ] Add broker modify method (#3619)
0675a6cdd is described below

commit 0675a6cdd5cae0301abceebf8d3220751b46ef16
Author: bluewang <88...@users.noreply.github.com>
AuthorDate: Mon Apr 11 19:26:37 2022 +0800

    [INLONG-3598][TubeMQ] Add broker modify method (#3619)
---
 .../manager/controller/node/NodeController.java    |  3 ++
 .../controller/node/request/ModifyBrokerReq.java   | 45 ++++++++++++++++++++++
 2 files changed, 48 insertions(+)

diff --git a/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/NodeController.java b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/NodeController.java
index 335da3924..cccc13694 100644
--- a/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/NodeController.java
+++ b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/NodeController.java
@@ -28,6 +28,7 @@ import org.apache.inlong.tubemq.manager.controller.node.request.AddBrokersReq;
 import org.apache.inlong.tubemq.manager.controller.node.request.BrokerSetReadOrWriteReq;
 import org.apache.inlong.tubemq.manager.controller.node.request.CloneBrokersReq;
 import org.apache.inlong.tubemq.manager.controller.node.request.DeleteBrokerReq;
+import org.apache.inlong.tubemq.manager.controller.node.request.ModifyBrokerReq;
 import org.apache.inlong.tubemq.manager.controller.node.request.OnlineOfflineBrokerReq;
 import org.apache.inlong.tubemq.manager.controller.node.request.ReloadBrokerReq;
 import org.apache.inlong.tubemq.manager.repository.MasterRepository;
@@ -99,6 +100,8 @@ public class NodeController {
                 return nodeService.cloneBrokersWithTopic(gson.fromJson(req, CloneBrokersReq.class));
             case TubeConst.ADD:
                 return masterService.baseRequestMaster(gson.fromJson(req, AddBrokersReq.class));
+            case TubeConst.MODIFY:
+                return masterService.baseRequestMaster(gson.fromJson(req, ModifyBrokerReq.class));
             case TubeConst.ONLINE:
             case TubeConst.OFFLINE:
                 return masterService.baseRequestMaster(gson.fromJson(req, OnlineOfflineBrokerReq.class));
diff --git a/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/ModifyBrokerReq.java b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/ModifyBrokerReq.java
new file mode 100644
index 000000000..51295b779
--- /dev/null
+++ b/inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/node/request/ModifyBrokerReq.java
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.inlong.tubemq.manager.controller.node.request;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ToString(callSuper = true)
+public class ModifyBrokerReq extends BaseReq {
+    private String brokerId;
+    private String brokerPort;
+    private String brokerTLSPort;
+    private String deleteWhen;
+    private String deletePolicy;
+    private Integer numPartitions;
+    private String unflushThreshold;
+    private String unflushInterval;
+    private String unflushDataHold;
+    private Integer numTopicStores;
+    private String memCacheMsgCntInK;
+    private String memCacheMsgSizeInMB;
+    private String memCacheFlushIntvl;
+    private String acceptPublish;
+    private String acceptSubscribe;
+    private String modifyUser;
+    private String confModAuthToken;
+}