Skip to content

Commit cfb60c8

Browse files
authored
Merge pull request #20121 from k8s-infra-cherrypick-robot/cherry-pick-20120-to-release-3.6
[release-3.6] Update 'endpoint health' command to avoid calling `flags.SetPflagsFromEnv` multiple times
2 parents debb049 + 4562eec commit cfb60c8

File tree

1 file changed

+16
-5
lines changed

1 file changed

+16
-5
lines changed

etcdctl/ctlv3/command/ep_command.go

Lines changed: 16 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ import (
2929
"go.etcd.io/etcd/client/pkg/v3/logutil"
3030
clientv3 "go.etcd.io/etcd/client/v3"
3131
"go.etcd.io/etcd/pkg/v3/cobrautl"
32-
"go.etcd.io/etcd/pkg/v3/flags"
3332
)
3433

3534
var (
@@ -96,8 +95,6 @@ func epHealthCommandFunc(cmd *cobra.Command, args []string) {
9695
if err != nil {
9796
cobrautl.ExitWithError(cobrautl.ExitError, err)
9897
}
99-
flags.SetPflagsFromEnv(lg, "ETCDCTL", cmd.InheritedFlags())
100-
initDisplayFromCmd(cmd)
10198

10299
cfgSpec := clientConfigFromCmd(cmd)
103100

@@ -253,10 +250,24 @@ func endpointsFromCluster(cmd *cobra.Command) []string {
253250
return endpoints
254251
}
255252

256-
cfgSpec := clientConfigFromCmd(cmd)
253+
sec := secureCfgFromCmd(cmd)
254+
dt := dialTimeoutFromCmd(cmd)
255+
ka := keepAliveTimeFromCmd(cmd)
256+
kat := keepAliveTimeoutFromCmd(cmd)
257+
eps, err := endpointsFromCmd(cmd)
258+
if err != nil {
259+
cobrautl.ExitWithError(cobrautl.ExitError, err)
260+
}
257261
// exclude auth for not asking needless password (MemberList() doesn't need authentication)
258262
lg, _ := logutil.CreateDefaultZapLogger(zap.InfoLevel)
259-
cfg, err := clientv3.NewClientConfig(cfgSpec, lg)
263+
264+
cfg, err := clientv3.NewClientConfig(&clientv3.ConfigSpec{
265+
Endpoints: eps,
266+
DialTimeout: dt,
267+
KeepAliveTime: ka,
268+
KeepAliveTimeout: kat,
269+
Secure: sec,
270+
}, lg)
260271
if err != nil {
261272
cobrautl.ExitWithError(cobrautl.ExitError, err)
262273
}

0 commit comments

Comments
 (0)