add consul config center

config/config_test.go

@@ -2,12 +2,17 @@ package config_test
 
 import (
 	"context"
-	"github.com/dobyte/due/config/etcd/v2"
 	"github.com/dobyte/due/v2/config"
+	"github.com/dobyte/due/v2/config/file"
 	"testing"
 	"time"
 )
 
+func init() {
+	source := file.NewSource(file.WithMode(config.ReadWrite))
+	config.SetConfigurator(config.NewConfigurator(config.WithSources(source)))
+}
+
 func TestWatch(t *testing.T) {
 	ticker1 := time.NewTicker(2 * time.Second)
 	ticker2 := time.After(time.Minute)
@@ -26,8 +31,8 @@ func TestWatch(t *testing.T) {
 
 func TestLoad(t *testing.T) {
 	ctx := context.Background()
-	file := "config.json"
-	c, err := config.Load(ctx, etcd.Name, file)
+	filename := "config.json"
+	c, err := config.Load(ctx, file.Name, filename)
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -40,7 +45,7 @@ func TestLoad(t *testing.T) {
 
 func TestStore(t *testing.T) {
 	ctx := context.Background()
-	file := "config.json"
+	filename := "config.json"
 	content1 := map[string]interface{}{
 		"timezone": "Local",
 	}
@@ -50,14 +55,14 @@ func TestStore(t *testing.T) {
 		"pid":      "./run/gate.pid",
 	}
 
-	err := config.Store(ctx, etcd.Name, file, content1, true)
+	err := config.Store(ctx, file.Name, filename, content1, true)
 	if err != nil {
 		t.Fatal(err)
 	}
 
 	time.Sleep(5 * time.Second)
 
-	err = config.Store(ctx, etcd.Name, file, content2)
+	err = config.Store(ctx, file.Name, filename, content2)
 	if err != nil {
 		t.Fatal(err)
 	}

config/etcd/config_test.go

@@ -0,0 +1,75 @@
+package etcd_test
+
+import (
+	"context"
+	"github.com/dobyte/due/config/etcd/v2"
+	"github.com/dobyte/due/v2/config"
+	"testing"
+	"time"
+)
+
+func init() {
+	source := etcd.NewSource(etcd.WithMode(config.ReadWrite))
+	config.SetConfigurator(config.NewConfigurator(config.WithSources(source)))
+}
+
+func TestWatch(t *testing.T) {
+	ticker1 := time.NewTicker(2 * time.Second)
+	ticker2 := time.After(time.Minute)
+
+	for {
+		select {
+		case <-ticker1.C:
+			t.Log(config.Get("config.timezone").String())
+			t.Log(config.Get("config.pid").String())
+		case <-ticker2:
+			config.Close()
+			return
+		}
+	}
+}
+
+func TestLoad(t *testing.T) {
+	ctx := context.Background()
+	file := "config.json"
+	c, err := config.Load(ctx, etcd.Name, file)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	t.Log(c[0].Name)
+	t.Log(c[0].Path)
+	t.Log(c[0].Format)
+	t.Log(c[0].Content)
+}
+
+func TestStore(t *testing.T) {
+	ctx := context.Background()
+	file := "config.json"
+	content1 := map[string]interface{}{
+		"timezone": "Local",
+	}
+
+	content2 := map[string]interface{}{
+		"timezone": "UTC",
+		"pid":      "./run/gate.pid",
+	}
+
+	err := config.Store(ctx, etcd.Name, file, content1, true)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	time.Sleep(5 * time.Second)
+
+	err = config.Store(ctx, etcd.Name, file, content2)
+	if err != nil {
+		t.Fatal(err)
+	}
+}
+
+func BenchmarkGet(b *testing.B) {
+	for i := 0; i < b.N; i++ {
+		config.Get("config").Value()
+	}
+}

testdata/etc/etc.toml

@@ -30,6 +30,14 @@ timezone = "Local"
         path = "/config"
         # 读写模式。可选：read-only | read-write，默认为read-only
         mode = "read-only"
+    # consul配置中心
+    [config.consul]
+        # 客户端连接地址
+        addr = "127.0.0.1:8500"
+        # 路径。默认为/config
+        path = "/config"
+        # 读写模式。可选：read-only | read-write，默认为read-only
+        mode = "read-only"
 
 [cluster]
     # 集群网关配置