Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 204 for setDist (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. staging/src/k8s.io/apiserver/pkg/storage/etcd3/linearized_read_test.go

    			t.Fatalf("failed to get key: %v", err)
    		}
    	}
    
    	list := &example.PodList{}
    	if err := store.GetList(ctx, dir, storage.ListOptions{Predicate: storage.Everything, Recursive: true}, list); err != nil {
    		t.Errorf("Unexpected List error: %v", err)
    	}
    	finalRevision := list.ResourceVersion
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 07 20:08:59 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top