Skip to content

Commit b81e7a8

Browse files
josephwoodwardjosephwoodward
committed
fix: address gofmt linting violations
1 parent 4feea31 commit b81e7a8

File tree

10 files changed

+2
-33
lines changed

10 files changed

+2
-33
lines changed

‎internal/cli/blobl/cli.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ func run(c *cli.Context, opts *common.CLIOpts) error {
306306

307307
var mu sync.Mutex
308308

309-
for i := 0; i < t; i++ {
309+
for range t {
310310
eg.Go(func() error {
311311
execCache := newExecCache()
312312
for {

‎internal/component/input/async_preserver_test.go‎

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,6 @@ func TestAsyncPreserverNackThenClose(t *testing.T) {
183183
wg := sync.WaitGroup{}
184184

185185
wg.Go(func() {
186-
187186
select {
188187
case readerImpl.connChan <- nil:
189188
case <-ctx.Done():
@@ -254,7 +253,6 @@ func TestAsyncPreserverCloseThenAck(t *testing.T) {
254253
wg := sync.WaitGroup{}
255254

256255
wg.Go(func() {
257-
258256
select {
259257
case readerImpl.connChan <- nil:
260258
case <-ctx.Done():
@@ -325,7 +323,6 @@ func TestAsyncPreserverCloseThenNackThenAck(t *testing.T) {
325323
wg := sync.WaitGroup{}
326324

327325
wg.Go(func() {
328-
329326
select {
330327
case readerImpl.connChan <- nil:
331328
case <-ctx.Done():
@@ -401,7 +398,6 @@ func TestAsyncPreserverMutateThenNack(t *testing.T) {
401398
wg := sync.WaitGroup{}
402399

403400
wg.Go(func() {
404-
405401
select {
406402
case readerImpl.connChan <- nil:
407403
case <-ctx.Done():
@@ -488,7 +484,6 @@ func TestAsyncPreserverCloseViaConnectThenAck(t *testing.T) {
488484
wg := sync.WaitGroup{}
489485

490486
wg.Go(func() {
491-
492487
select {
493488
case readerImpl.connChan <- nil:
494489
case <-ctx.Done():

‎internal/impl/io/input_http_server_test.go‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1010,7 +1010,6 @@ http_server:
10101010

10111011
wg := sync.WaitGroup{}
10121012
wg.Go(func() {
1013-
10141013
req, err := http.NewRequest(http.MethodPost, server.URL+"/testpost", bytes.NewBufferString(input))
10151014
if err != nil {
10161015
t.Error(err)
@@ -1164,7 +1163,6 @@ http_server:
11641163

11651164
wg := sync.WaitGroup{}
11661165
wg.Go(func() {
1167-
11681166
hdr, body, err := createMultipart(input, "application/octet-stream")
11691167
require.NoError(t, err)
11701168

@@ -1233,7 +1231,6 @@ http_server:
12331231

12341232
wg := sync.WaitGroup{}
12351233
wg.Go(func() {
1236-
12371234
res, err := http.Post(
12381235
server.URL+"/testpost",
12391236
"application/octet-stream",

‎internal/impl/io/input_socket_server_test.go‎

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -269,7 +269,6 @@ socket_server:
269269

270270
_, cerr = conn.Write([]byte("baz\n"))
271271
require.NoError(t, cerr)
272-
273272
})
274273

275274
readNextMsg := func() (message.Batch, error) {
@@ -338,7 +337,6 @@ socket_server:
338337

339338
_, cerr = conn.Write([]byte("baz\n\n"))
340339
require.NoError(t, cerr)
341-
342340
})
343341

344342
readNextMsg := func() (message.Batch, error) {
@@ -401,7 +399,6 @@ socket_server:
401399

402400
_, cerr = conn.Write([]byte("baz\n@@"))
403401
require.NoError(t, cerr)
404-
405402
})
406403

407404
readNextMsg := func() (message.Batch, error) {
@@ -527,7 +524,6 @@ socket_server:
527524

528525
_, cerr = conn.Write([]byte("baz\n"))
529526
require.NoError(t, cerr)
530-
531527
})
532528

533529
readNextMsg := func() (message.Batch, error) {
@@ -594,7 +590,6 @@ socket_server:
594590

595591
_, cerr = conn.Write([]byte("baz\n"))
596592
require.NoError(t, cerr)
597-
598593
})
599594

600595
readNextMsg := func(reject bool) (message.Batch, error) {
@@ -711,7 +706,6 @@ socket_server:
711706

712707
_, cerr = conn.Write([]byte("baz\n"))
713708
require.NoError(t, cerr)
714-
715709
})
716710

717711
readNextMsg := func() (message.Batch, error) {
@@ -782,7 +776,6 @@ socket_server:
782776

783777
_, cerr = conn.Write([]byte("baz\n@@"))
784778
require.NoError(t, cerr)
785-
786779
})
787780

788781
readNextMsg := func() (message.Batch, error) {
@@ -925,7 +918,6 @@ socket_server:
925918

926919
_, cerr = conn.Write([]byte("baz\n"))
927920
require.NoError(t, cerr)
928-
929921
})
930922

931923
readNextMsg := func() (message.Batch, error) {
@@ -988,7 +980,6 @@ socket_server:
988980

989981
_, cerr = conn.Write([]byte("baz\n"))
990982
require.NoError(t, cerr)
991-
992983
})
993984

994985
readNextMsg := func(reject bool) (message.Batch, error) {
@@ -1097,7 +1088,6 @@ socket_server:
10971088

10981089
_, cerr = conn.Write([]byte("baz\n"))
10991090
require.NoError(t, cerr)
1100-
11011091
})
11021092

11031093
readNextMsg := func() (message.Batch, error) {
@@ -1164,7 +1154,6 @@ socket_server:
11641154

11651155
_, cerr = conn.Write([]byte("baz\n@@"))
11661156
require.NoError(t, cerr)
1167-
11681157
})
11691158

11701159
readNextMsg := func() (message.Batch, error) {
@@ -1303,7 +1292,6 @@ socket_server:
13031292

13041293
_, cerr = conn.Write([]byte("baz\n"))
13051294
require.NoError(t, cerr)
1306-
13071295
})
13081296

13091297
readNextMsg := func() (message.Batch, error) {
@@ -1371,7 +1359,6 @@ socket_server:
13711359

13721360
_, cerr = conn.Write([]byte("baz\n"))
13731361
require.NoError(t, cerr)
1374-
13751362
})
13761363

13771364
readNextMsg := func() (message.Batch, error) {
@@ -1438,7 +1425,6 @@ socket_server:
14381425

14391426
_, cerr = conn.Write([]byte("baz\n\n"))
14401427
require.NoError(t, cerr)
1441-
14421428
})
14431429

14441430
readNextMsg := func() (message.Batch, error) {
@@ -1500,7 +1486,6 @@ socket_server:
15001486

15011487
_, cerr = conn.Write([]byte("baz\n@@"))
15021488
require.NoError(t, cerr)
1503-
15041489
})
15051490

15061491
readNextMsg := func() (message.Batch, error) {
@@ -1624,7 +1609,6 @@ socket_server:
16241609

16251610
_, cerr = conn.Write([]byte("baz\n"))
16261611
require.NoError(t, cerr)
1627-
16281612
})
16291613

16301614
readNextMsg := func() (message.Batch, error) {
@@ -1690,7 +1674,6 @@ socket_server:
16901674

16911675
_, cerr := conn.Write([]byte("foo\n"))
16921676
require.NoError(t, cerr)
1693-
16941677
})
16951678

16961679
readNextMsg := func() (message.Batch, error) {

‎internal/impl/pure/output_switch_test.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -773,7 +773,6 @@ cases:
773773

774774
wg := sync.WaitGroup{}
775775
wg.Go(func() {
776-
777776
closed := 0
778777
bar := `{"foo":"bar"}`
779778
baz := `{"foo":"baz"}`

‎internal/impl/pure/processor_insert_part_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ insert_part:
3333
}
3434

3535
var parts [][]byte
36-
for k := 0; k < i; k++ {
36+
for range i {
3737
parts = append(parts, []byte("foo"))
3838
}
3939

‎public/service/input_auto_retry_batched_test.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,6 @@ func TestBatchAutoRetryClose(t *testing.T) {
109109
wg := sync.WaitGroup{}
110110

111111
wg.Go(func() {
112-
113112
err := pres.Connect(ctx)
114113
require.NoError(t, err)
115114

‎public/service/input_auto_retry_test.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,6 @@ func TestAutoRetryClose(t *testing.T) {
109109
wg := sync.WaitGroup{}
110110

111111
wg.Go(func() {
112-
113112
err := pres.Connect(ctx)
114113
require.NoError(t, err)
115114

‎public/service/input_force_timely_nacks_test.go‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,6 @@ func TestBatchTimelyNacksClose(t *testing.T) {
5252
wg := sync.WaitGroup{}
5353

5454
wg.Go(func() {
55-
5655
err := pres.Connect(ctx)
5756
require.NoError(t, err)
5857

‎public/service/stream_builder_test.go‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,6 @@ file:
8383

8484
wg := sync.WaitGroup{}
8585
wg.Go(func() {
86-
8786
ctx, done := context.WithTimeout(t.Context(), time.Second*10)
8887
defer done()
8988

@@ -132,7 +131,6 @@ file:
132131

133132
wg := sync.WaitGroup{}
134133
wg.Go(func() {
135-
136134
ctx, done := context.WithTimeout(t.Context(), time.Second*10)
137135
defer done()
138136

0 commit comments

Comments
 (0)