diff --git a/staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go b/staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go index 481d496e297..753cbe899a1 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go +++ b/staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go @@ -573,12 +573,12 @@ func (s *store) Count(key string) (int64, error) { } startTime := time.Now() - getResp, err := s.client.KV.Get(context.Background(), preparedKey, clientv3.WithRange(clientv3.GetPrefixRangeEnd(preparedKey)), clientv3.WithCountOnly()) + count, err := s.client.Kubernetes.Count(context.Background(), preparedKey, kubernetes.CountOptions{}) metrics.RecordEtcdRequest("listWithCount", preparedKey, err, startTime) if err != nil { return 0, err } - return getResp.Count, nil + return count, nil } // ReadinessCheck implements storage.Interface.