chore: move some functions around

grafana · Aug 1, 2024 · 7d98cb0 · 7d98cb0
1 parent 06269b0
commit 7d98cb0
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 18 deletions.
diff --git a/pkg/distributor/validator.go b/pkg/distributor/validator.go
@@ -169,6 +169,7 @@ func (v Validator) ValidateLabels(ctx validationContext, ls labels.Labels, strea
 	if ls.Has(push.LabelServiceName) {
 		numLabelNames--
 	}
+
 	if numLabelNames > ctx.maxLabelNamesPerSeries {
 		updateMetrics(validation.MaxLabelNamesPerSeries, ctx.userID, stream)
 		return fmt.Errorf(validation.MaxLabelNamesPerSeriesErrorMsg, stream.Labels, numLabelNames, ctx.maxLabelNamesPerSeries)

diff --git a/pkg/pattern/flush.go b/pkg/pattern/flush.go
@@ -73,21 +73,3 @@ func (i *Ingester) sweepInstance(instance *instance, _, mayRemoveStreams bool) {
 		return true, nil
 	})
 }
-
-func (i *Ingester) stopWriters() {
-	instances := i.getInstances()
-
-	for _, instance := range instances {
-		if instance.writer != nil {
-			instance.writer.Stop()
-		}
-	}
-}
-
-func (i *Ingester) downsampleMetrics(ts model.Time) {
-	instances := i.getInstances()
-
-	for _, instance := range instances {
-		instance.Downsample(ts)
-	}
-}
diff --git a/pkg/pattern/ingester.go b/pkg/pattern/ingester.go
@@ -363,3 +363,21 @@ func (i *Ingester) getInstances() []*instance {
 	}
 	return instances
 }
+
+func (i *Ingester) stopWriters() {
+	instances := i.getInstances()
+
+	for _, instance := range instances {
+		if instance.writer != nil {
+			instance.writer.Stop()
+		}
+	}
+}
+
+func (i *Ingester) downsampleMetrics(ts model.Time) {
+	instances := i.getInstances()
+
+	for _, instance := range instances {
+		instance.Downsample(ts)
+	}
+}