UserStats returns ingestion statistics for the current user.
(ctx context.Context, req *client.UserStatsRequest)
| 2302 | |
| 2303 | // UserStats returns ingestion statistics for the current user. |
| 2304 | func (i *Ingester) UserStats(ctx context.Context, req *client.UserStatsRequest) (*client.UserStatsResponse, error) { |
| 2305 | if err := i.checkRunning(); err != nil { |
| 2306 | return nil, err |
| 2307 | } |
| 2308 | |
| 2309 | userID, err := users.TenantID(ctx) |
| 2310 | if err != nil { |
| 2311 | return nil, err |
| 2312 | } |
| 2313 | |
| 2314 | db, err := i.getTSDB(userID) |
| 2315 | if err != nil || db == nil { |
| 2316 | return &client.UserStatsResponse{}, nil |
| 2317 | } |
| 2318 | |
| 2319 | userStat := createUserStats(db, i.cfg.ActiveSeriesMetricsEnabled) |
| 2320 | |
| 2321 | return &client.UserStatsResponse{ |
| 2322 | IngestionRate: userStat.IngestionRate, |
| 2323 | NumSeries: userStat.NumSeries, |
| 2324 | ApiIngestionRate: userStat.APIIngestionRate, |
| 2325 | RuleIngestionRate: userStat.RuleIngestionRate, |
| 2326 | ActiveSeries: userStat.ActiveSeries, |
| 2327 | LoadedBlocks: userStat.LoadedBlocks, |
| 2328 | }, nil |
| 2329 | } |
| 2330 | |
| 2331 | func (i *Ingester) userStats() []UserIDStats { |
| 2332 | i.stoppedMtx.RLock() |
nothing calls this directly
no test coverage detected