etcd.go 405 B

123456789101112131415161718192021222324252627
  1. package config
  2. import (
  3. "github.com/sirupsen/logrus"
  4. "go.etcd.io/etcd/client/v3"
  5. "os"
  6. "time"
  7. )
  8. var (
  9. Etcd *clientv3.Client
  10. )
  11. func InitEtcd() {
  12. config := clientv3.Config{
  13. Endpoints: []string{os.Getenv("ETCD_URL")},
  14. DialTimeout: time.Second * 3,
  15. }
  16. //连接
  17. client, err := clientv3.New(config)
  18. if err != nil {
  19. logrus.Panic("连接Etcd不成功, err:", err)
  20. return
  21. }
  22. Etcd = client
  23. }