Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for makeTestPodDetails (0.28 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go

    		},
    	})
    	defer store.Stop()
    	// In background, update the store.
    	go func() {
    		store.Add(makeTestPodDetails("pod1", 2, "node1", map[string]string{"label": "value1"}))
    		store.Add(makeTestPodDetails("pod2", 3, "node1", map[string]string{"label": "value1"}))
    		store.Add(makeTestPodDetails("pod3", 5, "node2", map[string]string{"label": "value2"}))
    	}()
    
    	// list by empty MatchValues.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    						Reason:  metav1.StatusReasonTimeout,
    						Code:    504,
    					},
    				},
    			}, true)
    
    			go func(t *testing.T) {
    				err := cacher.watchCache.Add(makeTestPodDetails("pod1", 105, "node1", map[string]string{"label": "value1"}))
    				require.NoError(t, err, "failed adding a pod to the watchCache")
    			}(t)
    			w, err = cacher.Watch(context.Background(), "pods/ns", scenario.opts)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
Back to top