|
|
@@ -129,26 +129,18 @@ func putFunc(cmd *cobra.Command, args []string) {
|
|
|
}
|
|
|
|
|
|
func compactKV(clients []*v3.Client) {
|
|
|
- var curRev int64
|
|
|
- for _, c := range clients {
|
|
|
- ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
|
|
- resp, err := c.KV.Get(ctx, "foo")
|
|
|
- cancel()
|
|
|
- if err != nil {
|
|
|
- panic(err)
|
|
|
- }
|
|
|
- curRev = resp.Header.Revision
|
|
|
- break
|
|
|
+ ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
|
|
+ resp, err := clients[0].KV.Get(ctx, "foo")
|
|
|
+ cancel()
|
|
|
+ if err != nil {
|
|
|
+ panic(err)
|
|
|
}
|
|
|
- revToCompact := max(0, curRev-compactIndexDelta)
|
|
|
- for _, c := range clients {
|
|
|
- ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
|
|
- _, err := c.KV.Compact(ctx, revToCompact)
|
|
|
- cancel()
|
|
|
- if err != nil {
|
|
|
- panic(err)
|
|
|
- }
|
|
|
- break
|
|
|
+ revToCompact := max(0, resp.Header.Revision-compactIndexDelta)
|
|
|
+ ctx, cancel = context.WithTimeout(context.Background(), 5*time.Second)
|
|
|
+ _, err = clients[0].KV.Compact(ctx, revToCompact)
|
|
|
+ cancel()
|
|
|
+ if err != nil {
|
|
|
+ panic(err)
|
|
|
}
|
|
|
}
|
|
|
|