- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for WithRange (0.09 sec)
-
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) -
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)