Function createTestLogicalPlan

pkg/api/queryapi/query_api_test.go:472–505

(t *testing.T, start, end int64, stepDuration int64)

}

func createTestLogicalPlan(t *testing.T, start, end int64, stepDuration int64) []byte {
	startTime, endTime := convertMsToTime(start), convertMsToTime(end)
	step := convertMsToDuration(stepDuration)

	qOpts := query.Options{
		Start:              startTime,
		End:                startTime,
		Step:               0,
		StepsBatch:         10,
		LookbackDelta:      0,
		EnablePerStepStats: false,
	}

	if step != 0 {
		qOpts.End = endTime
		qOpts.Step = step
	}

	// using a different metric name here so that we can check with debugger which query (from query string vs http request body)
	// is being executed by the queriers
	expr, err := parser.NewParser("up", parser.WithFunctions(parser.Functions)).ParseExpr()
	require.NoError(t, err)

	planOpts := logicalplan.PlanOptions{
		DisableDuplicateLabelCheck: false,
	}

	logicalPlan, err := logicalplan.NewFromAST(expr, &qOpts, planOpts)
	require.NoError(t, err)
	byteval, err := logicalplan.Marshal(logicalPlan.Root())
	require.NoError(t, err)

	return byteval
}