| 176 | } |
| 177 | |
| 178 | type schedulerRequest struct { |
| 179 | frontendAddress string |
| 180 | userID string |
| 181 | queryID uint64 |
| 182 | request *httpgrpc.HTTPRequest |
| 183 | statsEnabled bool |
| 184 | |
| 185 | enqueueTime time.Time |
| 186 | |
| 187 | ctx context.Context |
| 188 | ctxCancel context.CancelFunc |
| 189 | queueSpan opentracing.Span |
| 190 | |
| 191 | // This is only used for testing. |
| 192 | parentSpanContext opentracing.SpanContext |
| 193 | |
| 194 | // fragment represents a portion of the query plan. |
| 195 | // In distributed execution mode, contains a specific plan segment. |
| 196 | // In non-distributed mode, only marks the query as root fragment. |
| 197 | fragment plan_fragments.Fragment |
| 198 | } |
| 199 | |
| 200 | func (s schedulerRequest) Priority() int64 { |
| 201 | priority, ok := stats.FromContext(s.ctx).LoadPriority() |
nothing calls this directly
no outgoing calls
no test coverage detected