Enable Lint Rules: bare-return & empty-lines (#5512)

## Which problem is this PR solving?
-  Partial Fix for #5506

## Description of the changes
- Enabled bare-return in revive linter. 
- Removed naked returns.
- Enabled empty-lines in revive linter.

## How was this change tested?
- `make lint` `make test`

## Checklist
- [x] I have read
https://github.com/jaegertracing/jaeger/blob/master/CONTRIBUTING_GUIDELINES.md
- [x] I have signed all commits
- [ ] I have added unit tests for the new functionality
- [x] I have run lint and test steps successfully
  - for `jaeger`: `make lint test`
  - for `jaeger-ui`: `yarn lint` and `yarn test`

---------

Signed-off-by: FlamingSaint <[email protected]>

.golangci.yml

@@ -213,12 +213,6 @@ linters-settings:
         # enable after cleanup
         - name: early-return
           disabled: true
-        # enable after cleanup
-        - name: bare-return
-          disabled: true
-        # enable after cleanup
-        - name: empty-lines
-          disabled: true
         # investigate, could be real bugs. But didn't recent Go version changed loop variables semantics?
         - name: range-val-address
           disabled: true

cmd/collector/app/collector.go

@@ -154,7 +154,6 @@ func (c *Collector) Start(options *flags.CollectorOptions) error {
 			return fmt.Errorf("could not start Zipkin receiver: %w", err)
 		}
 		c.zipkinReceiver = zipkinReceiver
-
 	}
 
 	if options.OTLP.Enabled {

cmd/query/app/server.go

@@ -205,7 +205,6 @@ func createHTTPServer(
 			return nil, err
 		}
 		server.TLSConfig = tlsCfg
-
 	}
 
 	server.staticHandlerCloser = RegisterStaticHandler(r, logger, queryOpts, querySvc.GetCapabilities())

cmd/query/app/server_test.go

@@ -382,9 +382,7 @@ func TestServerHTTPTLS(t *testing.T) {
 				if conn != nil {
 					clientClose = conn.Close
 				}
-
 			} else {
-
 				conn, err1 := net.DialTimeout("tcp", "localhost:"+fmt.Sprintf("%d", ports.QueryHTTP), 2*time.Second)
 				clientError = err1
 				clientClose = nil

pkg/fswatcher/fswatcher_test.go

@@ -47,7 +47,7 @@ func createTestFiles(t *testing.T) (file1 string, file2 string, file3 string) {
 	err = os.WriteFile(file3, []byte("test data"), 0o600)
 	require.NoError(t, err)
 
-	return
+	return file1, file2, file3
 }
 
 func TestFSWatcherAddFiles(t *testing.T) {

pkg/gzipfs/gzip.go

@@ -50,17 +50,17 @@ func (f file) Stat() (fs.FileInfo, error) {
 	}, nil
 }
 
-func (f *file) Read(buf []byte) (n int, err error) {
+func (f *file) Read(buf []byte) (int, error) {
 	if len(buf) > len(f.content)-f.offset {
 		buf = buf[0:len(f.content[f.offset:])]
 	}
 
-	n = copy(buf, f.content[f.offset:])
+	n := copy(buf, f.content[f.offset:])
 	if n == len(f.content)-f.offset {
 		return n, io.EOF
 	}
 	f.offset += n
-	return
+	return n, nil
 }
 
 func (f file) Close() error {

pkg/httpmetrics/metrics.go

@@ -149,5 +149,5 @@ func (r *requestDurations) buildTimer(metricsFactory metrics.Factory, key record
 			"method": key.method,
 		},
 	})
-	return
+	return out
 }

pkg/kafka/auth/plaintext.go

@@ -42,9 +42,8 @@ func (x *scramClient) Begin(userName, password, authzID string) (err error) {
 
 // Step steps client through the SCRAM exchange. It is
 // called repeatedly until it errors or `Done` returns true.
-func (x *scramClient) Step(challenge string) (response string, err error) {
-	response, err = x.ClientConversation.Step(challenge)
-	return
+func (x *scramClient) Step(challenge string) (string, error) {
+	return x.ClientConversation.Step(challenge)
 }
 
 // Done should return true when the SCRAM conversation
@@ -84,7 +83,6 @@ func setPlainTextConfiguration(config *PlainTextConfig, saramaConfig *sarama.Con
 
 	default:
 		return fmt.Errorf("config plaintext.mechanism error: %s, only support 'SCRAM-SHA-256' or 'SCRAM-SHA-512' or 'PLAIN'", config.Mechanism)
-
 	}
 	return nil
 }

plugin/sampling/strategystore/static/strategy_store.go

@@ -278,7 +278,6 @@ func (h *strategyStore) parseStrategies(strategies *strategies) {
 
 		opS := newStore.serviceStrategies[s.Service].OperationSampling
 		if opS == nil {
-
 			// Service does not have its own per-operation rules, so copy (by value) from the default strategy.
 			newOpS := *newStore.defaultStrategy.OperationSampling
 

plugin/storage/badger/spanstore/reader.go

@@ -280,7 +280,6 @@ func serviceQueries(query *spanstore.TraceQueryParameters, indexSeeks [][]byte)
 		} else if !tagQueryUsed { // Tag query already reduces the search set with a serviceName
 			indexSearchKey = append(indexSearchKey, serviceNameIndexKey)
 			indexSearchKey = append(indexSearchKey, []byte(query.ServiceName)...)
-
 		}
 
 		if len(indexSearchKey) > 0 {

plugin/storage/cassandra/spanstore/reader_test.go

@@ -402,7 +402,6 @@ func TestSpanReaderFindTraces(t *testing.T) {
 				if testCase.queryDuration {
 					queryParams.DurationMin = time.Minute
 					queryParams.DurationMax = time.Minute * 3
-
 				}
 				res, err := r.reader.FindTraces(context.Background(), queryParams)
 				if testCase.expectedError == "" {

plugin/storage/memory/memory.go

@@ -187,7 +187,6 @@ func (st *Store) WriteSpan(ctx context.Context, span *model.Span) error {
 			// update the ring with the trace id
 			m.ids[m.index] = &span.TraceID
 		}
-
 	}
 	m.traces[span.TraceID].Spans = append(m.traces[span.TraceID].Spans, span)