Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for CreateMirrorPod (0.46 sec)

  1. pkg/kubelet/pod/testing/fake_mirror_client.go

    	m := FakeMirrorClient{}
    	m.mirrorPods = sets.New[string]()
    	m.createCounts = make(map[string]int)
    	m.deleteCounts = make(map[string]int)
    	return &m
    }
    
    func (fmc *FakeMirrorClient) CreateMirrorPod(pod *v1.Pod) error {
    	fmc.mirrorPodLock.Lock()
    	defer fmc.mirrorPodLock.Unlock()
    	podFullName := kubecontainer.GetPodFullName(pod)
    	fmc.mirrorPods.Insert(podFullName)
    	fmc.createCounts[podFullName]++
    	return nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    			} else {
    				klog.V(4).InfoS("Creating a mirror pod for static pod", "pod", klog.KObj(pod))
    				if err := kl.mirrorPodClient.CreateMirrorPod(pod); err != nil {
    					klog.ErrorS(err, "Failed creating a mirror pod for", "pod", klog.KObj(pod))
    				}
    			}
    		}
    	}
    
    	// Make data directories for the pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top