- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for StatusManager (0.14 sec)
-
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) -
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) -
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)