Skip to content

Commit 8ac2461

Browse files
author
Ariel Kass
committed
resolving more wsl_v5 linter issues
Signed-off-by: Ariel Kass <[email protected]>
1 parent 35329b0 commit 8ac2461

File tree

4 files changed

+6
-0
lines changed

4 files changed

+6
-0
lines changed

controllers/pvc_test.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,7 @@ func TestGetVolumeHandle(t *testing.T) {
172172
}
173173

174174
reconciler := createFakeVolumeReplicationReconciler(t, testPV, testPVC, volumeReplication)
175+
175176
resultPVC, resultPV, err := reconciler.getPVCDataSource(context.TODO(), reconciler.Log, namespacedName)
176177
if tc.errorExpected {
177178
require.Error(t, err)

controllers/volumereplication_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -465,6 +465,7 @@ func (r *VolumeReplicationReconciler) updateReplicationStatus(
465465
instance.Status.State = state
466466
instance.Status.Message = message
467467
instance.Status.ObservedGeneration = instance.Generation
468+
468469
err := r.Client.Status().Update(ctx, instance)
469470
if err != nil {
470471
logger.Error(err, "failed to update status")

pkg/client/client.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ func connect(address string, timeout time.Duration) (*grpc.ClientConn, error) {
4343
// New creates and returns the GRPC client.
4444
func New(address string, timeout time.Duration) (*Client, error) {
4545
client := &Client{}
46+
4647
conn, err := connect(address, timeout)
4748
if err != nil {
4849
return client, err

pkg/client/replication-client.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@ func (rc *replicationClient) EnableVolumeReplication(replicationSource *replicat
7070

7171
createCtx, cancel := context.WithTimeout(context.Background(), rc.timeout)
7272
defer cancel()
73+
7374
resp, err := rc.client.EnableVolumeReplication(createCtx, req)
7475

7576
return resp, err
@@ -88,6 +89,7 @@ func (rc *replicationClient) DisableVolumeReplication(replicationSource *replica
8889

8990
createCtx, cancel := context.WithTimeout(context.Background(), rc.timeout)
9091
defer cancel()
92+
9193
resp, err := rc.client.DisableVolumeReplication(createCtx, req)
9294

9395
return resp, err
@@ -144,6 +146,7 @@ func (rc *replicationClient) ResyncVolume(replicationSource *replicationlib.Repl
144146

145147
createCtx, cancel := context.WithTimeout(context.Background(), rc.timeout)
146148
defer cancel()
149+
147150
resp, err := rc.client.ResyncVolume(createCtx, req)
148151

149152
return resp, err

0 commit comments

Comments
 (0)