- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for StatusManager (0.37 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) -
pkg/config/analysis/incluster/controller.go
analyzer *local.IstiodAnalyzer statusctl *status.Controller } func NewController(stop <-chan struct{}, rwConfigStore model.ConfigStoreController, kubeClient kube.Client, revision, namespace string, statusManager *status.Manager, domainSuffix string, ) (*Controller, error) { analyzer := analyzers.AllCombined() all := kuberesource.ConvertInputsToSchemas(analyzer.Metadata().Inputs)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// which pods are running. volumeManager volumemanager.VolumeManager // statusManager receives updated pod status updates from the podWorker and updates the API // status of those pods to match. The statusManager is authoritative for the synthesized // status of the pod from the kubelet's perspective (other components own the individual
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.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/kubelet_test.go
kl.HandlePodAdditions(pods) if _, found := kl.statusManager.GetPodStatus(podToTest.UID); !found { t.Fatalf("expected to have status cached for pod2") } // Sync with empty pods so that the entry in status map will be removed. kl.podManager.SetPods([]*v1.Pod{}) kl.HandlePodCleanups(ctx) if _, found := kl.statusManager.GetPodStatus(podToTest.UID); found {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K 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) -
pkg/kubelet/runonce_test.go
rootDirectory: filepath.Clean(basePath), podLogsDirectory: filepath.Join(basePath, "pod-logs"), recorder: &record.FakeRecorder{}, cadvisor: cadvisor, nodeLister: testNodeLister{}, statusManager: status.NewManager(nil, podManager, &statustest.FakePodDeletionSafetyProvider{}, podStartupLatencyTracker, basePath), mirrorPodClient: podtest.NewFakeMirrorClient(), podManager: podManager,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0)