This is an automated email from the ASF dual-hosted git repository.
jonyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 65bc52c85 [ISSUE #3140]Modify request and response packages class
attributes public to private (#3144)
65bc52c85 is described below
commit 65bc52c855bd7f8436aef90d1f29ff7129f66489
Author: mxsm <[email protected]>
AuthorDate: Thu Feb 16 09:09:23 2023 +0800
[ISSUE #3140]Modify request and response packages class attributes public
to private (#3144)
---
.../runtime/admin/handler/GrpcClientHandler.java | 8 +-
.../runtime/admin/handler/HTTPClientHandler.java | 8 +-
.../runtime/admin/handler/RegistryHandler.java | 2 +-
.../runtime/admin/handler/TCPClientHandler.java | 10 +-
.../runtime/admin/handler/TopicHandler.java | 4 +-
.../runtime/admin/request/CreateTopicRequest.java | 10 +-
.../admin/request/DeleteGrpcClientRequest.java | 10 +-
.../admin/request/DeleteHTTPClientRequest.java | 10 +-
.../admin/request/DeleteTCPClientRequest.java | 15 +-
.../runtime/admin/request/DeleteTopicRequest.java | 10 +-
.../eventmesh/runtime/admin/response/Error.java | 14 +-
.../runtime/admin/response/GetClientResponse.java | 50 +++---
.../admin/response/GetConfigurationResponse.java | 80 +++++-----
.../runtime/admin/response/GetMetricsResponse.java | 173 +++++++++++----------
.../admin/response/GetRegistryResponse.java | 25 +--
15 files changed, 229 insertions(+), 200 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/GrpcClientHandler.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/GrpcClientHandler.java
index 207cd8408..8a0821a0b 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/GrpcClientHandler.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/GrpcClientHandler.java
@@ -80,7 +80,7 @@ public class GrpcClientHandler extends AbstractHttpHandler {
try {
String request =
HttpExchangeUtils.streamToString(httpExchange.getRequestBody());
DeleteGrpcClientRequest deleteGrpcClientRequest =
JsonUtils.parseObject(request, DeleteGrpcClientRequest.class);
- String url = deleteGrpcClientRequest.url;
+ String url = deleteGrpcClientRequest.getUrl();
ConsumerManager consumerManager =
eventMeshGrpcServer.getConsumerManager();
Map<String, List<ConsumerGroupClient>> clientTable =
consumerManager.getClientTable();
@@ -151,10 +151,10 @@ public class GrpcClientHandler extends
AbstractHttpHandler {
}
getClientResponseList.sort((lhs, rhs) -> {
- if (lhs.host.equals(rhs.host)) {
- return lhs.host.compareTo(rhs.host);
+ if (lhs.getHost().equals(rhs.getHost())) {
+ return lhs.getHost().compareTo(rhs.getHost());
}
- return Integer.compare(rhs.port, lhs.port);
+ return Integer.compare(rhs.getPort(), lhs.getPort());
});
String result = JsonUtils.toJSONString(getClientResponseList);
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/HTTPClientHandler.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/HTTPClientHandler.java
index 032ac44f0..e312dd056 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/HTTPClientHandler.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/HTTPClientHandler.java
@@ -78,7 +78,7 @@ public class HTTPClientHandler extends AbstractHttpHandler {
try {
String request =
HttpExchangeUtils.streamToString(httpExchange.getRequestBody());
DeleteHTTPClientRequest deleteHTTPClientRequest =
JsonUtils.parseObject(request, DeleteHTTPClientRequest.class);
- String url = deleteHTTPClientRequest.url;
+ String url = deleteHTTPClientRequest.getUrl();
for (List<Client> clientList :
eventMeshHTTPServer.getSubscriptionManager().getLocalClientInfoMapping().values())
{
clientList.removeIf(client -> Objects.equals(client.getUrl(),
url));
@@ -142,10 +142,10 @@ public class HTTPClientHandler extends
AbstractHttpHandler {
}
getClientResponseList.sort((lhs, rhs) -> {
- if (lhs.host.equals(rhs.host)) {
- return lhs.host.compareTo(rhs.host);
+ if (lhs.getHost().equals(rhs.getHost())) {
+ return lhs.getHost().compareTo(rhs.getHost());
}
- return Integer.compare(rhs.port, lhs.port);
+ return Integer.compare(rhs.getPort(), lhs.getPort());
});
String result = JsonUtils.toJSONString(getClientResponseList);
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RegistryHandler.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RegistryHandler.java
index cb6f296e4..aad37cab8 100755
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RegistryHandler.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/RegistryHandler.java
@@ -84,7 +84,7 @@ public class RegistryHandler extends AbstractHttpHandler {
);
getRegistryResponseList.add(getRegistryResponse);
}
- getRegistryResponseList.sort(Comparator.comparing(lhs ->
lhs.eventMeshClusterName));
+ getRegistryResponseList.sort(Comparator.comparing(lhs ->
lhs.getEventMeshClusterName()));
String result = JsonUtils.toJSONString(getRegistryResponseList);
httpExchange.sendResponseHeaders(200, result.getBytes().length);
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TCPClientHandler.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TCPClientHandler.java
index a43fb1b87..4f3566cbe 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TCPClientHandler.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TCPClientHandler.java
@@ -83,8 +83,8 @@ public class TCPClientHandler extends AbstractHttpHandler {
try {
String request =
HttpExchangeUtils.streamToString(httpExchange.getRequestBody());
DeleteTCPClientRequest deleteTCPClientRequest =
JsonUtils.parseObject(request, DeleteTCPClientRequest.class);
- String host = deleteTCPClientRequest.host;
- int port = deleteTCPClientRequest.port;
+ String host = deleteTCPClientRequest.getHost();
+ int port = deleteTCPClientRequest.getPort();
ClientSessionGroupMapping clientSessionGroupMapping =
eventMeshTCPServer.getClientSessionGroupMapping();
ConcurrentHashMap<InetSocketAddress, Session> sessionMap =
clientSessionGroupMapping.getSessionMap();
@@ -157,10 +157,10 @@ public class TCPClientHandler extends AbstractHttpHandler
{
}
getClientResponseList.sort((lhs, rhs) -> {
- if (lhs.host.equals(rhs.host)) {
- return lhs.host.compareTo(rhs.host);
+ if (lhs.getHost().equals(rhs.getHost())) {
+ return lhs.getHost().compareTo(rhs.getHost());
}
- return Integer.compare(rhs.port, lhs.port);
+ return Integer.compare(rhs.getPort(), lhs.getPort());
});
String result = JsonUtils.toJSONString(getClientResponseList);
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TopicHandler.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TopicHandler.java
index 0b65e1b8a..61659a21b 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TopicHandler.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/TopicHandler.java
@@ -122,7 +122,7 @@ public class TopicHandler extends AbstractHttpHandler {
try {
String request =
HttpExchangeUtils.streamToString(httpExchange.getRequestBody());
CreateTopicRequest createTopicRequest =
JsonUtils.parseObject(request, CreateTopicRequest.class);
- String topicName = createTopicRequest.name;
+ String topicName = createTopicRequest.getName();
admin.createTopic(topicName);
httpExchange.sendResponseHeaders(200, 0);
} catch (Exception e) {
@@ -159,7 +159,7 @@ public class TopicHandler extends AbstractHttpHandler {
try {
String request =
HttpExchangeUtils.streamToString(httpExchange.getRequestBody());
DeleteTopicRequest deleteTopicRequest =
JsonUtils.parseObject(request, DeleteTopicRequest.class);
- String topicName = deleteTopicRequest.name;
+ String topicName = deleteTopicRequest.getName();
admin.deleteTopic(topicName);
httpExchange.sendResponseHeaders(200, 0);
} catch (Exception e) {
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/CreateTopicRequest.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/CreateTopicRequest.java
index c8c320a8a..aa02a1fdf 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/CreateTopicRequest.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/CreateTopicRequest.java
@@ -22,13 +22,15 @@ package org.apache.eventmesh.runtime.admin.request;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class CreateTopicRequest {
- public String name;
+
+ private String name;
@JsonCreator
- public CreateTopicRequest(
- @JsonProperty("name") String name
- ) {
+ public CreateTopicRequest(@JsonProperty("name") String name) {
super();
this.name = name;
}
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteGrpcClientRequest.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteGrpcClientRequest.java
index 4dd715a32..8c0115d9a 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteGrpcClientRequest.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteGrpcClientRequest.java
@@ -22,13 +22,15 @@ package org.apache.eventmesh.runtime.admin.request;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class DeleteGrpcClientRequest {
- public String url;
+
+ private String url;
@JsonCreator
- public DeleteGrpcClientRequest(
- @JsonProperty("url") String url
- ) {
+ public DeleteGrpcClientRequest(@JsonProperty("url") String url) {
super();
this.url = url;
}
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteHTTPClientRequest.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteHTTPClientRequest.java
index 822dd3b09..a6237dcb7 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteHTTPClientRequest.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteHTTPClientRequest.java
@@ -22,13 +22,15 @@ package org.apache.eventmesh.runtime.admin.request;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class DeleteHTTPClientRequest {
- public String url;
+
+ private String url;
@JsonCreator
- public DeleteHTTPClientRequest(
- @JsonProperty("url") String url
- ) {
+ public DeleteHTTPClientRequest(@JsonProperty("url") String url) {
super();
this.url = url;
}
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTCPClientRequest.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTCPClientRequest.java
index abc2ac3d9..c122f04e6 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTCPClientRequest.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTCPClientRequest.java
@@ -22,15 +22,20 @@ package org.apache.eventmesh.runtime.admin.request;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class DeleteTCPClientRequest {
- public String host;
- public int port;
+
+ private String host;
+
+ private int port;
@JsonCreator
public DeleteTCPClientRequest(
- @JsonProperty("host") String host,
- @JsonProperty("port") int port
- ) {
+ @JsonProperty("host") String host,
+ @JsonProperty("port") int port) {
+
super();
this.host = host;
this.port = port;
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTopicRequest.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTopicRequest.java
index a3883c5b9..37f18288c 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTopicRequest.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/request/DeleteTopicRequest.java
@@ -22,13 +22,15 @@ package org.apache.eventmesh.runtime.admin.request;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class DeleteTopicRequest {
- public String name;
+
+ private String name;
@JsonCreator
- public DeleteTopicRequest(
- @JsonProperty("name") String name
- ) {
+ public DeleteTopicRequest(@JsonProperty("name") String name) {
super();
this.name = name;
}
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/Error.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/Error.java
index c282d5145..4b03a07ba 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/Error.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/Error.java
@@ -20,15 +20,17 @@ package org.apache.eventmesh.runtime.admin.response;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class Error {
- public String message;
- public String stackTrace;
+
+ private String message;
+
+ private String stackTrace;
@JsonCreator
- public Error(
- @JsonProperty("message") String message,
- @JsonProperty("stackTrace") String stackTrace
- ) {
+ public Error(@JsonProperty("message") String message,
@JsonProperty("stackTrace") String stackTrace) {
super();
this.message = message;
this.stackTrace = stackTrace;
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetClientResponse.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetClientResponse.java
index 381451a71..8093704c5 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetClientResponse.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetClientResponse.java
@@ -20,33 +20,37 @@ package org.apache.eventmesh.runtime.admin.response;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class GetClientResponse {
- public String env;
- public String subsystem;
- public String url;
- public String pid;
- public String host;
- public int port;
- public String version;
- public String idc;
- public String group;
- public String purpose;
- public String protocol;
+
+ private String env;
+ private String subsystem;
+ private String url;
+ private String pid;
+ private String host;
+ private int port;
+ private String version;
+ private String idc;
+ private String group;
+ private String purpose;
+ private String protocol;
@JsonCreator
public GetClientResponse(
- @JsonProperty("env") String env,
- @JsonProperty("subsystem") String subsystem,
- @JsonProperty("url") String url,
- @JsonProperty("pid") String pid,
- @JsonProperty("host") String host,
- @JsonProperty("port") int port,
- @JsonProperty("version") String version,
- @JsonProperty("idc") String idc,
- @JsonProperty("group") String group,
- @JsonProperty("purpose") String purpose,
- @JsonProperty("protocol") String protocol
- ) {
+ @JsonProperty("env") String env,
+ @JsonProperty("subsystem") String subsystem,
+ @JsonProperty("url") String url,
+ @JsonProperty("pid") String pid,
+ @JsonProperty("host") String host,
+ @JsonProperty("port") int port,
+ @JsonProperty("version") String version,
+ @JsonProperty("idc") String idc,
+ @JsonProperty("group") String group,
+ @JsonProperty("purpose") String purpose,
+ @JsonProperty("protocol") String protocol) {
+
super();
this.env = env;
this.subsystem = subsystem;
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetConfigurationResponse.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetConfigurationResponse.java
index eb44e6992..50ec462ca 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetConfigurationResponse.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetConfigurationResponse.java
@@ -22,51 +22,55 @@ package org.apache.eventmesh.runtime.admin.response;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class GetConfigurationResponse {
- public String eventMeshEnv;
- public String eventMeshIDC;
- public String eventMeshCluster;
- public String eventMeshServerIp;
- public boolean eventMeshServerSecurityEnable;
- public boolean eventMeshServerRegistryEnable;
- public String eventMeshName;
- public String sysID;
- public String eventMeshWebhookOrigin;
- public String namesrvAddr;
- public int eventMeshTcpServerPort;
+ private String eventMeshEnv;
+ private String eventMeshIDC;
+ private String eventMeshCluster;
+ private String eventMeshServerIp;
+ private boolean eventMeshServerSecurityEnable;
+ private boolean eventMeshServerRegistryEnable;
+ private String eventMeshName;
+ private String sysID;
+ private String eventMeshWebhookOrigin;
+ private String namesrvAddr;
+
+ private int eventMeshTcpServerPort;
- public int eventMeshHttpServerPort;
- public boolean eventMeshHttpServerUseTls;
+ private int eventMeshHttpServerPort;
+ private boolean eventMeshHttpServerUseTls;
- public int eventMeshGrpcServerPort;
- public boolean eventMeshGrpcServerUseTls;
+ private int eventMeshGrpcServerPort;
+ private boolean eventMeshGrpcServerUseTls;
@JsonCreator
public GetConfigurationResponse(
- // Common Configuration
- @JsonProperty("sysID") String sysID,
- @JsonProperty("namesrvAddr") String namesrvAddr,
- @JsonProperty("eventMeshEnv") String eventMeshEnv,
- @JsonProperty("eventMeshIDC") String eventMeshIDC,
- @JsonProperty("eventMeshCluster") String eventMeshCluster,
- @JsonProperty("eventMeshServerIp") String eventMeshServerIp,
- @JsonProperty("eventMeshName") String eventMeshName,
- @JsonProperty("eventMeshWebhookOrigin") String
eventMeshWebhookOrigin,
- @JsonProperty("eventMeshServerSecurityEnable") boolean
eventMeshServerSecurityEnable,
- @JsonProperty("eventMeshServerRegistryEnable") boolean
eventMeshServerRegistryEnable,
-
- // TCP Configuration
- @JsonProperty("eventMeshTcpServerPort") int eventMeshTcpServerPort,
-
- // HTTP Configuration
- @JsonProperty("eventMeshHttpServerPort") int
eventMeshHttpServerPort,
- @JsonProperty("eventMeshHttpServerUseTls") boolean
eventMeshHttpServerUseTls,
-
- // gRPC Configuration
- @JsonProperty("eventMeshGrpcServerPort") int
eventMeshGrpcServerPort,
- @JsonProperty("eventMeshGrpcServerUseTls") boolean
eventMeshGrpcServerUseTls
- ) {
+ // Common Configuration
+ @JsonProperty("sysID") String sysID,
+ @JsonProperty("namesrvAddr") String namesrvAddr,
+ @JsonProperty("eventMeshEnv") String eventMeshEnv,
+ @JsonProperty("eventMeshIDC") String eventMeshIDC,
+ @JsonProperty("eventMeshCluster") String eventMeshCluster,
+ @JsonProperty("eventMeshServerIp") String eventMeshServerIp,
+ @JsonProperty("eventMeshName") String eventMeshName,
+ @JsonProperty("eventMeshWebhookOrigin") String eventMeshWebhookOrigin,
+ @JsonProperty("eventMeshServerSecurityEnable") boolean
eventMeshServerSecurityEnable,
+ @JsonProperty("eventMeshServerRegistryEnable") boolean
eventMeshServerRegistryEnable,
+
+ // TCP Configuration
+ @JsonProperty("eventMeshTcpServerPort") int eventMeshTcpServerPort,
+
+ // HTTP Configuration
+ @JsonProperty("eventMeshHttpServerPort") int eventMeshHttpServerPort,
+ @JsonProperty("eventMeshHttpServerUseTls") boolean
eventMeshHttpServerUseTls,
+
+ // gRPC Configuration
+ @JsonProperty("eventMeshGrpcServerPort") int eventMeshGrpcServerPort,
+ @JsonProperty("eventMeshGrpcServerUseTls") boolean
eventMeshGrpcServerUseTls) {
+
super();
this.sysID = sysID;
this.namesrvAddr = namesrvAddr;
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetMetricsResponse.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetMetricsResponse.java
index 357249304..86f4ed16a 100755
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetMetricsResponse.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetMetricsResponse.java
@@ -20,100 +20,103 @@ package org.apache.eventmesh.runtime.admin.response;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+@Data
public class GetMetricsResponse {
+
// HTTP Metrics
- public float maxHTTPTPS;
- public float avgHTTPTPS;
- public long maxHTTPCost;
- public float avgHTTPCost;
- public float avgHTTPBodyDecodeCost;
- public long httpDiscard;
- public float maxBatchSendMsgTPS;
- public float avgBatchSendMsgTPS;
- public long sendBatchMsgNumSum;
- public long sendBatchMsgFailNumSum;
- public float sendBatchMsgFailRate;
- public long sendBatchMsgDiscardNumSum;
- public float maxSendMsgTPS;
- public float avgSendMsgTPS;
- public long sendMsgNumSum;
- public long sendMsgFailNumSum;
- public float sendMsgFailRate;
- public long replyMsgNumSum;
- public long replyMsgFailNumSum;
- public float maxPushMsgTPS;
- public float avgPushMsgTPS;
- public long pushHTTPMsgNumSum;
- public long pushHTTPMsgFailNumSum;
- public float pushHTTPMsgFailRate;
- public float maxHTTPPushLatency;
- public float avgHTTPPushLatency;
- public int batchMsgQueueSize;
- public int sendMsgQueueSize;
- public int pushMsgQueueSize;
- public int retryHTTPQueueSize;
- public float avgBatchSendMsgCost;
- public float avgSendMsgCost;
- public float avgReplyMsgCost;
+ private float maxHTTPTPS;
+ private float avgHTTPTPS;
+ private long maxHTTPCost;
+ private float avgHTTPCost;
+ private float avgHTTPBodyDecodeCost;
+ private long httpDiscard;
+ private float maxBatchSendMsgTPS;
+ private float avgBatchSendMsgTPS;
+ private long sendBatchMsgNumSum;
+ private long sendBatchMsgFailNumSum;
+ private float sendBatchMsgFailRate;
+ private long sendBatchMsgDiscardNumSum;
+ private float maxSendMsgTPS;
+ private float avgSendMsgTPS;
+ private long sendMsgNumSum;
+ private long sendMsgFailNumSum;
+ private float sendMsgFailRate;
+ private long replyMsgNumSum;
+ private long replyMsgFailNumSum;
+ private float maxPushMsgTPS;
+ private float avgPushMsgTPS;
+ private long pushHTTPMsgNumSum;
+ private long pushHTTPMsgFailNumSum;
+ private float pushHTTPMsgFailRate;
+ private float maxHTTPPushLatency;
+ private float avgHTTPPushLatency;
+ private int batchMsgQueueSize;
+ private int sendMsgQueueSize;
+ private int pushMsgQueueSize;
+ private int retryHTTPQueueSize;
+ private float avgBatchSendMsgCost;
+ private float avgSendMsgCost;
+ private float avgReplyMsgCost;
// TCP Metrics
- public int retryTCPQueueSize;
- public double client2eventMeshTCPTPS;
- public double eventMesh2mqTCPTPS;
- public double mq2eventMeshTCPTPS;
- public double eventMesh2clientTCPTPS;
- public double allTCPTPS;
- public int allTCPConnections;
- public int subTopicTCPNum;
+ private int retryTCPQueueSize;
+ private double client2eventMeshTCPTPS;
+ private double eventMesh2mqTCPTPS;
+ private double mq2eventMeshTCPTPS;
+ private double eventMesh2clientTCPTPS;
+ private double allTCPTPS;
+ private int allTCPConnections;
+ private int subTopicTCPNum;
@JsonCreator
public GetMetricsResponse(
- // HTTP Metrics
- @JsonProperty("maxHTTPTPS") float maxHTTPTPS,
- @JsonProperty("avgHTTPTPS") float avgHTTPTPS,
- @JsonProperty("maxHTTPCost") long maxHTTPCost,
- @JsonProperty("avgHTTPCost") float avgHTTPCost,
- @JsonProperty("avgHTTPBodyDecodeCost") float avgHTTPBodyDecodeCost,
- @JsonProperty("httpDiscard") long httpDiscard,
- @JsonProperty("maxBatchSendMsgTPS") float maxBatchSendMsgTPS,
- @JsonProperty("avgBatchSendMsgTPS") float avgBatchSendMsgTPS,
- @JsonProperty("sendBatchMsgNumSum") long sendBatchMsgNumSum,
- @JsonProperty("sendBatchMsgFailNumSum") long
sendBatchMsgFailNumSum,
- @JsonProperty("sendBatchMsgFailRate") float sendBatchMsgFailRate,
- @JsonProperty("sendBatchMsgDiscardNumSum") long
sendBatchMsgDiscardNumSum,
- @JsonProperty("maxSendMsgTPS") float maxSendMsgTPS,
- @JsonProperty("avgSendMsgTPS") float avgSendMsgTPS,
- @JsonProperty("sendMsgNumSum") long sendMsgNumSum,
- @JsonProperty("sendMsgFailNumSum") long sendMsgFailNumSum,
- @JsonProperty("sendMsgFailRate") float sendMsgFailRate,
- @JsonProperty("replyMsgNumSum") long replyMsgNumSum,
- @JsonProperty("replyMsgFailNumSum") long replyMsgFailNumSum,
- @JsonProperty("maxPushMsgTPS") float maxPushMsgTPS,
- @JsonProperty("avgPushMsgTPS") float avgPushMsgTPS,
- @JsonProperty("pushHTTPMsgNumSum") long pushHTTPMsgNumSum,
- @JsonProperty("pushHTTPMsgFailNumSum") long pushHTTPMsgFailNumSum,
- @JsonProperty("pushHTTPMsgFailRate") float pushHTTPMsgFailRate,
- @JsonProperty("maxHTTPPushLatency") float maxHTTPPushLatency,
- @JsonProperty("avgHTTPPushLatency") float avgHTTPPushLatency,
- @JsonProperty("batchMsgQueueSize") int batchMsgQueueSize,
- @JsonProperty("sendMsgQueueSize") int sendMsgQueueSize,
- @JsonProperty("pushMsgQueueSize") int pushMsgQueueSize,
- @JsonProperty("retryHTTPQueueSize") int retryHTTPQueueSize,
- @JsonProperty("avgBatchSendMsgCost") float avgBatchSendMsgCost,
- @JsonProperty("avgSendMsgCost") float avgSendMsgCost,
- @JsonProperty("avgReplyMsgCost") float avgReplyMsgCost,
- // TCP Metrics
- @JsonProperty("retryTCPQueueSize") int retryTCPQueueSize,
- @JsonProperty("client2eventMeshTCPTPS") double
client2eventMeshTCPTPS,
- @JsonProperty("eventMesh2mqTCPTPS") double eventMesh2mqTCPTPS,
- @JsonProperty("mq2eventMeshTCPTPS") double mq2eventMeshTCPTPS,
- @JsonProperty("eventMesh2clientTCPTPS") double
eventMesh2clientTCPTPS,
- @JsonProperty("allTCPTPS") double allTCPTPS,
- @JsonProperty("allTCPConnections") int allTCPConnections,
- @JsonProperty("subTopicTCPNum") int subTopicTCPNum
- ) {
+ // HTTP Metrics
+ @JsonProperty("maxHTTPTPS") float maxHTTPTPS,
+ @JsonProperty("avgHTTPTPS") float avgHTTPTPS,
+ @JsonProperty("maxHTTPCost") long maxHTTPCost,
+ @JsonProperty("avgHTTPCost") float avgHTTPCost,
+ @JsonProperty("avgHTTPBodyDecodeCost") float avgHTTPBodyDecodeCost,
+ @JsonProperty("httpDiscard") long httpDiscard,
+ @JsonProperty("maxBatchSendMsgTPS") float maxBatchSendMsgTPS,
+ @JsonProperty("avgBatchSendMsgTPS") float avgBatchSendMsgTPS,
+ @JsonProperty("sendBatchMsgNumSum") long sendBatchMsgNumSum,
+ @JsonProperty("sendBatchMsgFailNumSum") long sendBatchMsgFailNumSum,
+ @JsonProperty("sendBatchMsgFailRate") float sendBatchMsgFailRate,
+ @JsonProperty("sendBatchMsgDiscardNumSum") long
sendBatchMsgDiscardNumSum,
+ @JsonProperty("maxSendMsgTPS") float maxSendMsgTPS,
+ @JsonProperty("avgSendMsgTPS") float avgSendMsgTPS,
+ @JsonProperty("sendMsgNumSum") long sendMsgNumSum,
+ @JsonProperty("sendMsgFailNumSum") long sendMsgFailNumSum,
+ @JsonProperty("sendMsgFailRate") float sendMsgFailRate,
+ @JsonProperty("replyMsgNumSum") long replyMsgNumSum,
+ @JsonProperty("replyMsgFailNumSum") long replyMsgFailNumSum,
+ @JsonProperty("maxPushMsgTPS") float maxPushMsgTPS,
+ @JsonProperty("avgPushMsgTPS") float avgPushMsgTPS,
+ @JsonProperty("pushHTTPMsgNumSum") long pushHTTPMsgNumSum,
+ @JsonProperty("pushHTTPMsgFailNumSum") long pushHTTPMsgFailNumSum,
+ @JsonProperty("pushHTTPMsgFailRate") float pushHTTPMsgFailRate,
+ @JsonProperty("maxHTTPPushLatency") float maxHTTPPushLatency,
+ @JsonProperty("avgHTTPPushLatency") float avgHTTPPushLatency,
+ @JsonProperty("batchMsgQueueSize") int batchMsgQueueSize,
+ @JsonProperty("sendMsgQueueSize") int sendMsgQueueSize,
+ @JsonProperty("pushMsgQueueSize") int pushMsgQueueSize,
+ @JsonProperty("retryHTTPQueueSize") int retryHTTPQueueSize,
+ @JsonProperty("avgBatchSendMsgCost") float avgBatchSendMsgCost,
+ @JsonProperty("avgSendMsgCost") float avgSendMsgCost,
+ @JsonProperty("avgReplyMsgCost") float avgReplyMsgCost,
+ // TCP Metrics
+ @JsonProperty("retryTCPQueueSize") int retryTCPQueueSize,
+ @JsonProperty("client2eventMeshTCPTPS") double client2eventMeshTCPTPS,
+ @JsonProperty("eventMesh2mqTCPTPS") double eventMesh2mqTCPTPS,
+ @JsonProperty("mq2eventMeshTCPTPS") double mq2eventMeshTCPTPS,
+ @JsonProperty("eventMesh2clientTCPTPS") double eventMesh2clientTCPTPS,
+ @JsonProperty("allTCPTPS") double allTCPTPS,
+ @JsonProperty("allTCPConnections") int allTCPConnections,
+ @JsonProperty("subTopicTCPNum") int subTopicTCPNum) {
+
super();
this.maxHTTPTPS = maxHTTPTPS;
this.avgHTTPTPS = avgHTTPTPS;
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetRegistryResponse.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetRegistryResponse.java
index 7ac5384de..2a2806a8b 100755
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetRegistryResponse.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/GetRegistryResponse.java
@@ -20,22 +20,25 @@ package org.apache.eventmesh.runtime.admin.response;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
public class GetRegistryResponse {
- public String eventMeshClusterName;
- public String eventMeshName;
- public String endpoint;
- public long lastUpdateTimestamp;
- public String metadata;
+
+ private String eventMeshClusterName;
+ private String eventMeshName;
+ private String endpoint;
+ private long lastUpdateTimestamp;
+ private String metadata;
@JsonCreator
public GetRegistryResponse(
- @JsonProperty("eventMeshClusterName") String eventMeshClusterName,
- @JsonProperty("eventMeshName") String eventMeshName,
- @JsonProperty("endpoint") String endpoint,
- @JsonProperty("lastUpdateTimestamp") long lastUpdateTimestamp,
- @JsonProperty("metadata") String metadata
- ) {
+ @JsonProperty("eventMeshClusterName") String eventMeshClusterName,
+ @JsonProperty("eventMeshName") String eventMeshName,
+ @JsonProperty("endpoint") String endpoint,
+ @JsonProperty("lastUpdateTimestamp") long lastUpdateTimestamp,
+ @JsonProperty("metadata") String metadata) {
super();
this.eventMeshClusterName = eventMeshClusterName;
this.eventMeshName = eventMeshName;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
