aloyszhang commented on code in PR #10757:
URL: https://github.com/apache/inlong/pull/10757#discussion_r1706307691
##########
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentStatusManager.java:
##########
@@ -55,22 +52,83 @@
import static
org.apache.inlong.agent.constant.FetcherConstants.AGENT_GLOBAL_READER_QUEUE_PERMIT;
import static
org.apache.inlong.agent.constant.FetcherConstants.AGENT_GLOBAL_READER_SOURCE_PERMIT;
import static
org.apache.inlong.agent.constant.FetcherConstants.AGENT_GLOBAL_WRITER_PERMIT;
-import static
org.apache.inlong.agent.constant.FetcherConstants.AGENT_MANAGER_ADDR;
-import static
org.apache.inlong.agent.constant.FetcherConstants.AGENT_MANAGER_AUTH_SECRET_ID;
-import static
org.apache.inlong.agent.constant.FetcherConstants.AGENT_MANAGER_AUTH_SECRET_KEY;
/**
* Collect various indicators of agent processes for backend problem analysis
*/
public class AgentStatusManager {
+ @Data
+ @AllArgsConstructor
+ @NoArgsConstructor
+ public static class AgentStatus {
+
+ private String agentIp;
+ private String tag;
+ private String cluster;
+ private String agentVersion;
+ private String agentStartTime;
+ private String cpuCore;
+ private String procCpu;
+ private String freeMem;
+ private String maxMem;
+ private String useMem;
+ private String os;
+ private String installPlatform;
+ private String usrDir;
+ private String usrName;
+ private String processId;
+ private String globalConfigMd5;
+ private String taskMd5;
+ private String taskNum;
+ private String instanceNum;
+ private String bootTime;
+ private String sendPackageCount;
+ private String sendDataLen;
+ private String sourcePermitLeft;
+ private String queuePermitLeft;
+ private String writerPermitLeft;
+ private String activeThreadCount;
+
+ public String getFieldsString() {
+ List<String> fields = Lists.newArrayList();
+ fields.add(agentIp);
+ fields.add(tag);
+ fields.add(cluster);
+ fields.add(agentVersion);
+ fields.add(agentStartTime);
+ fields.add(cpuCore);
+ fields.add(procCpu);
+ fields.add(freeMem);
+ fields.add(maxMem);
+ fields.add(useMem);
+ fields.add(os);
+ fields.add(installPlatform);
+ fields.add(usrDir);
+ fields.add(usrName);
+ fields.add(processId);
+ fields.add(globalConfigMd5);
+ fields.add(taskMd5);
+ fields.add(taskNum);
+ fields.add(instanceNum);
+ fields.add(bootTime);
+ fields.add(sendPackageCount);
+ fields.add(sendDataLen);
+ fields.add(sourcePermitLeft);
+ fields.add(queuePermitLeft);
+ fields.add(writerPermitLeft);
+ fields.add(activeThreadCount);
+ return Strings.join(fields, ',');
+ }
+ }
+
private static final Logger LOGGER =
LoggerFactory.getLogger(AgentStatusManager.class);
public static final String INLONG_AGENT_SYSTEM = "inlong_agent_system";
public static final String INLONG_AGENT_STATUS = "inlong_agent_status";
private static AgentStatusManager manager = null;
private final AgentConfiguration conf;
- private final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd
HH:mm:ss"); // 设置格式
+ private final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd
HH:mm:ss");
private Runtime runtime = Runtime.getRuntime();
final long GB = 1024 * 1024 * 1024;
private OperatingSystemMXBean osMxBean;
Review Comment:
remove legacy codes
--
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: commits-unsubscr...@inlong.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
