Go etcd模块使用
go语言使用etcdpackage mainimport ("fmt""github.com/astaxie/beego/logs"etcd_client "github.com/coreos/etcd/clientv3")type EtcdClient struct {client *etcd_client.Client}// 定义全局变量var (etcdClient *EtcdClient)
·
go语言使用etcd
package main
import (
"fmt"
"github.com/astaxie/beego/logs"
etcd_client "github.com/coreos/etcd/clientv3"
)
type EtcdClient struct {
client *etcd_client.Client
}
// 定义全局变量
var (
etcdClient *EtcdClient
)
func initEtcd(addr string) error {
cli, err := etcd_client.New(etcd_client.Config{
EndPoints: []string{"localhost:2379", "localhost:22379"},
DialTimeout: 5 * time.Second,
})
if err != nil {
logs.Error("connect etcd failed, err:", err)
return
}
etcdClient = &EtcdClient{
client: cli
}
fmt.Println("connect success!")
}
更多推荐
已为社区贡献7条内容
所有评论(0)