Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WithRange (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    	if !strings.HasSuffix(preparedKey, "/") {
    		preparedKey += "/"
    	}
    
    	startTime := time.Now()
    	getResp, err := s.client.KV.Get(context.Background(), preparedKey, clientv3.WithRange(clientv3.GetPrefixRangeEnd(preparedKey)), clientv3.WithCountOnly())
    	metrics.RecordEtcdRequest("listWithCount", preparedKey, err, startTime)
    	if err != nil {
    		return 0, err
    	}
    	return getResp.Count, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go

    	opts := []clientv3.OpOption{}
    	if wc.recursive {
    		opts = append(opts, clientv3.WithLimit(defaultWatcherMaxLimit))
    		rangeEnd := clientv3.GetPrefixRangeEnd(wc.key)
    		opts = append(opts, clientv3.WithRange(rangeEnd))
    	}
    
    	var err error
    	var lastKey []byte
    	var withRev int64
    	var getResp *clientv3.GetResponse
    
    	metricsOp := "get"
    	if wc.recursive {
    		metricsOp = "list"
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 10:26:38 UTC 2023
    - 18.9K bytes
    - Viewed (0)
Back to top