- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 73 for PVCs (0.34 sec)
-
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/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/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/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) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go
rbacv1helpers.NewRule("get", "list", "watch", "create", "delete").Groups(legacyGroup).Resources("persistentvolumes").RuleOrDie(), // update is needed in addition to read access for setting lock annotations on PVCs rbacv1helpers.NewRule("get", "list", "watch", "update").Groups(legacyGroup).Resources("persistentvolumeclaims").RuleOrDie(), rbacv1helpers.NewRule(Read...).Groups(storageGroup).Resources("storageclasses").RuleOrDie(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 34.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
} if monotonic { // if the set does not allow bursting, return immediately return true, nil } } // If the Pod is in pending state then trigger PVC creation to create missing PVCs if isPending(replicas[i]) { logger.V(4).Info( "StatefulSet is triggering PVC creation for pending Pod", "statefulSet", klog.KObj(set), "pod", klog.KObj(replicas[i]))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0)