插拔型配置中心支持ETCD,K8S,Apollo

Author: hwholiday

README.md

@@ -107,7 +107,60 @@
 {"level":"debug","ts":1639453664.7402549,"caller":"example/main.go:33","msg":"test","traceId":"68867b89-c949-45a4-b325-86866c9f869a"}
 ```
 
+### [hconfig 插拔式配置读取工具可动态加载](https://github.com/hwholiday/learning_tools/tree/master/hconfig)
 
+- 支持 etcd
+- 支持 kubernetes
+- 支持 apollo
+
+#### hconfig  配置不同的源
+
+```base
+//etcd
+cli, err := clientv3.New(clientv3.Config{
+	Endpoints: []string{"127.0.0.1:2379"},})
+	
+c, err := etcd.NewEtcdConfig(cli,
+	etcd.WithRoot("/hconf"),
+	etcd.WithPaths("app", "mysql"))
+
+//kubernetes
+cli, err := kubernetes.NewK8sClientset(
+     kubernetes.KubeConfigPath("/home/app/conf/kube_config/local_kube.yaml"))
+     
+c, err := kubernetes.NewKubernetesConfig(cli, 
+	kubernetes.WithNamespace("im"),
+	kubernetes.WithPaths("im-test-conf", "im-test-conf2"))
+	
+//apollo
+c, err := apollo.NewApolloConfig(
+    apollo.WithAppid("test"),
+    apollo.WithNamespace("test.yaml"),
+    apollo.WithAddr("http://127.0.0.1:32001"),
+    apollo.WithCluster("dev"),
+    )
+```
+
+
+#### hconfig  使用
+
+```base
+conf, err := NewHConfig(
+	WithDataSource(c),//c 不同的源
+)
+
+// 加载配置
+conf.Load() 
+
+//读取配置
+val, err := conf.GetPath("test.yaml")
+t.Logf("val %+v\n", val.String())
+
+//监听配置变化
+conf.WatchPaths(func(path string, v HVal) {
+	t.Logf("path %s val %+v\n", path, v.String())
+})
+```
 
 # go_push 一个实用的消息推送服务
 

hconfig/README.md

@@ -0,0 +1,54 @@
+### [hconfig 插拔式配置读取工具可动态加载](https://github.com/hwholiday/learning_tools/tree/master/hconfig)
+
+- 支持 etcd
+- 支持 kubernetes
+- 支持 apollo
+
+#### hconfig  配置不同的源
+
+```base
+//etcd
+cli, err := clientv3.New(clientv3.Config{
+	Endpoints: []string{"127.0.0.1:2379"},})
+	
+c, err := etcd.NewEtcdConfig(cli,
+	etcd.WithRoot("/hconf"),
+	etcd.WithPaths("app", "mysql"))
+
+//kubernetes
+cli, err := kubernetes.NewK8sClientset(
+     kubernetes.KubeConfigPath("/home/app/conf/kube_config/local_kube.yaml"))
+     
+c, err := kubernetes.NewKubernetesConfig(cli, 
+	kubernetes.WithNamespace("im"),
+	kubernetes.WithPaths("im-test-conf", "im-test-conf2"))
+	
+//apollo
+c, err := apollo.NewApolloConfig(
+    apollo.WithAppid("test"),
+    apollo.WithNamespace("test.yaml"),
+    apollo.WithAddr("http://127.0.0.1:32001"),
+    apollo.WithCluster("dev"),
+    )
+```
+
+
+#### hconfig 使用
+
+```base
+conf, err := NewHConfig(
+	WithDataSource(c),//c 不同的源
+)
+
+// 加载配置
+conf.Load() 
+
+//读取配置
+val, err := conf.GetPath("test.yaml")
+t.Logf("val %+v\n", val.String())
+
+//监听配置变化
+conf.WatchPaths(func(path string, v HVal) {
+	t.Logf("path %s val %+v\n", path, v.String())
+})
+```

hconfig/etcd/config_test.go

@@ -7,7 +7,7 @@ import clientv3 "go.etcd.io/etcd/client/v3"
 
 func TestNewEtcdConfig(t *testing.T) {
 	cli, err := clientv3.New(clientv3.Config{
-		Endpoints: []string{"172.12.12.165:2379"},
+		Endpoints: []string{"127.0.0.1:2379"},
 	})
 	if err != nil {
 		t.Error(err)

hconfig/hconfig_test.go

@@ -10,7 +10,7 @@ import (
 
 func TestNewHConfig_ETCD(t *testing.T) {
 	cli, err := clientv3.New(clientv3.Config{
-		Endpoints: []string{"172.12.12.165:2379"},
+		Endpoints: []string{"127.0.0.1:2379"},
 	})
 	if err != nil {
 		t.Error(err)