Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SetContainerReadiness (0.28 sec)

  1. pkg/kubelet/status/testing/mock_pod_status_provider.go

    }
    
    // SetContainerReadiness mocks base method.
    func (m *MockManager) SetContainerReadiness(podUID types.UID, containerID container.ContainerID, ready bool) {
    	m.ctrl.T.Helper()
    	m.ctrl.Call(m, "SetContainerReadiness", podUID, containerID, ready)
    }
    
    // SetContainerReadiness indicates an expected call of SetContainerReadiness.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. pkg/kubelet/status/fake_status_manager.go

    }
    
    func (m *fakeManager) SetPodStatus(pod *v1.Pod, status v1.PodStatus) {
    	klog.InfoS("SetPodStatus()")
    	return
    }
    
    func (m *fakeManager) SetContainerReadiness(podUID types.UID, containerID kubecontainer.ContainerID, ready bool) {
    	klog.InfoS("SetContainerReadiness()")
    	return
    }
    
    func (m *fakeManager) SetContainerStartup(podUID types.UID, containerID kubecontainer.ContainerID, started bool) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 05:59:34 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager_test.go

    	t.Log("Setting unchanged readiness should do nothing.")
    	m.SetContainerReadiness(pod.UID, cID1, false)
    	verifyUpdates(t, m, 0)
    	status = expectPodStatus(t, m, pod)
    	verifyReadiness("unchanged", &status, false, false, false)
    
    	t.Log("Setting container readiness should generate update but not pod readiness.")
    	m.SetContainerReadiness(pod.UID, cID1, true)
    	verifyUpdates(t, m, 1)
    	status = expectPodStatus(t, m, pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  4. pkg/kubelet/status/status_manager.go

    	// SetPodStatus caches updates the cached status for the given pod, and triggers a status update.
    	SetPodStatus(pod *v1.Pod, status v1.PodStatus)
    
    	// SetContainerReadiness updates the cached container status with the given readiness, and
    	// triggers a status update.
    	SetContainerReadiness(podUID types.UID, containerID kubecontainer.ContainerID, ready bool)
    
    	// SetContainerStartup updates the cached container status with the given startup, and
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  5. pkg/kubelet/prober/prober_manager_test.go

    	update := <-m.readinessManager.Updates()
    	// This code corresponds to an extract from kubelet.syncLoopIteration()
    	ready := update.Result == results.Success
    	m.statusManager.SetContainerReadiness(update.PodUID, update.ContainerID, ready)
    }
    
    func TestUpdateReadiness(t *testing.T) {
    	testPod := getTestPod()
    	setTestProbe(testPod, readiness, v1.Probe{})
    	m := newTestManager()
    	defer cleanup(t, m)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet.go

    			handleProbeSync(kl, update, handler, "liveness", "unhealthy")
    		}
    	case update := <-kl.readinessManager.Updates():
    		ready := update.Result == proberesults.Success
    		kl.statusManager.SetContainerReadiness(update.PodUID, update.ContainerID, ready)
    
    		status := ""
    		if ready {
    			status = "ready"
    		}
    		handleProbeSync(kl, update, handler, "readiness", status)
    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