- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for StatusManager (0.55 sec)
-
pkg/kubelet/prober/worker_test.go
m.statusManager.SetPodStatus(w.pod, getTestRunningStatusWithStarted(false)) // livenessProbe fails, but is disabled m.prober.exec = fakeExecProber{probe.Failure, nil} msg := "Not started, probe failure, result success" expectContinue(t, w, w.doProbe(ctx), msg) expectResult(t, w, results.Success, msg) // setting started state m.statusManager.SetContainerStartup(w.pod.UID, w.containerID, true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 23:48:10 UTC 2023 - 16.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
s.kubeClient, args.Revision, args.Namespace, s.statusManager, args.RegistryOptions.KubeOptions.DomainSuffix) if err != nil { return } cont.Run(leaderStop) }).Run(stop) return nil }) return nil } func (s *Server) initStatusController(args *PilotArgs, writeStatus bool) { if s.statusManager == nil && writeStatus { s.initStatusManager(args) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
// NewManager creates a Manager for pod probing. func NewManager( statusManager status.Manager, livenessManager results.Manager, readinessManager results.Manager, startupManager results.Manager, runner kubecontainer.CommandRunner, recorder record.EventRecorder) Manager { prober := newProber(runner, recorder) return &manager{ statusManager: statusManager, prober: prober,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
default: return nil } } func (c *Controller) SetStatusWrite(enabled bool, statusManager *status.Manager) { if enabled && features.EnableGatewayAPIStatus && statusManager != nil { c.statusController.Store( statusManager.CreateGenericController(func(status any, context any) status.GenerationProvider { return &gatewayGeneration{context} }), ) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager_test.go
} func (m *manager) extractedReadinessHandling() { 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()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/kubelet/prober/worker.go
// associated with it which runs the probe loop until the container permanently terminates, or the // stop channel is closed. The worker uses the probe Manager's statusManager to get up-to-date // container IDs. type worker struct { // Channel for stopping the probe. stopCh chan struct{} // Channel for triggering the probe manually. manualTriggerCh chan struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 01:28:06 UTC 2023 - 10.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} func (s *Server) initStatusManager(_ *PilotArgs) { s.addStartFunc("status manager", func(stop <-chan struct{}) error { s.statusManager = status.NewManager(s.RWConfigStore) s.statusManager.Start(stop) return nil }) } func (s *Server) serveHTTP() error { // At this point we are ready - start Http Listener so that it can respond to readiness events.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
// a kubelet running without apiserver requires an additional // update of the static pod status. See #57106 for i, p := range pods { if kubelettypes.IsStaticPod(p) { if status, ok := kl.statusManager.GetPodStatus(p.UID); ok { klog.V(2).InfoS("Pod status updated", "pod", klog.KObj(p), "status", status.Phase) // do not mutate the cache p = p.DeepCopy() p.Status = status pods[i] = p }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0)