diff --git a/contrib/config/consul/README.md b/contrib/config/consul/README.md index dfe8b3053..12655eaa3 100644 --- a/contrib/config/consul/README.md +++ b/contrib/config/consul/README.md @@ -42,7 +42,7 @@ func init() { ) adapter, err := consul.New(ctx, consul.Config{ - Params: consulConfig, + ConsulConfig: consulConfig, Path: configPath, Watch: true, }) diff --git a/example/config/consul/boot/boot.go b/example/config/consul/boot/boot.go new file mode 100644 index 000000000..286e18ce6 --- /dev/null +++ b/example/config/consul/boot/boot.go @@ -0,0 +1,35 @@ +package boot + +import ( + consul "github.com/gogf/gf/contrib/config/consul/v2" + + "github.com/gogf/gf/v2/frame/g" + "github.com/gogf/gf/v2/os/gctx" + "github.com/hashicorp/consul/api" + "github.com/hashicorp/go-cleanhttp" +) + +func init() { + var ( + ctx = gctx.GetInitCtx() + consulConfig = api.Config{ + Address: "127.0.0.1:8500", + Scheme: "http", + Datacenter: "dc1", + Transport: cleanhttp.DefaultPooledTransport(), + Token: "3f8aeba2-f1f7-42d0-b912-fcb041d4546d", + } + configPath = "server/message" + ) + + adapter, err := consul.New(ctx, consul.Config{ + ConsulConfig: consulConfig, + Path: configPath, + Watch: true, + }) + if err != nil { + g.Log().Fatalf(ctx, `New consul adapter error: %+v`, err) + } + + g.Cfg().SetAdapter(adapter) +} diff --git a/example/config/consul/main.go b/example/config/consul/main.go new file mode 100644 index 000000000..ad7a96a4a --- /dev/null +++ b/example/config/consul/main.go @@ -0,0 +1,21 @@ +package main + +import ( + _ "github.com/gogf/gf/example/config/consul/boot" + + "github.com/gogf/gf/v2/frame/g" + "github.com/gogf/gf/v2/os/gctx" +) + +func main() { + var ctx = gctx.GetInitCtx() + + // Available checks. + g.Dump(g.Cfg().Available(ctx)) + + // All key-value configurations. + g.Dump(g.Cfg().Data(ctx)) + + // Retrieve certain value by key. + g.Dump(g.Cfg().MustGet(ctx, "redis.addr")) +}