Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #13461 from qsyqian/etcdctl-command-defrag

Browse Source 
etcdctl/ctlv3/command: add use time for defrag command
This commit is contained in:
Sahdev Zala 2021-11-17 13:36:23 -05:00 committed by GitHub
commit 7e0248b367
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
etcdctl/ctlv3/command/defrag_command.go
View File

@ -17,6 +17,7 @@ package command
import ( import (
"fmt" "fmt"
"os" "os"
"time"
"github.com/spf13/cobra" "github.com/spf13/cobra"
"go.etcd.io/etcd/etcdutl/v3/etcdutl" "go.etcd.io/etcd/etcdutl/v3/etcdutl"
@ -53,13 +54,15 @@ func defragCommandFunc(cmd *cobra.Command, args []string) {
c := mustClientFromCmd(cmd) c := mustClientFromCmd(cmd)
for _, ep := range endpointsFromCluster(cmd) { for _, ep := range endpointsFromCluster(cmd) {
ctx, cancel := commandCtx(cmd) ctx, cancel := commandCtx(cmd)
start := time.Now()
_, err := c.Defragment(ctx, ep) _, err := c.Defragment(ctx, ep)
d := time.Now().Sub(start)
cancel() cancel()
if err != nil { if err != nil {
fmt.Fprintf(os.Stderr, "Failed to defragment etcd member[%s] (%v)\n", ep, err) fmt.Fprintf(os.Stderr, "Failed to defragment etcd member[%s]. took %s. (%v)\n", ep, d.String(), err)
failures++ failures++
} else { } else {
fmt.Printf("Finished defragmenting etcd member[%s]\n", ep) fmt.Printf("Finished defragmenting etcd member[%s]. took %s\n", ep, d.String())
} }
} }