make batchupdate idempotent

jschwinger233 · jschwinger233 · commit 25de1053ce15 · 2021-06-25T13:08:55.000+08:00
diff --git a/store/etcdv3/meta/etcd.go b/store/etcdv3/meta/etcd.go
@@ -308,7 +308,7 @@ func (e *ETCD) Grant(ctx context.Context, ttl int64) (*clientv3.LeaseGrantRespon
 func (e *ETCD) batchUpdate(ctx context.Context, data map[string]string, opts ...clientv3.OpOption) (*clientv3.TxnResponse, error) {
 	limit := map[string]map[string]string{}
 	for key := range data {
-		limit[key] = map[string]string{cmpVersion: "!=", cmpValue: "!="} // ignore same data
+		limit[key] = map[string]string{cmpVersion: "!="}
 	}
 	resp, err := e.batchPut(ctx, data, limit, opts...)
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -308,7 +308,7 @@ func (e ETCD) Grant(ctx context.Context, ttl int64) (clientv3.LeaseGrantRespon`
`308`	`308`	`func (e ETCD) batchUpdate(ctx context.Context, data map[string]string, opts ...clientv3.OpOption) (clientv3.TxnResponse, error) {`
`309`	`309`	`limit := map[string]map[string]string{}`
`310`	`310`	`for key := range data {`
`311`		`- limit[key] = map[string]string{cmpVersion: "!=", cmpValue: "!="} // ignore same data`
	`311`	`+ limit[key] = map[string]string{cmpVersion: "!="}`
`312`	`312`	`}`
`313`	`313`	`resp, err := e.batchPut(ctx, data, limit, opts...)`
`314`	`314`	`if err != nil {`