Method doQuery

edgraph/server.go:1396–1564

(ctx context.Context, req *Request)

}

func (s *Server) doQuery(ctx context.Context, req *Request) (resp *api.Response, rerr error) {
	if ctx.Err() != nil {
		return nil, ctx.Err()
	}
	defer atomic.AddInt64(&pendingQueries, -1)
	if val := atomic.AddInt64(&pendingQueries, 1); val > maxPendingQueries {
		return nil, serverOverloadErr
	}

	isGraphQL, _ := ctx.Value(IsGraphql).(bool)
	if isGraphQL {
		atomic.AddUint64(&numGraphQL, 1)
	} else {
		atomic.AddUint64(&numDQL, 1)
	}
	l := &query.Latency{}
	l.Start = time.Now()

	isMutation := len(req.req.Mutations) > 0
	methodRequest := methodQuery
	if isMutation {
		methodRequest = methodMutate
	}

	var measurements []ostats.Measurement
	ctx, span := otel.Tracer("").Start(ctx, methodRequest)
	if ns, err := x.ExtractNamespace(ctx); err == nil {
		annotateNamespace(span, ns)
	}

	if bool(glog.V(3)) || worker.LogDQLRequestEnabled() {
		traceID := ""
		if span.SpanContext().IsValid() {
			traceID = fmt.Sprintf(" [trace_id=%s]", span.SpanContext().TraceID().String())
		}
		glog.Infof("Got a query, DQL form: %+v %+v at %+v%s",
			req.req.Query, req.req.Mutations, l.Start.Format(time.RFC3339), traceID)
	}

	ctx = x.WithMethod(ctx, methodRequest)
	defer func() {
		span.End()
		v := x.TagValueStatusOK
		if rerr != nil {
			v = x.TagValueStatusError
		}
		ctx, _ = tag.New(ctx, tag.Upsert(x.KeyStatus, v))
		timeSpentMs := x.SinceMs(l.Start)
		measurements = append(measurements, x.LatencyMs.M(timeSpentMs))
		ostats.Record(ctx, measurements...)

		// Log slow queries with structured fields for observability
		if x.WorkerConfig.SlowQueryLogThreshold > 0 {
			x.LogSlowOperation(ctx, "query", "dql", req.req.Query, &x.SlowOperationLatency{
				Start:      l.Start,
				Parsing:    l.Parsing,
				Processing: l.Processing,
				Encoding:   l.Json,