PR remarks

Signed-off-by: Kaviraj <[email protected]>
grafana · Feb 19, 2024 · 655844f · 655844f
1 parent e373341
commit 655844f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/pkg/logql/rangemapper.go b/pkg/logql/rangemapper.go
@@ -58,10 +58,11 @@ type RangeMapper struct {
 	metrics         *MapperMetrics
 	stats           *MapperStats
 
-	// SplitAlign
 	splitAlignTs time.Time
 }
 
+// NewRangeMapperWithSplitAlign is similar to `NewRangeMapper` except it accepts additonal `splitAlign` argument and used to
+// align the subqueries generated according to that. Look at `rangeSplitAlign` method for more information.
 func NewRangeMapperWithSplitAlign(interval time.Duration, splitAlign time.Time, metrics *MapperMetrics, stats *MapperStats) (RangeMapper, error) {
 	rm, err := NewRangeMapper(interval, metrics, stats)
 	if err != nil {

diff --git a/pkg/querier/queryrange/codec.go b/pkg/querier/queryrange/codec.go
@@ -109,7 +109,7 @@ func (r *LokiInstantRequest) GetStart() time.Time {
 
 func (r *LokiInstantRequest) WithStartEnd(s time.Time, _ time.Time) queryrangebase.Request {
 	clone := *r
-	clone.TimeTs = time.Unix(0, s.UnixNano())
+	clone.TimeTs = s
 	return &clone
 }