- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 77 for PVCs (0.04 sec)
-
plugin/pkg/admission/limitranger/admission.go
return PersistentVolumeClaimValidateLimitFunc(limitRange, obj.(*api.PersistentVolumeClaim)) } return nil } // SupportsAttributes ignores all calls that do not deal with pod resources or storage requests (PVCs). // Also ignores any call that has a subresource defined. func (d *DefaultLimitRangerActions) SupportsAttributes(a admission.Attributes) bool { if a.GetSubresource() != "" { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 13:04:39 UTC 2023 - 25.8K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
"k8s.io/kubernetes/pkg/controller/volume/common" ephemeralvolumemetrics "k8s.io/kubernetes/pkg/controller/volume/ephemeral/metrics" "k8s.io/kubernetes/pkg/controller/volume/events" ) // Controller creates PVCs for ephemeral inline volumes in a pod spec. type Controller interface { Run(ctx context.Context, workers int) } type ephemeralController struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/features/kube_features.go
// of code conflicts because changes are more likely to be scattered // across the file. // owner: @ttakahashi21 @mkimuram // kep: https://kep.k8s.io/3294 // alpha: v1.26 // // Enable usage of Provision of PVCs from snapshots in other namespaces CrossNamespaceVolumeDataSource featuregate.Feature = "CrossNamespaceVolumeDataSource" // owner: @thockin // deprecated: v1.29 //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0) -
pkg/scheduler/internal/cache/snapshot_test.go
{ Pods: []*framework.PodInfo{ {Pod: podWithPort}, }, }, }, expectedNumNodes: 1, }, { name: "multiple nodes, pods with PVCs", pods: podsWithPVCs, nodes: []*v1.Node{ {ObjectMeta: metav1.ObjectMeta{Name: "node-0"}}, {ObjectMeta: metav1.ObjectMeta{Name: "node-1"}}, {ObjectMeta: metav1.ObjectMeta{Name: "node-2"}}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 12K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
// deployment holds associated replicaSets for a deployment type deployment struct { replicaSets *appsv1.ReplicaSet deployment *appsv1.Deployment } // WaitForResources polls to get the current status of all pods, PVCs, and Services // until all are ready or a timeout is reached func WaitForResources(objects object.K8sObjects, client kube.Client, waitTimeout time.Duration, dryRun bool, l *progress.ManifestLog, ) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
logger := klog.FromContext(ctx) logger.V(4).Info("Resyncing PV controller") pvcs, err := ctrl.claimLister.List(labels.NewSelector()) if err != nil { logger.Info("Cannot list claims", "err", err) return } for _, pvc := range pvcs { ctrl.enqueueWork(ctx, ctrl.claimQueue, pvc) } pvs, err := ctrl.volumeLister.List(labels.NewSelector()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
if matchesRef(&ownerRef, set, controllerKind) { if ownerRef.UID != set.GetUID() { // A UID mismatch means that pods were incorrectly orphaned. Treating this as an unexpected // controller means we won't touch the PVCs (eg, leave it to the garbage collector to clean // up if appropriate). return true } continue // This is us. } if matchesRef(&ownerRef, pod, podKind) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
nodesSynced: nodeInformer.Informer().HasSynced, pvcQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "pvcs"}, ), } adc.csiNodeLister = csiNodeInformer.Lister() adc.csiNodeSynced = csiNodeInformer.Informer().HasSynced adc.csiDriverLister = csiDriverInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
// Generate event. No cloning is needed, this claim is not stored in the // controller cache yet. if r.fakeClaimWatch != nil { r.fakeClaimWatch.Add(claim) } } // AddClaims adds PVCs into VolumeReactor. func (r *VolumeReactor) AddClaims(claims []*v1.PersistentVolumeClaim) { r.lock.Lock() defer r.lock.Unlock() for _, claim := range claims { r.claims[claim.Name] = claim } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
fts := feature.Features{} tests := []struct { name string registerPlugins []tf.RegisterPluginFunc extenders []tf.FakeExtender nodes []string pvcs []v1.PersistentVolumeClaim pod *v1.Pod pods []*v1.Pod wantNodes sets.Set[string] wantEvaluatedNodes *int32 wErr error }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)