config

config

go-etcd/config 是 go-micro/config 的 etcd 实现，提供统一的配置存储与监听能力。

能力范围

• Store：Get/GetByQuery/Put/Delete
• 版本能力：PutVersion/GetVersion/ListVersions
• 元信息能力：GetMeta/PutMeta
• Watcher：Watch/Unwatch
• loader 辅助：NewStoreFromLoader、LoadConfigFromStore

路径模型

默认命名空间：/config-center

按单条配置键生成路径：

• 当前配置：/{namespace}/{tenant}/{env}/{app}/{group}/{name}/current
• 版本前缀：/{namespace}/{tenant}/{env}/{app}/{group}/{name}/versions
• 版本快照：/{namespace}/{tenant}/{env}/{app}/{group}/{name}/versions/{version}
• 元信息：/{namespace}/{tenant}/{env}/{app}/{group}/{name}/meta

当 tenant 为空时会回退为 default。

Loader 辅助

当调用方已经接入 go-micro/config 的 LoaderParams / StoreParams 体系时，可以直接使用：

• NewStoreFromLoader：先按 local / remote 规则加载 etcd.Conf，再创建 Store
• LoadConfigFromStore：从 Store 读取配置并解码为目标类型

快速开始

package main

import (
	"context"

	etcdx "github.com/fireflycore/go-etcd"
	etcdcfg "github.com/fireflycore/go-etcd/config"
	microcfg "github.com/fireflycore/go-micro/config"
)

func main() {
	cli, err := etcdx.New(&etcdx.Conf{
		Endpoint: []string{"127.0.0.1:2379"},
	})
	if err != nil {
		panic(err)
	}
	defer cli.Close()

	store, err := etcdcfg.NewStore(cli, &etcdcfg.Conf{
		Namespace: "/config-center",
	})
	if err != nil {
		panic(err)
	}

	key := microcfg.Key{
		TenantId: "t1",
		Env:      "prod",
		AppId:    "order-service",
		Group:    "db",
		Name:     "primary",
	}

	_ = store.Put(context.Background(), key, &microcfg.Item{
		Version: "v1",
		Content: []byte(`{"dsn":"root:root@tcp(127.0.0.1:3306)/order"}`),
	})

	_, _ = store.Get(context.Background(), key)
}