mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
allow retroactive storage class assignment in pv controller
This commit is contained in:
parent
42b24b7baf
commit
a0a5aa3680
@ -350,6 +350,14 @@ func (ctrl *PersistentVolumeController) syncUnboundClaim(ctx context.Context, cl
|
||||
klog.V(4).Infof("synchronizing unbound PersistentVolumeClaim[%s]: no volume found", claimToClaimKey(claim))
|
||||
// No PV could be found
|
||||
// OBSERVATION: pvc is "Pending", will retry
|
||||
|
||||
if utilfeature.DefaultFeatureGate.Enabled(features.RetroactiveDefaultStorageClass) {
|
||||
klog.V(4).Infof("FeatureGate[%s] is enabled, attempting to assign storage class to unbound PersistentVolumeClaim[%s]", features.RetroactiveDefaultStorageClass, claimToClaimKey(claim))
|
||||
if claim, err = ctrl.assignDefaultStorageClass(claim); err != nil {
|
||||
return fmt.Errorf("can't update PersistentVolumeClaim[%q]: %w", claimToClaimKey(claim), err)
|
||||
}
|
||||
}
|
||||
|
||||
switch {
|
||||
case delayBinding && !storagehelpers.IsDelayBindingProvisioning(claim):
|
||||
if err = ctrl.emitEventForUnboundDelayBindingClaim(claim); err != nil {
|
||||
@ -918,6 +926,35 @@ func (ctrl *PersistentVolumeController) updateVolumePhaseWithEvent(volume *v1.Pe
|
||||
return newVol, nil
|
||||
}
|
||||
|
||||
// assignDefaultStorageClass updates the claim storage class if there is any, the claim is updated to the API server.
|
||||
// Ignores claims that already have a storage class.
|
||||
// TODO: if resync is ever changed to a larger period, we might need to change how we set the default class on existing unbound claims
|
||||
func (ctrl *PersistentVolumeController) assignDefaultStorageClass(claim *v1.PersistentVolumeClaim) (*v1.PersistentVolumeClaim, error) {
|
||||
if claim.Spec.StorageClassName != nil {
|
||||
return claim, nil
|
||||
}
|
||||
|
||||
class, err := util.GetDefaultClass(ctrl.classLister)
|
||||
if err != nil {
|
||||
// It is safe to ignore errors here because it means we either could not list SCs or there is more than one default.
|
||||
// TODO: do not ignore errors after this PR is merged: https://github.com/kubernetes/kubernetes/pull/110559
|
||||
klog.V(4).Infof("failed to get default storage class: %v", err)
|
||||
return claim, nil
|
||||
} else if class == nil {
|
||||
klog.V(4).Infof("can not assign storage class to PersistentVolumeClaim[%s]: default storage class not found", claimToClaimKey(claim))
|
||||
return claim, nil
|
||||
}
|
||||
|
||||
klog.V(4).Infof("assigning StorageClass[%s] to PersistentVolumeClaim[%s]", class.Name, claimToClaimKey(claim))
|
||||
claim.Spec.StorageClassName = &class.Name
|
||||
newClaim, err := ctrl.kubeClient.CoreV1().PersistentVolumeClaims(claim.GetNamespace()).Update(context.TODO(), claim, metav1.UpdateOptions{})
|
||||
if err != nil {
|
||||
return claim, err
|
||||
}
|
||||
|
||||
return newClaim, nil
|
||||
}
|
||||
|
||||
// bindVolumeToClaim modifies given volume to be bound to a claim and saves it to
|
||||
// API server. The claim is not modified in this method!
|
||||
func (ctrl *PersistentVolumeController) bindVolumeToClaim(volume *v1.PersistentVolume, claim *v1.PersistentVolumeClaim) (*v1.PersistentVolume, error) {
|
||||
|
Loading…
Reference in New Issue
Block a user