- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for numPods (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
if err != nil { t.Fatalf("Unexpected error: %v", err) } deletedPods := deleted.(*example.PodList) if len(deletedPods.Items) != numPods { t.Errorf("Unexpected number of pods deleted: %d, expected: %d", len(deletedPods.Items), numPods) } expectedCalls := (int64(numPods) + deleteCollectionPageSize - 1) / deleteCollectionPageSize if listCalls := atomic.LoadInt64(&storeWithCounter.listCounter); listCalls != expectedCalls {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
const numNodes = 50 const podsPerNode = 100 makeNodes := func() []*v1.Node { nodes := make([]*v1.Node, numNodes) // Node created long time ago, with status updated by kubelet exceeds grace period. // Expect pods status updated and Unknown node status posted from node controller for i := 0; i < numNodes; i++ { nodes[i] = &v1.Node{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
src/database/sql/sql_test.go
defer cancel() r, err := db.QueryContext(ctx, "SELECT|people|name|") if err != nil { t.Fatal(err) } numRows := 0 var sink byte for r.Next() { if mode == "top" && numRows == 2 { // cancel between Next and Scan is observed by Scan as err = context.Canceled. // The sleep here is only to make it more likely that the cancel will be observed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
}, Allocatable: v1.ResourceList{ v1.ResourcePods: resource.MustParse("100"), }, }, } } func addNodes(nodeStore cache.Store, startIndex, numNodes int, label map[string]string) { for i := startIndex; i < startIndex+numNodes; i++ { nodeStore.Add(newNode(fmt.Sprintf("node-%d", i), label)) } } func newPod(podName string, nodeName string, label map[string]string, ds *apps.DaemonSet) *v1.Pod {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
src/net/http/transport_test.go
func TestIssue3644(t *testing.T) { run(t, testIssue3644) } func testIssue3644(t *testing.T, mode testMode) { const numFoos = 5000 ts := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) { w.Header().Set("Connection", "close") for i := 0; i < numFoos; i++ { w.Write([]byte("foo ")) } })).ts c := ts.Client() res, err := c.Get(ts.URL) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0)