Skip to content

Commit 5eb1ef7

Browse files
Use klog.Info instead of Infof and User errors.New instead of fmt.Errorf
1 parent a6e5b55 commit 5eb1ef7

File tree

3 files changed

+8
-6
lines changed

3 files changed

+8
-6
lines changed

pkg/controller/controller.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,12 @@ package controller
1818

1919
import (
2020
"context"
21+
"errors"
2122
"fmt"
2223
"time"
2324

2425
"github.com/kubernetes-csi/external-resizer/pkg/features"
25-
"k8s.io/apimachinery/pkg/api/errors"
26+
apierrors "k8s.io/apimachinery/pkg/api/errors"
2627

2728
"github.com/kubernetes-csi/external-resizer/pkg/resizer"
2829
"github.com/kubernetes-csi/external-resizer/pkg/util"
@@ -460,7 +461,7 @@ func (ctrl *resizeController) resizePVC(pvc *v1.PersistentVolumeClaim, pv *v1.Pe
460461
// Record an event to indicate that resizer is not expanding the pvc
461462
msg := fmt.Sprintf("Unable to expand %s because CSI driver %s only supports offline expansion and volume is currently in-use", klog.KObj(pvc), ctrl.resizer.Name())
462463
ctrl.eventRecorder.Event(pvc, v1.EventTypeWarning, util.VolumeResizeFailed, msg)
463-
return fmt.Errorf(msg)
464+
return errors.New(msg)
464465
}
465466

466467
// Record an event to indicate that external resizer is resizing this volume.
@@ -481,7 +482,7 @@ func (ctrl *resizeController) resizePVC(pvc *v1.PersistentVolumeClaim, pv *v1.Pe
481482
return ctrl.markPVCResizeFinished(pvc, newSize)
482483
}()
483484

484-
if err != nil && !errors.IsConflict(err) /* ignore conflicts as they should be silently retried */ {
485+
if err != nil && !apierrors.IsConflict(err) /* ignore conflicts as they should be silently retried */ {
485486
// Record an event to indicate that resize operation is failed.
486487
ctrl.eventRecorder.Eventf(pvc, v1.EventTypeWarning, util.VolumeResizeFailed, err.Error())
487488
}

pkg/controller/expand_and_recover.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@ limitations under the License.
1717
package controller
1818

1919
import (
20+
"errors"
2021
"fmt"
2122

2223
"github.com/kubernetes-csi/external-resizer/pkg/util"
@@ -153,7 +154,7 @@ func (ctrl *resizeController) expandAndRecover(pvc *v1.PersistentVolumeClaim, pv
153154
if allocatedSize != nil && allocatedSize.Cmp(newSize) == 0 {
154155
if inSlowSet {
155156
msg := fmt.Sprintf("skipping volume expansion for pvc %s, because expansion previously failed with infeasible error", pvcKey)
156-
klog.V(4).Infof(msg)
157+
klog.V(4).Info(msg)
157158
delayRetryError := util.NewDelayRetryError(msg, ctrl.slowSet.TimeRemaining(pvcKey))
158159
return pvc, pv, delayRetryError, resizeNotCalled
159160
}
@@ -172,7 +173,7 @@ func (ctrl *resizeController) expandAndRecover(pvc *v1.PersistentVolumeClaim, pv
172173
// Record an event to indicate that resizer is not expanding the pvc
173174
msg := fmt.Sprintf("Unable to expand %s because CSI driver %s only supports offline expansion and volume is currently in-use", klog.KObj(pvc), ctrl.resizer.Name())
174175
ctrl.eventRecorder.Event(pvc, v1.EventTypeWarning, util.VolumeResizeFailed, msg)
175-
return pvc, pv, fmt.Errorf(msg), resizeNotCalled
176+
return pvc, pv, errors.New(msg), resizeNotCalled
176177
}
177178

178179
// Record an event to indicate that external resizer is resizing this volume.

pkg/modifycontroller/modify_volume.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ func (ctrl *modifyController) delayModificationIfRecentlyInfeasible(pvc *v1.Pers
186186

187187
if inSlowSet {
188188
msg := fmt.Sprintf("skipping volume modification for pvc %s, because modification previously failed with infeasible error", pvcKey)
189-
klog.V(4).Infof(msg)
189+
klog.V(4).Info(msg)
190190
delayRetryError := util.NewDelayRetryError(msg, ctrl.slowSet.TimeRemaining(pvcKey))
191191
return delayRetryError
192192
}

0 commit comments

Comments
 (0)