config, api: add API for getting the config checksum

lib/config/health.go

@@ -15,5 +15,5 @@
 package config
 
 type HealthInfo struct {
-	ConfigVersion uint32 `json:"config_version"`
+	ConfigChecksum uint32 `json:"config_checksum"`
 }

pkg/manager/config/config.go

@@ -15,11 +15,13 @@
 package config
 
 import (
+	"hash/crc32"
 	"os"
 	"time"
 
 	"github.com/BurntSushi/toml"
 	"github.com/fsnotify/fsnotify"
+	gotoml "github.com/pelletier/go-toml/v2"
 	"github.com/pingcap/TiProxy/lib/config"
 	"go.uber.org/zap"
 )
@@ -74,8 +76,9 @@ func (e *ConfigManager) SetTOMLConfig(data []byte) error {
 		return err
 	}
 
-	e.sts.current = base
-	e.sts.version++
+	if err := e.setCurrentConfig(base); err != nil {
+		return err
+	}
 
 	for _, list := range e.sts.listeners {
 		list <- base.Clone()
@@ -84,6 +87,17 @@ func (e *ConfigManager) SetTOMLConfig(data []byte) error {
 	return nil
 }
 
+func (e *ConfigManager) setCurrentConfig(cfg *config.Config) error {
+	e.sts.current = cfg
+	e.sts.version++
+	bytes, err := gotoml.Marshal(cfg)
+	if err != nil {
+		return err
+	}
+	e.sts.checksum = crc32.ChecksumIEEE(bytes)
+	return nil
+}
+
 func (e *ConfigManager) GetConfig() *config.Config {
 	e.sts.Lock()
 	v := e.sts.current
@@ -98,6 +112,13 @@ func (e *ConfigManager) GetConfigVersion() uint32 {
 	return v
 }
 
+func (e *ConfigManager) GetConfigChecksum() uint32 {
+	e.sts.Lock()
+	c := e.sts.checksum
+	e.sts.Unlock()
+	return c
+}
+
 func (e *ConfigManager) WatchConfig() <-chan *config.Config {
 	ch := make(chan *config.Config)
 	e.sts.Lock()

pkg/manager/config/config_test.go

@@ -163,3 +163,18 @@ func TestConfigRemove(t *testing.T) {
 	require.NoError(t, os.WriteFile(tmpcfg, []byte(`proxy.addr = "vv"`), 0644))
 	require.Eventually(t, func() bool { return cfgmgr.GetConfig().Proxy.Addr == "vv" }, time.Second, 100*time.Millisecond)
 }
+
+func TestChecksum(t *testing.T) {
+	cfgmgr, _ := testConfigManager(t, "")
+	c1 := cfgmgr.GetConfigChecksum()
+	require.NoError(t, cfgmgr.SetTOMLConfig([]byte(`proxy.addr = "gg"`)))
+	c2 := cfgmgr.GetConfigChecksum()
+	require.NoError(t, cfgmgr.SetTOMLConfig([]byte(`proxy.addr = "vv"`)))
+	c3 := cfgmgr.GetConfigChecksum()
+	require.NoError(t, cfgmgr.SetTOMLConfig([]byte(`proxy.addr="gg"`)))
+	c4 := cfgmgr.GetConfigChecksum()
+	require.Equal(t, c2, c4)
+	require.NotEqual(t, c1, c2)
+	require.NotEqual(t, c1, c3)
+	require.NotEqual(t, c2, c3)
+}

pkg/manager/config/manager.go

@@ -57,6 +57,7 @@ type ConfigManager struct {
 		listeners []chan<- *config.Config
 		current   *config.Config
 		version   uint32
+		checksum  uint32
 	}
 }
 

pkg/server/api/debug.go

@@ -24,7 +24,7 @@ import (
 
 func (h *HTTPServer) DebugHealth(c *gin.Context) {
 	c.JSON(http.StatusOK, config.HealthInfo{
-		ConfigVersion: h.mgr.cfg.GetConfigVersion(),
+		ConfigChecksum: h.mgr.cfg.GetConfigChecksum(),
 	})
 }