Increase the usage of MetaSpace in computing

arklet/arklet-core/src/main/java/com/alipay/sofa/serverless/arklet/core/command/record/ProcessRecord.java

@@ -22,6 +22,7 @@
 import lombok.Getter;
 import lombok.Setter;
 
+import java.lang.management.MemoryPoolMXBean;
 import java.util.Date;
 
 import static com.alipay.sofa.serverless.arklet.core.command.record.ProcessRecord.Status.EXECUTING;
@@ -39,6 +40,8 @@ public class ProcessRecord {
 
     private static final ArkletLogger LOGGER = ArkletLoggerFactory.getDefaultLogger();
 
+    private MemoryPoolMXBean          metaSpaceMXBean;
+
     private String                    requestId;
 
     private ArkBizMeta                arkBizMeta;
@@ -55,14 +58,20 @@ public class ProcessRecord {
 
     private Date                      startTime;
 
+    private long                      startSpace;
+
     private long                      startTimestamp;
 
     private Date                      endTime;
 
+    private long                      endSpace;
+
     private long                      endTimestamp;
 
     private long                      elapsedTime;
 
+    private long                      elapsedSpace;
+
     public enum Status {
 
         INITIALIZED("INITIALIZED"),
@@ -89,6 +98,8 @@ public void setName(String name) {
     }
 
     public void markFinishTime() {
+        setEndSpace(getMetaSpaceMXBean().getUsage().getUsed());
+        setElapsedSpace(getEndSpace() - getStartSpace());
         Date date = new Date();
         setEndTime(date);
         setEndTimestamp(date.getTime());

arklet/arklet-core/src/main/java/com/alipay/sofa/serverless/arklet/core/command/record/ProcessRecordHolder.java

@@ -16,10 +16,11 @@
  */
 package com.alipay.sofa.serverless.arklet.core.command.record;
 
-import com.alipay.sofa.serverless.arklet.core.command.meta.InputMeta;
 import com.alipay.sofa.serverless.arklet.core.command.meta.bizops.ArkBizMeta;
 import org.apache.commons.lang3.StringUtils;
 
+import java.lang.management.ManagementFactory;
+import java.lang.management.MemoryPoolMXBean;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -58,10 +59,17 @@ public static List<ProcessRecord> getProcessRecordsByStatus(String status) {
 
     public static ProcessRecord createProcessRecord(String rid, ArkBizMeta arkBizMeta) {
         ProcessRecord pr = new ProcessRecord();
+        List<MemoryPoolMXBean> memoryPoolMXBeans = ManagementFactory.getMemoryPoolMXBeans();
+        MemoryPoolMXBean metaSpaceMXBean = null;
+        for (MemoryPoolMXBean memoryPoolMXBean : memoryPoolMXBeans)
+            if (memoryPoolMXBean.getName().equals("Metaspace"))
+                metaSpaceMXBean = memoryPoolMXBean;
         pr.setRequestId(rid);
         pr.setArkBizMeta(arkBizMeta);
         pr.setStatus(INITIALIZED);
         Date date = new Date();
+        pr.setMetaSpaceMXBean(metaSpaceMXBean);
+        pr.setStartSpace(metaSpaceMXBean.getUsage().getUsed());
         pr.setStartTime(date);
         pr.setStartTimestamp(date.getTime());
         processRecords.put(rid, pr);

arklet/arklet-core/src/main/java/com/alipay/sofa/serverless/arklet/core/health/HealthServiceImpl.java

@@ -49,9 +49,8 @@
 @Singleton
 public class HealthServiceImpl implements HealthService {
 
-    private static final ArkletLogger              LOGGER        = ArkletLoggerFactory
-                                                                     .getDefaultLogger();
-    private final HealthBuilder                    healthBuilder = new HealthBuilder();
+    private static final ArkletLogger    LOGGER        = ArkletLoggerFactory.getDefaultLogger();
+    private final HealthBuilder          healthBuilder = new HealthBuilder();
 
     private final Map<String, Indicator> indicators    = new ConcurrentHashMap<>(3);
 

arklet/arklet-core/src/test/java/com/alipay/sofa/serverless/arklet/core/command/CommandTests.java

@@ -16,11 +16,7 @@
  */
 package com.alipay.sofa.serverless.arklet.core.command;
 
-import java.util.HashMap;
-import java.util.Map;
-
 import com.alibaba.fastjson.JSONObject;
-
 import com.alipay.sofa.serverless.arklet.core.BaseTest;
 import com.alipay.sofa.serverless.arklet.core.command.builtin.BuiltinCommand;
 import com.alipay.sofa.serverless.arklet.core.command.builtin.handler.InstallBizHandler;
@@ -32,6 +28,9 @@
 import org.junit.Assert;
 import org.junit.Test;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * @author mingmen
  * @date 2023/6/26
@@ -73,6 +72,10 @@ public void testInstallHandler() throws InterruptedException {
         Map map1 = JSONObject.parseObject(JSONObject.toJSONString(input1), Map.class);
         Output<?> output1 = commandService.process(BuiltinCommand.QUERY_BIZ_OPS.getId(), map1);
         Assert.assertNotNull(output1);
+        ProcessRecord processRecord1 = (ProcessRecord) output1.getData();
+        Assert.assertNotNull(processRecord1);
+        Assert.assertNotNull(processRecord1.getEndSpace());
+        Assert.assertNotNull(processRecord1.getEndTime());
     }
 
 }

arklet/arklet-core/src/test/java/com/alipay/sofa/serverless/arklet/core/command/HealthHandlerTest.java

@@ -1,3 +1,19 @@
+/*
+ * 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 com.alipay.sofa.serverless.arklet.core.command;
 
 import com.alipay.sofa.serverless.arklet.core.BaseTest;
@@ -12,7 +28,7 @@
  */
 public class HealthHandlerTest extends BaseTest {
 
-    private void testValidate(Input input) throws CommandValidationException{
+    private void testValidate(Input input) throws CommandValidationException {
         HealthHandler handler = (HealthHandler) commandService.getHandler(BuiltinCommand.HEALTH);
         handler.validate(input);
     }