Method AddTimeRange

runtime/metricsview/ast.go:738–760

AddTimeRange adds a time range to the given SelectNode's WHERE clause.

(n *SelectNode, tr *TimeRange)

// AddTimeRange adds a time range to the given SelectNode's WHERE clause.
func (a *AST) AddTimeRange(n *SelectNode, tr *TimeRange) error {
	if tr == nil || tr.IsZero() || (a.MetricsView.TimeDimension == "" && tr.TimeDimension == "") {
		return nil
	}

	// Since resolving time ranges may require contextual info (like watermarks), the upstream caller is responsible for resolving them.
	if tr.Start.IsZero() && tr.End.IsZero() {
		panic("ast received a non-empty, unresolved time range")
	}

	timeDimExpr, typeCode, err := a.getTimeDimensionExpression(tr)
	if err != nil {
		return err
	}

	expr, args := a.sqlForTimeRange(timeDimExpr, typeCode, tr.Start, tr.End)
	n.TimeWhere = &ExprNode{
		Expr: expr,
		Args: args,
	}

	return nil
}

// AddMeasureField adds a measure field to the given SelectNode.
// Depending on the measure type, it may rewrite the SelectNode to accommodate the measure.