signoz/pkg/querier/list_range.go

package querier

import "github.com/SigNoz/signoz/pkg/querybuilder"

const hourNanos = int64(3_600_000_000_000) // 1 h in ns

type tsRange struct{ fromNS, toNS uint64 }

// slice the timerange into exponentially growing buckets
func makeBuckets(start, end uint64) []tsRange {
	startNS := querybuilder.ToNanoSecs(start)
	endNS := querybuilder.ToNanoSecs(end)

	if endNS-startNS <= uint64(hourNanos) {
		return []tsRange{{fromNS: startNS, toNS: endNS}}
	}

	var out []tsRange
	bucket := uint64(hourNanos)
	curEnd := endNS

	for {
		curStart := curEnd - bucket
		if curStart < startNS {
			curStart = startNS
		}
		out = append(out, tsRange{fromNS: curStart, toNS: curEnd})

		if curStart == startNS {
			break
		}
		curEnd = curStart
		bucket *= 2
	}
	return out
}