etcdctl/ctlv3/command: add use time for defrag command
parent
6656181d31
commit
eccabd237b
|
@ -17,6 +17,7 @@ package command
|
|||
import (
|
||||
"fmt"
|
||||
"os"
|
||||
"time"
|
||||
|
||||
"github.com/spf13/cobra"
|
||||
"go.etcd.io/etcd/etcdutl/v3/etcdutl"
|
||||
|
@ -53,13 +54,15 @@ func defragCommandFunc(cmd *cobra.Command, args []string) {
|
|||
c := mustClientFromCmd(cmd)
|
||||
for _, ep := range endpointsFromCluster(cmd) {
|
||||
ctx, cancel := commandCtx(cmd)
|
||||
start := time.Now()
|
||||
_, err := c.Defragment(ctx, ep)
|
||||
d := time.Now().Sub(start)
|
||||
cancel()
|
||||
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++
|
||||
} else {
|
||||
fmt.Printf("Finished defragmenting etcd member[%s]\n", ep)
|
||||
fmt.Printf("Finished defragmenting etcd member[%s]. took %s\n", ep, d.String())
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue