Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for fakePod1 (0.59 sec)

  1. pkg/kubelet/prober/scale_test.go

    			).(*manager)
    			defer cleanup(t, m)
    
    			now := time.Now()
    			fakePods := make([]*fakePod, numTestPods)
    			for i := 0; i < numTestPods; i++ {
    				fake, err := newFakePod(tt.http)
    				if err != nil {
    					t.Fatalf("unexpected error creating fake pod: %v", err)
    				}
    				defer fake.stop()
    				handler := fake.probeHandler()
    				fakePods[i] = fake
    
    				pod := v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 16:33:01 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  2. pkg/volume/csi/testing/testing.go

    		t.Fatalf("can't create temp dir: %v", err)
    	}
    
    	if client == nil {
    		client = fakeclient.NewSimpleClientset()
    	}
    
    	client.Tracker().Add(&v1.Node{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: "fakeNode",
    		},
    		Spec: v1.NodeSpec{},
    	})
    
    	// Start informer for CSIDrivers.
    	factory := informers.NewSharedInformerFactory(client, csi.CsiResyncPeriod)
    	csiDriverInformer := factory.Storage().V1().CSIDrivers()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 07 00:11:50 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  3. pkg/kubelet/container/runtime_cache_test.go

    	ctx := context.Background()
    	runtime := &ctest.FakeRuntime{}
    	cache := NewTestRuntimeCache(runtime)
    
    	// Cache old pods.
    	oldpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}}
    	runtime.PodList = oldpods
    	cache.UpdateCacheWithLock()
    
    	// Update the runtime to new pods.
    	newpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}, {Pod: &Pod{ID: "2222"}}, {Pod: &Pod{ID: "3333"}}}
    	runtime.PodList = newpods
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  4. pkg/kubelet/server/stats/volume_stat_calculator_test.go

    	volumes := map[string]volume.Volume{vol0: &fakeVolume{}, vol1: &fakeVolume{}, vol3: &fakeVolume{}}
    	mockStats.EXPECT().ListVolumesForPod(fakePod.UID).Return(volumes, true)
    	blockVolumes := map[string]volume.BlockVolume{vol2: &fakeBlockVolume{}}
    	mockStats.EXPECT().ListBlockVolumesForPod(fakePod.UID).Return(blockVolumes, true)
    
    	eventStore := make(chan string, 1)
    	fakeEventRecorder := record.FakeRecorder{
    		Events: eventStore,
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/policy_none_test.go

    func TestNonePolicyAllocate(t *testing.T) {
    	policy := &nonePolicy{}
    
    	st := &mockState{
    		assignments:   state.ContainerCPUAssignments{},
    		defaultCPUSet: cpuset.New(1, 2, 3, 4, 5, 6, 7),
    	}
    
    	testPod := makePod("fakePod", "fakeContainer", "1000m", "1000m")
    
    	container := &testPod.Spec.Containers[0]
    	err := policy.Allocate(st, testPod, container)
    	if err != nil {
    		t.Errorf("NonePolicy Allocate() error. expected no error but got: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  6. cni/pkg/plugin/plugin_dryrun_test.go

    	}
    }
    
    func buildFakeDryRunPod() *corev1.Pod {
    	app := corev1.Container{Name: "test"}
    	proxy := corev1.Container{Name: "istio-proxy"}
    	validate := corev1.Container{Name: "istio-validate"}
    	fakePod := &corev1.Pod{
    		TypeMeta: metav1.TypeMeta{
    			APIVersion: "core/v1",
    			Kind:       "Pod",
    		},
    		ObjectMeta: metav1.ObjectMeta{
    			Name:        testPodName,
    			Namespace:   testNSName,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Feb 10 00:31:55 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top