- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 288 for podutil (0.14 sec)
-
pkg/kubelet/secret/secret_manager.go
limitations under the License. */ package secret import ( "context" "fmt" "time" v1 "k8s.io/api/core/v1" clientset "k8s.io/client-go/kubernetes" podutil "k8s.io/kubernetes/pkg/api/v1/pod" corev1 "k8s.io/kubernetes/pkg/apis/core/v1" "k8s.io/kubernetes/pkg/kubelet/util/manager" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/volume/util/util.go
mounts = sets.New[string]() devices = sets.New[string]() seLinuxContainerContexts = make(map[string][]*v1.SELinuxOptions) podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(container *v1.Container, containerType podutil.ContainerType) bool { var seLinuxOptions *v1.SELinuxOptions if utilfeature.DefaultFeatureGate.Enabled(features.SELinuxMountReadWriteOncePod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/controller/daemon/update.go
case newPod != nil: // this pod is up to date, check its availability if !podutil.IsPodAvailable(newPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}) { // an unavailable new pod is counted against maxUnavailable numUnavailable++ } default: // this pod is old, it is an update candidate switch { case !podutil.IsPodAvailable(oldPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/kubelet/prober/worker.go
klog.V(3).InfoS("Pod is terminated, exiting probe worker", "pod", klog.KObj(w.pod), "phase", status.Phase) return false } c, ok := podutil.GetContainerStatus(status.ContainerStatuses, w.container.Name) if !ok || len(c.ContainerID) == 0 { c, ok = podutil.GetContainerStatus(status.InitContainerStatuses, w.container.Name) if !ok || len(c.ContainerID) == 0 {
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/cm/helpers_linux.go
} out = append(out, pid) } } return out, nil } // GetPodCgroupNameSuffix returns the last element of the pod CgroupName identifier func GetPodCgroupNameSuffix(podUID types.UID) string { return podCgroupNamePrefix + string(podUID) } // NodeAllocatableRoot returns the literal cgroup path for the node allocatable cgroup func NodeAllocatableRoot(cgroupRoot string, cgroupsPerQOS bool, cgroupDriver string) string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 11:52:28 UTC 2023 - 9.8K bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
if pod.DeletionTimestamp != nil { continue } if podutil.IsPodReady(pod) == ready { continue } if !fn(pod) { continue } condition := v1.PodCondition{Type: v1.PodReady} if ready { condition.Status = v1.ConditionTrue } else { condition.Status = v1.ConditionFalse } if !podutil.UpdatePodCondition(&pod.Status, &condition) { t.Fatal("failed to update pod")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission.go
} hasSecrets := false podutil.VisitPodSecretNames(pod, func(name string) (shouldContinue bool) { hasSecrets = true; return false }, podutil.AllContainers) if hasSecrets { return admission.NewForbidden(a, fmt.Errorf("node %q can not create pods that reference secrets", nodeName)) } hasConfigMaps := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
if ds == nil { return } logger.V(4).Info("Pod updated", "pod", klog.KObj(curPod)) dsc.enqueueDaemonSet(ds) changedToReady := !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod) // See https://github.com/kubernetes/kubernetes/pull/38076 for more details if changedToReady && ds.Spec.MinReadySeconds > 0 { // Add a second to avoid milliseconds skew in AddAfter.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/serviceaccount/legacy_serviceaccount_token_cleaner.go
coreinformers "k8s.io/client-go/informers/core/v1" clientset "k8s.io/client-go/kubernetes" listersv1 "k8s.io/client-go/listers/core/v1" "k8s.io/client-go/tools/cache" "k8s.io/klog/v2" podutil "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/controlplane/controller/legacytokentracking" "k8s.io/kubernetes/pkg/serviceaccount" "k8s.io/utils/clock" ) const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 10K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction.go
"k8s.io/apiserver/pkg/util/feature" policyclient "k8s.io/client-go/kubernetes/typed/policy/v1" "k8s.io/client-go/util/retry" pdbhelper "k8s.io/component-helpers/apps/poddisruptionbudget" podutil "k8s.io/kubernetes/pkg/api/pod" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/apis/policy" "k8s.io/kubernetes/pkg/features" ) const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 11:58:48 UTC 2023 - 18.2K bytes - Viewed (0)