- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for GetResponseRange (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact.go
).Else( clientv3.OpGet(compactRevKey), ).Commit() if err != nil { return t, rev, err } curRev := resp.Header.Revision if !resp.Succeeded { curTime := resp.Responses[0].GetResponseRange().Kvs[0].Version return curTime, curRev, nil } curTime := t + 1 if rev == 0 { // We don't compact on bootstrap. return curTime, curRev, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 17 02:54:36 UTC 2022 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
).Commit() metrics.RecordEtcdRequest("delete", s.groupResourceString, err, startTime) if err != nil { return err } if !txnResp.Succeeded { getResp := (*clientv3.GetResponse)(txnResp.Responses[0].GetResponseRange()) klog.V(4).Infof("deletion of %s failed because of a conflict, going to retry", key) origState, err = s.getState(ctx, getResp, key, v, false) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0)