etcdtools

README

etcd-tools

可用于服务配置数据的获取和热更新，从而实现依赖配置数据服务的热重载。

安装

go get github.com/lonisy/etcd-tools

概述

包 etcdtools 使用了 go.etcd.io/etcd/client/v3 客户端。

使用 etcdtools.NewEtcdTools() 创建客户端。

Etcd := etcdtools.NewEtcdTools().Init(clientv3.Config{
    Endpoints:   []string{"xxx.xxx.xxx.xxx:2379","xxx.xxx.xxx.xxx:2379","xxx.xxx.xxx.xxx:2379"},
    DialTimeout: 5 * time.Second,
})

使用 viper 来加载服务配置数据。 这里使用 github.com/spf13/viper 作为程序应用配置解决方案。

key := "/projects/apps/domain.com/prod.json"
AppConfig = viper.New()
AppConfig.SetConfigType("json")
Etcd.LoadData(key, func(x, y interface{}) {
    if err := AppConfig.ReadConfig(bytes.NewBufferString(cast.ToString(y))); err == nil {
        if err := AppConfig.WriteConfigAs("config.json"); err != nil {
            log.Println(err.Error())
        }
    } else {
        log.Panicln(err.Error())
    }
})
Etcd.WatchData(key, func(x, y interface{}) {
    if err := AppConfig.ReadConfig(bytes.NewBufferString(cast.ToString(y))); err == nil {
        if err := AppConfig.WriteConfigAs("config.json"); err != nil {
            log.Println(err.Error())
        }
        // 这里可以触发应用程序的热重载回调
        // Todo ServiceReload... 
    } else {
        log.Panicln(err.Error())
    }
})

使用数据结构来加载服务数据

type Goods []struct {
    GoodsID uint   `json:"id"`
    Name    string `json:"name"`
    Image   string `json:"image"`
}

var GoodsItems Goods

func InitGoodsItems() {
    key := "/projects/apps/domain.com/cache/goods.json"
    Etcd.LoadData(key, func(x, y interface{}) {
        if err := json.Unmarshal([]byte(cast.ToString(y)), &GoodsItems); err != nil {
            log.Panicln(err.Error())
        }
    })
    Etcd.WatchData(key, func(x, y interface{}) {
        if err := json.Unmarshal([]byte(cast.ToString(y)), &GoodsItems); err != nil {
            log.Panicln(err.Error())
        }
    })
}

Documentation

Index

• type Callback
• type EtcdTools
  • func NewEtcdTools() *EtcdTools
  • func (s *EtcdTools) Destructor()
  • func (s *EtcdTools) Init(config clientv3.Config) *EtcdTools
  • func (s *EtcdTools) LoadData(key string, callback Callback)
  • func (s *EtcdTools) WatchData(key string, callback Callback)

Types

type Callback

type Callback func(x, y interface{})

type EtcdTools

type EtcdTools struct {
	Client *clientv3.Client
	// contains filtered or unexported fields
}

func NewEtcdTools

func NewEtcdTools() *EtcdTools

func (*EtcdTools) Destructor

func (s *EtcdTools) Destructor()

func (*EtcdTools) Init

func (s *EtcdTools) Init(config clientv3.Config) *EtcdTools

func (*EtcdTools) LoadData

func (s *EtcdTools) LoadData(key string, callback Callback)

func (*EtcdTools) WatchData

func (s *EtcdTools) WatchData(key string, callback Callback)