Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for PodSync (0.15 sec)

  1. pkg/kubelet/pleg/generic_test.go

    	}
    }
    
    func TestRelisting(t *testing.T) {
    	testPleg := newTestGenericPLEG()
    	pleg, runtime := testPleg.pleg, testPleg.runtime
    	ch := pleg.Watch()
    	// The first relist should send a PodSync event to each pod.
    	runtime.AllPodList = []*containertest.FakePod{
    		{Pod: &kubecontainer.Pod{
    			ID: "1234",
    			Containers: []*kubecontainer.Container{
    				createTestContainer("c1", kubecontainer.ContainerStateExited),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  2. pkg/kubelet/status/status_manager.go

    // attempted for testing.
    func (m *manager) syncBatch(all bool) int {
    	type podSync struct {
    		podUID    types.UID
    		statusUID kubetypes.MirrorPodUID
    		status    versionedPodStatus
    	}
    
    	var updatedStatuses []podSync
    	podToMirror, mirrorToPod := m.podManager.GetUIDTranslations()
    	func() { // Critical section
    		m.podStatusesLock.RLock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
Back to top