More fixes

grafana · Jan 10, 2025 · c2b668e · c2b668e
1 parent 890104d
commit c2b668e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/modules/ingester/limiter.go b/modules/ingester/limiter.go
@@ -107,10 +107,10 @@ func (l *limiter) minNonZero(first, second int) int {
 
 type partitionLimiter struct {
 	limits overrides.Interface
-	ring   ring.PartitionRingWatcher
+	ring   *ring.PartitionRingWatcher
 }
 
-func NewPartitionLimiter(limits overrides.Interface, ring ring.PartitionRingWatcher) Limiter {
+func NewPartitionLimiter(limits overrides.Interface, ring *ring.PartitionRingWatcher) Limiter {
 	return &partitionLimiter{
 		limits: limits,
 		ring:   ring,

diff --git a/pkg/ingest/config.go b/pkg/ingest/config.go
@@ -17,11 +17,6 @@ import (
 )
 
 const (
-	consumeFromLastOffset = "last-offset"
-	consumeFromStart      = "start"
-	consumeFromEnd        = "end"
-	consumeFromTimestamp  = "timestamp"
-
 	// writerRequestTimeoutOverhead is the overhead applied by the Writer to every Kafka timeout.
 	// You can think about this overhead as an extra time for requests sitting in the client's buffer
 	// before being sent on the wire and the actual time it takes to send it over the network and