Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for GetResponseRange (0.19 sec)

  1. 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)
  2. 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)
Back to top