reportBatch will report OOPK batch related stats to the query logger.
(isArchiveBatch bool)
| 232 | |
| 233 | // reportBatch will report OOPK batch related stats to the query logger. |
| 234 | func (qc *AQLQueryContext) reportBatch(isArchiveBatch bool) { |
| 235 | if qc.Debug { |
| 236 | batchType := "live batch" |
| 237 | if isArchiveBatch { |
| 238 | batchType = "archive batch" |
| 239 | } |
| 240 | stats := qc.OOPK.currentBatch.stats |
| 241 | utils.GetQueryLogger(). |
| 242 | With( |
| 243 | "timings", stats.timings, |
| 244 | "total", stats.totalTiming, |
| 245 | "batchID", stats.batchID, |
| 246 | "batchSize", stats.batchSize, |
| 247 | "batchType", batchType, |
| 248 | ).Infof("Query stats") |
| 249 | if isArchiveBatch { |
| 250 | qc.OOPK.ArchiveBatchStats.applyBatchStats(stats) |
| 251 | } else { |
| 252 | qc.OOPK.LiveBatchStats.applyBatchStats(stats) |
| 253 | } |
| 254 | } |
| 255 | } |
no test coverage detected