- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 377 for podB (0.04 sec)
-
pkg/config/analysis/analyzers/injection/injection-image.go
} } return true }) for ns, pods := range namespaceMismatchedPods { sort.Strings(pods) c.Report(gvk.Namespace, msg.NewPodsIstioProxyImageMismatchInNamespace(namespaceResources[ns], pods)) } } // GetIstioProxyImage retrieves the proxy image name defined in the sidecar injector // configuration.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
podMap[rs.UID] = []*v1.Pod{} } for _, pod := range pods { // Do not ignore inactive Pods because Recreate Deployments need to verify that no // Pods from older versions are running before spinning up new Pods. controllerRef := metav1.GetControllerOf(pod) if controllerRef == nil { continue } // Only append if we care about this UID. if _, ok := podMap[controllerRef.UID]; ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/scheduler/framework/types_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.Debug("Pod is now stopped... cleaning up.") if err := removePodFromHostNSIpset(pod, &s.hostsideProbeIPSet); err != nil { log.Errorf("failed to remove pod %s from host ipset, error was: %v", pod.Name, err) return err } log.Info("in pod mode - deleting pod from ztunnel")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
message string } simplePod := func() *v1.Pod { return &v1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "pod1", Namespace: "ns1", UID: types.UID("1")}, Spec: v1.PodSpec{ Containers: []v1.Container{ {Name: "container-1"}, }, }, } } withPhase := func(pod *v1.Pod, phase v1.PodPhase) *v1.Pod { pod.Status.Phase = phase return pod } staticPod := func() *v1.Pod {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/config/analysis/analyzers/sidecar/selector.go
"match at least one pod, and that there aren't multiple sidecar resources that select overlapping pods", Inputs: []config.GroupVersionKind{ gvk.Sidecar, gvk.Pod, gvk.Namespace, }, } } // Analyze implements Analyzer func (a *SelectorAnalyzer) Analyze(c analysis.Context) { podsToSidecars := make(map[resource.FullName][]*resource.Instance) pods := make(map[resource.FullName]*resource.Instance)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
return svc } // getPodLocality retrieves the locality for a pod. func (c *Controller) getPodLocality(pod *v1.Pod) string { // if pod has `istio-locality` label, skip below ops if len(pod.Labels[model.LocalityLabel]) > 0 { return model.GetLocalityLabel(pod.Labels[model.LocalityLabel]) } // NodeName is set by the scheduler after the pod is created
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/controller/podautoscaler/config/types.go
// might be skipped. HorizontalPodAutoscalerCPUInitializationPeriod metav1.Duration // HorizontalPodAutoscalerInitialReadinessDelay is period after pod start during which readiness // changes are treated as readiness being set for the first time. The only effect of this is that // HPA will disregard CPU samples from unready pods that had last readiness change during that
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 19 09:49:23 UTC 2024 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.Pod.pb
Shingo Omura <******@****.***> 1717022429 +0900
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/config/analysis/analyzers/gateway/gateway.go
portMapping := map[uint32]uint32{} // svc port -> svc targetPort mapping gwSelectorMatches := 0 // For pods selected by gw.Selector, find Services that select them and remember those ports gwSelector := klabels.SelectorFromSet(gw.Selector) c.ForEach(gvk.Pod, func(rPod *resource.Instance) bool { podLabels := klabels.Set(rPod.Metadata.Labels) if gwSelector.Matches(podLabels) { gwSelectorMatches++
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 08:48:06 UTC 2024 - 4.7K bytes - Viewed (0)