(ctx context.Context)
| 3356 | } |
| 3357 | |
| 3358 | func (i *Ingester) expirePostingsCache(ctx context.Context) error { |
| 3359 | for _, userID := range i.getTSDBUsers() { |
| 3360 | if ctx.Err() != nil { |
| 3361 | return nil |
| 3362 | } |
| 3363 | userDB, err := i.getTSDB(userID) |
| 3364 | if err != nil || userDB == nil || userDB.postingCache == nil { |
| 3365 | continue |
| 3366 | } |
| 3367 | userDB.postingCache.PurgeExpiredItems() |
| 3368 | } |
| 3369 | |
| 3370 | return nil |
| 3371 | } |
| 3372 | |
| 3373 | func (i *Ingester) closeAndDeleteUserTSDBIfIdle(userID string) tsdbCloseCheckResult { |
| 3374 | userDB, err := i.getTSDB(userID) |