Function NewAdjustStartEndWare

modules/frontend/pipeline/async_adjust_start_end.go:37–46

NewAdjustStartEndWare creates middleware that adjusts the "end" parameter of incoming requests. It is assumed that all request pipelines it exists in expect a "start" and "end" parameter. Traditionally some of these endpoints supported no start/end parameter which simply meant "search all recent dat

(defStart time.Duration, endBuffer time.Duration, sendNanos bool)

//     This prevents queries from using "now" as an end time, which may hit incomplete data.
//   - sendNanos:  If true, times are encoded as Unix nanoseconds. Otherwise, Unix seconds are used.
func NewAdjustStartEndWare(defStart time.Duration, endBuffer time.Duration, sendNanos bool) AsyncMiddleware[combiner.PipelineResponse] {
	return AsyncMiddlewareFunc[combiner.PipelineResponse](func(next AsyncRoundTripper[combiner.PipelineResponse]) AsyncRoundTripper[combiner.PipelineResponse] {
		return &adjustStartEndWare{
			next:      next,
			defStart:  defStart,
			endBuffer: endBuffer,
			sendNanos: sendNanos,
		}
	})
}

func (c adjustStartEndWare) RoundTrip(req Request) (Responses[combiner.PipelineResponse], error) {
	var (