| 2380 | } |
| 2381 | |
| 2382 | func createUserStats(db *userTSDB, activeSeriesMetricsEnabled bool) UserStats { |
| 2383 | apiRate := db.ingestedAPISamples.Rate() |
| 2384 | ruleRate := db.ingestedRuleSamples.Rate() |
| 2385 | |
| 2386 | var activeSeries uint64 |
| 2387 | if activeSeriesMetricsEnabled { |
| 2388 | activeSeries = uint64(db.activeSeries.Active()) |
| 2389 | } |
| 2390 | |
| 2391 | return UserStats{ |
| 2392 | IngestionRate: apiRate + ruleRate, |
| 2393 | APIIngestionRate: apiRate, |
| 2394 | RuleIngestionRate: ruleRate, |
| 2395 | NumSeries: db.Head().NumSeries(), |
| 2396 | ActiveSeries: activeSeries, |
| 2397 | LoadedBlocks: uint64(len(db.Blocks())), |
| 2398 | } |
| 2399 | } |
| 2400 | |
| 2401 | const queryStreamBatchMessageSize = 1 * 1024 * 1024 |
| 2402 | |