AllUserStats returns ingestion statistics for all users known to this ingester.
(_ context.Context, _ *client.UserStatsRequest)
| 2354 | |
| 2355 | // AllUserStats returns ingestion statistics for all users known to this ingester. |
| 2356 | func (i *Ingester) AllUserStats(_ context.Context, _ *client.UserStatsRequest) (*client.UsersStatsResponse, error) { |
| 2357 | if err := i.checkRunning(); err != nil { |
| 2358 | return nil, err |
| 2359 | } |
| 2360 | |
| 2361 | userStats := i.userStats() |
| 2362 | |
| 2363 | response := &client.UsersStatsResponse{ |
| 2364 | Stats: make([]*client.UserIDStatsResponse, 0, len(userStats)), |
| 2365 | } |
| 2366 | for _, userStat := range userStats { |
| 2367 | response.Stats = append(response.Stats, &client.UserIDStatsResponse{ |
| 2368 | UserId: userStat.UserID, |
| 2369 | Data: &client.UserStatsResponse{ |
| 2370 | IngestionRate: userStat.IngestionRate, |
| 2371 | NumSeries: userStat.NumSeries, |
| 2372 | ApiIngestionRate: userStat.APIIngestionRate, |
| 2373 | RuleIngestionRate: userStat.RuleIngestionRate, |
| 2374 | ActiveSeries: userStat.ActiveSeries, |
| 2375 | LoadedBlocks: userStat.LoadedBlocks, |
| 2376 | }, |
| 2377 | }) |
| 2378 | } |
| 2379 | return response, nil |
| 2380 | } |
| 2381 | |
| 2382 | func createUserStats(db *userTSDB, activeSeriesMetricsEnabled bool) UserStats { |
| 2383 | apiRate := db.ingestedAPISamples.Rate() |
nothing calls this directly
no test coverage detected