up

conf/prod/base.toml

@@ -23,4 +23,5 @@
     addrs = [
         "192.168.2.232:2379"
     ]
+    username = ""
     password = ""

main.go

@@ -26,6 +26,7 @@ func registryEtcd(){
 		//registry.WithAddrs([]string{"192.168.2.232:2379"}),
 		registry.WithAddrs(lib.GetStringSliceConf("base.etcd.addrs")),
 		registry.WithTimeout(5*time.Second),
+		registry.WithUsername("base.etcd.username"),
 		registry.WithPasswrod("base.etcd.password"),
 		registry.WithRegistryPath("/ichuntMicroService/"),
 		registry.WithHeartBeat(5),

registry/etcd/etcd.go

@@ -82,6 +82,8 @@ func (e *EtcdRegistry) Init(ctx context.Context, opts ...registry.Option) (err e
 		Endpoints:   e.options.Addrs,
 		DialTimeout: e.options.Timeout,
 		Password:	 e.options.Password,
+		Username:    e.options.Username,
+
 	}
 
 	e.client, err = clientv3.New(clientConfig)

registry/options.go

@@ -7,6 +7,7 @@ import (
 type Options struct {
 	Addrs   []string
 	Timeout time.Duration
+	Username string
 	Password string
 	// example:  /xxx_company/app/kuaishou/service_A/10.192.1.1:8801
 	// example:  /xxx_company/app/kuaishou/service_A/10.192.1.2:8801
@@ -34,6 +35,12 @@ func WithPasswrod(password string) Option {
 	}
 }
 
+func WithUsername(username string) Option {
+	return func(opts *Options) {
+		opts.Username = username
+	}
+}
+
 func WithRegistryPath(path string) Option {
 	return func(opts *Options) {
 		opts.RegistryPath = path