formate code

gaoyan1998 · Dec 12, 2023 · d96f7dc · d96f7dc
1 parent dfd8516
commit d96f7dc
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 18 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/context/MetricsContextHolder.java b/dinky-admin/src/main/java/org/dinky/context/MetricsContextHolder.java
@@ -30,7 +30,6 @@
 import java.util.concurrent.CompletableFuture;
 
 import cn.hutool.core.text.StrFormatter;
-import cn.hutool.json.JSONUtil;
 import lombok.extern.slf4j.Slf4j;
 
 /**
@@ -56,20 +55,21 @@ public static MetricsContextHolder getInstances() {
 
     public void sendAsync(String key, MetricsVO o) {
         CompletableFuture.runAsync(() -> {
-            metricsVOS.add(o);
-            long duration = System.currentTimeMillis() - lastDumpTime;
-            synchronized (metricsVOS) {
-                if (metricsVOS.size() > 1000 || duration > 1000 * 5) {
-                    PaimonUtil.write(PaimonTableConstant.DINKY_METRICS, metricsVOS, MetricsVO.class);
-                    metricsVOS.clear();
-                }
-            }
-            String topic = StrFormatter.format("{}/{}", SseTopic.METRICS.getValue(), key);
-            SseSessionContextHolder.sendTopic(topic, o);
-        }).whenComplete((v, t) -> {
-            if (t!= null) {
-                log.error("send metrics async error", t);
-            }
-        });
+                    metricsVOS.add(o);
+                    long duration = System.currentTimeMillis() - lastDumpTime;
+                    synchronized (metricsVOS) {
+                        if (metricsVOS.size() > 1000 || duration > 1000 * 5) {
+                            PaimonUtil.write(PaimonTableConstant.DINKY_METRICS, metricsVOS, MetricsVO.class);
+                            metricsVOS.clear();
+                        }
+                    }
+                    String topic = StrFormatter.format("{}/{}", SseTopic.METRICS.getValue(), key);
+                    SseSessionContextHolder.sendTopic(topic, o);
+                })
+                .whenComplete((v, t) -> {
+                    if (t != null) {
+                        log.error("send metrics async error", t);
+                    }
+                });
     }
 }
diff --git a/dinky-common/src/main/java/org/dinky/data/metrics/MetricsTotal.java b/dinky-common/src/main/java/org/dinky/data/metrics/MetricsTotal.java
@@ -19,12 +19,12 @@
 
 package org.dinky.data.metrics;
 
+import java.io.Serializable;
+
 import cn.hutool.core.lang.Singleton;
 import lombok.Getter;
 import lombok.Setter;
 
-import java.io.Serializable;
-
 @Getter
 @Setter
 public class MetricsTotal implements Serializable {