Fix some comments

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

clients/pkg/logentry/stages/pack_test.go

@@ -40,7 +40,7 @@ pipeline_stages:
         ingest_timestamp: true
 `
 
-// TestDropPipeline is used to verify we properly parse the yaml config and create a working pipeline
+// TestPackPipeline is used to verify we properly parse the yaml config and create a working pipeline
 func TestPackPipeline(t *testing.T) {
 	registry := prometheus.NewRegistry()
 	plName := "test_pipeline_deal_with_it_linter"

integration/client/client.go

@@ -177,7 +177,7 @@ func (c *Client) pushLogLine(line string, timestamp time.Time, structuredMetadat
 	return fmt.Errorf("request failed with status code %v: %s", res.StatusCode, buf)
 }
 
-// pushLogLine creates a new logline
+// pushOTLPLogLine creates a new logline
 func (c *Client) pushOTLPLogLine(line string, timestamp time.Time, logAttributes map[string]any) error {
 	apiEndpoint := fmt.Sprintf("%s/otlp/v1/logs", c.baseURL)
 

operator/internal/manifests/serviceaccount.go

@@ -7,7 +7,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
-// BuildRulerServiceAccount returns a k8s object for the LokiStack
+// BuildServiceAccount returns a k8s object for the LokiStack
 // serviceaccount.
 func BuildServiceAccount(opts Options) client.Object {
 	return &corev1.ServiceAccount{

pkg/bloomcompactor/retention_test.go

@@ -730,7 +730,7 @@ func putMetasForLastNDays(t *testing.T, schemaCfg storageconfig.SchemaConfig, bl
 	}
 }
 
-// getMetasForLastNDays returns groups of continuous metas for the last N days.
+// getGroupedMetasForLastNDays returns groups of continuous metas for the last N days.
 func getGroupedMetasForLastNDays(t *testing.T, bloomStore *bloomshipper.BloomStore, tenant string, start model.Time, days int) [][][]bloomshipper.Meta {
 	metasGrouped := make([][][]bloomshipper.Meta, 0)
 	currentGroup := make([][]bloomshipper.Meta, 0)

pkg/bloomgateway/client.go

@@ -229,7 +229,7 @@ func shuffleAddrs(addrs []string) []string {
 	return addrs
 }
 
-// FilterChunkRefs implements Client
+// FilterChunks implements Client
 func (c *GatewayClient) FilterChunks(ctx context.Context, tenant string, from, through model.Time, groups []*logproto.GroupedChunkRefs, plan plan.QueryPlan) ([]*logproto.GroupedChunkRefs, error) {
 	if !c.limits.BloomGatewayEnabled(tenant) {
 		return groups, nil