- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 204 for setDist (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/lister_watcher.go
Predicate: pred, Recursive: true, } ctx := context.Background() if lw.contextMetadata != nil { ctx = metadata.NewOutgoingContext(ctx, lw.contextMetadata) } if err := lw.storage.GetList(ctx, lw.resourcePrefix, storageOpts, list); err != nil { return nil, err } return list, nil } // Implements cache.ListerWatcher interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/cidrset/cidr_set.go
var i int for i = 0; i < s.maxCIDRs; i++ { if s.used.Bit(candidate) == 0 { break } candidate = (candidate + 1) % s.maxCIDRs } s.nextCandidate = (candidate + 1) % s.maxCIDRs s.used.SetBit(&s.used, candidate, 1) s.allocatedCIDRs++ // Update metrics cidrSetAllocations.WithLabelValues(s.label).Inc() cidrSetAllocationTriesPerRequest.WithLabelValues(s.label).Observe(float64(i))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 11 08:53:03 UTC 2023 - 9.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/SearchListTests.java
final String response = checkMethodBase(body).get(getApiPath() + "/" + getListEndpointSuffix()).asString(); final List<Map<String, Object>> results = JsonPath.from(response).getList("response.docs"); return results; } @Test void crudTest() { testCreate(); testRead(); testUpdate(); testDelete(); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/common/values.go
func (t *unstructuredSetList) Equal(other ref.Val) ref.Val { oSetList, ok := other.(traits.Lister) if !ok { return types.MaybeNoSuchOverloadErr(other) } sz := types.Int(len(t.elements)) if sz != oSetList.Size() { return types.False } tSet := t.getSet() for it := oSetList.Iterator(); it.HasNext() == types.True; { next := it.Next().Value() _, ok := tSet[next]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:30:17 UTC 2023 - 20.5K bytes - Viewed (0) -
src/index/suffixarray/suffixarray_test.go
} case "zero": data = make([]byte, 50e6) case "rand": data = make([]byte, 50e6) for i := range data { data[i] = byte(rand.Intn(256)) } } return data, nil } func setBits(bits int) (cleanup func()) { if bits == 32 { maxData32 = realMaxData32 } else { maxData32 = -1 // force use of 64-bit code } return func() { maxData32 = realMaxData32 } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 14.1K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/FileAuthTests.java
searchBody.put("name", "test_fileconfig"); String res = checkMethodBase(searchBody).get("/api/admin/fileconfig/settings").asString(); List<String> fileConfigList = JsonPath.from(res).getList("response.settings.findAll {it.name.startsWith(\"test_fileconfig\")}.id"); return fileConfigList.get(0); } @AfterEach void deleteFileConfig() {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/linearized_read_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 07 20:08:59 UTC 2022 - 2.7K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/PerformanceTestResult.java
return channel; } public void setChannel(String channel) { this.channel = channel; } public String getHost() { return host; } public void setHost(String host) { this.host = host; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/LegacyRepositorySystemSessionExtender.java
org.eclipse.aether.repository.Proxy proxy = selector.getProxy(repo); if (proxy != null) { org.apache.maven.repository.Proxy p = new org.apache.maven.repository.Proxy(); p.setHost(proxy.getHost()); p.setProtocol(proxy.getType()); p.setPort(proxy.getPort()); if (proxy.getAuthentication() != null) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util.go
} emptyList := newListFunc() pred := SelectionPredicate{ Label: labels.Everything(), Field: fields.Everything(), Limit: 1, // just in case we actually hit something } err := storage.GetList(ctx, resourcePrefix, ListOptions{Predicate: pred}, emptyList) if err != nil { return 0, err } emptyListAccessor, err := meta.ListAccessor(emptyList) if err != nil { return 0, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:05:06 UTC 2024 - 4.6K bytes - Viewed (0)