[Refactor] 配置中心重构+支持配置回滚/撤回发布 (#1187)

Author: chuntaojun

.github/workflows/benchmark.yaml

@@ -62,9 +62,9 @@ jobs:
     steps:
       # Setup the environment.
       - name: Setup Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.19
+          go-version: "1.20"
       # Checkout latest code
       - name: Checkout repo
         uses: actions/checkout@v2

.github/workflows/codecov.yaml

@@ -52,9 +52,9 @@ jobs:
     steps:
       # Setup the environment.
       - name: Setup Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.19
+          go-version: "1.20"
       # Checkout latest code
       - name: Checkout repo
         uses: actions/checkout@v2

.github/workflows/docker.yml

@@ -35,10 +35,10 @@ jobs:
         id: get_version
         run: echo ::set-output name=VERSION::${GITHUB_REF/refs\/tags\//}
 
-      - name: Set up Go
-        uses: actions/setup-go@v2
+      - name: Setup Go
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.19
+          go-version: "1.20"
 
       - name: Set up Docker Buildx
         uses: docker/setup-buildx-action@v1

.github/workflows/golangci-lint.yml

@@ -29,7 +29,7 @@ jobs:
   golangci:
     strategy:
       matrix:
-        go-version: [ 1.19 ]
+        go-version: [ "1.20" ]
     name: golangci-lint
     runs-on: ubuntu-latest
     steps:

.github/workflows/integration-testing-mysql.yml

@@ -76,9 +76,9 @@ jobs:
     steps:
       # Setup the environment.
       - name: Setup Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.19
+          go-version: "1.20"
       # Checkout latest code
       - name: Checkout repo
         uses: actions/checkout@v2

.github/workflows/integration-testing.yml

@@ -62,9 +62,9 @@ jobs:
     steps:
       # Setup the environment.
       - name: Setup Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.19
+          go-version: "1.20"
       # Checkout latest code
       - name: Checkout repo
         uses: actions/checkout@v2

.github/workflows/release.yml

@@ -36,9 +36,9 @@ jobs:
         uses: actions/checkout@v2
 
       - name: Setup Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.19
+          go-version: "1.20"
 
       - name: Get version
         id: get_version

.github/workflows/standalone.yml

@@ -49,9 +49,9 @@ jobs:
           ref: ${{ github.event.inputs.server_version }}
 
       - name: Setup Go
-        uses: actions/setup-go@v2
+        uses: actions/setup-go@v4
         with:
-          go-version: 1.19
+          go-version: "1.20"
 
       - name: Build
         id: build

admin/config.go

@@ -17,9 +17,30 @@
 
 package admin
 
-import "github.com/polarismesh/polaris/admin/job"
+import (
+	"github.com/polarismesh/polaris/admin/job"
+)
 
 // Config maintain configuration
 type Config struct {
 	Jobs []job.JobConfig `yaml:"jobs"`
 }
+
+func DefaultConfig() *Config {
+	return &Config{
+		Jobs: []job.JobConfig{
+			{
+				Name:   "CleanDeletedClients",
+				Enable: true,
+			},
+			{
+				Name:   "CleanDeletedInstances",
+				Enable: true,
+			},
+			{
+				Name:   "CleanConfigReleaseHistory",
+				Enable: true,
+			},
+		},
+	}
+}

admin/job/history_clean.go

@@ -0,0 +1,78 @@
+/**
+ * Tencent is pleased to support the open source community by making Polaris available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * 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 job
+
+import (
+	"time"
+
+	"github.com/mitchellh/mapstructure"
+
+	"github.com/polarismesh/polaris/store"
+)
+
+// 默认保存配置发布天数
+const defaultHistoryRetentionDays = 7 * 24 * time.Hour
+
+type CleanConfigFileHistoryJobConfig struct {
+	RetentionDays time.Duration `mapstructure:"retentionDays"`
+	BatchSize     uint64        `mapstructure:"batchSize"`
+}
+
+type cleanConfigFileHistoryJob struct {
+	cfg     *CleanConfigFileHistoryJobConfig
+	storage store.Store
+}
+
+func (job *cleanConfigFileHistoryJob) init(raw map[string]interface{}) error {
+	cfg := &CleanConfigFileHistoryJobConfig{
+		RetentionDays: defaultHistoryRetentionDays,
+		BatchSize:     1000,
+	}
+	decodeConfig := &mapstructure.DecoderConfig{
+		DecodeHook: mapstructure.StringToTimeDurationHookFunc(),
+		Result:     cfg,
+	}
+	decoder, err := mapstructure.NewDecoder(decodeConfig)
+	if err != nil {
+		log.Errorf("[Maintain][Job][cleanConfigFileHistoryJob] new config decoder err: %v", err)
+		return err
+	}
+	if err = decoder.Decode(raw); err != nil {
+		log.Errorf("[Maintain][Job][cleanConfigFileHistoryJob] parse config err: %v", err)
+		return err
+	}
+	if cfg.RetentionDays < time.Minute {
+		cfg.RetentionDays = time.Minute
+	}
+	job.cfg = cfg
+	return nil
+}
+
+func (job *cleanConfigFileHistoryJob) execute() {
+	endTime := time.Now().Add(-1 * job.cfg.RetentionDays)
+	if err := job.storage.CleanConfigFileReleaseHistory(endTime, job.cfg.BatchSize); err != nil {
+		log.Errorf("[Maintain][Job][cleanConfigFileHistoryJob] execute err: %v", err)
+	}
+}
+
+func (job *cleanConfigFileHistoryJob) interval() time.Duration {
+	return time.Minute
+}
+
+func (job *cleanConfigFileHistoryJob) clear() {
+}