From 4c528bca61dc21aa3b84311beffe9c208b17702c Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 4 Jun 2024 11:01:49 +0800 Subject: [PATCH] =?UTF-8?q?refactor(monitor):=20=E8=A1=A8=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=B8=85=E7=90=86=E4=BA=A4=E7=BB=99=E8=BF=90=E7=BB=B4?= =?UTF-8?q?=E5=90=8C=E4=BA=8B=E7=BB=9F=E4=B8=80=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../clean/CompactionMetricsCleaner.java | 33 ------------------- .../monitor/clean/TableVersionCleaner.java | 31 ----------------- 2 files changed, 64 deletions(-) delete mode 100644 service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/CompactionMetricsCleaner.java delete mode 100644 service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/TableVersionCleaner.java diff --git a/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/CompactionMetricsCleaner.java b/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/CompactionMetricsCleaner.java deleted file mode 100644 index 95e1bd5..0000000 --- a/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/CompactionMetricsCleaner.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.lanyuanxiaoyao.service.monitor.clean; - -import com.lanyuanxiaoyao.service.forest.service.InfoService; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Service; - -import static com.lanyuanxiaoyao.service.common.Constants.MINUTE; - -/** - * 清理compaction metrics表 - * - * @author lanyuanxiaoyao - * @date 2024-05-23 - */ -@SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") -@Service -public class CompactionMetricsCleaner extends Cleaner { - private static final Logger logger = LoggerFactory.getLogger(CompactionMetricsCleaner.class); - - private final InfoService infoService; - - public CompactionMetricsCleaner(InfoService infoService) { - this.infoService = infoService; - } - - @Scheduled(cron = "0 0 6 * * ?") - @Override - void clean() { - logger.info("Clean compaction metrics: {}", infoService.cleanCompactionMetrics()); - } -} diff --git a/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/TableVersionCleaner.java b/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/TableVersionCleaner.java deleted file mode 100644 index 212d8f5..0000000 --- a/service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/clean/TableVersionCleaner.java +++ /dev/null @@ -1,31 +0,0 @@ -package com.lanyuanxiaoyao.service.monitor.clean; - -import com.lanyuanxiaoyao.service.forest.service.InfoService; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Service; - -/** - * 清理table version表 - * - * @author lanyuanxiaoyao - * @date 2024-05-23 - */ -@SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") -@Service -public class TableVersionCleaner extends Cleaner { - private static final Logger logger = LoggerFactory.getLogger(TableVersionCleaner.class); - - private final InfoService infoService; - - public TableVersionCleaner(InfoService infoService) { - this.infoService = infoService; - } - - @Scheduled(cron = "0 0 7 * * ?") - @Override - void clean() { - logger.info("Clean table version: {}", infoService.cleanTableVersion()); - } -}