- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for WithPrevKV (0.08 sec)
-
cluster/images/etcd/migrate/migrate_client.go
klog.Infof("Attaching lease to %d entries", len(objectsResp.Kvs)) for _, kv := range objectsResp.Kvs { putResp, err := v3client.KV.Put(ctx, string(kv.Key), string(kv.Value), clientv3.WithLease(lease.ID), clientv3.WithPrevKV()) if err != nil { klog.Errorf("Error while attaching lease to: %s", string(kv.Key)) } if !bytes.Equal(putResp.PrevKv.Value, kv.Value) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 6.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
wc.sendEvent(func() *event { e := progressNotifyEvent(wc.initialRev) e.isInitialEventsEndBookmark = true return e }()) } opts := []clientv3.OpOption{clientv3.WithRev(wc.initialRev + 1), clientv3.WithPrevKV()} if wc.recursive { opts = append(opts, clientv3.WithPrefix()) } if wc.progressNotify { opts = append(opts, clientv3.WithProgressNotify()) } wch := wc.watcher.client.Watch(wc.ctx, wc.key, opts...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0)