Method ScanUsers

pkg/util/users/scanner.go:152–177

(ctx context.Context)

}

func (s *userIndexScanner) ScanUsers(ctx context.Context) ([]string, []string, []string, error) {
	userIndex, err := ReadUserIndex(ctx, s.bkt, s.logger)
	if err != nil {
		if errors.Is(err, ErrIndexNotFound) {
			level.Info(s.logger).Log("msg", "user index not found, fallback to base scanner")
			s.fallbackScans.WithLabelValues("not-found").Inc()
		} else if !errors.Is(err, context.Canceled) {
			// Always fallback to the list scanner if failed to read the user index.
			level.Error(s.logger).Log("msg", "failed to read user index, fallback to base scanner", "error", err)
			s.fallbackScans.WithLabelValues("corrupted").Inc()
		}
		return s.baseScanner.ScanUsers(ctx)
	}

	now := time.Now()
	updatedAt := userIndex.GetUpdatedAt()
	s.userIndexUpdateDelay.Set(time.Since(updatedAt).Seconds())
	if updatedAt.Before(now.Add(-s.maxStalePeriod)) {
		level.Warn(s.logger).Log("msg", "user index is stale, fallback to base scanner", "updated_at", userIndex.GetUpdatedAt(), "max_stale_period", s.maxStalePeriod)
		s.fallbackScans.WithLabelValues("too_old").Inc()
		return s.baseScanner.ScanUsers(ctx)
	}

	s.succeededScans.Inc()
	return userIndex.ActiveUsers, userIndex.DeletingUsers, userIndex.DeletedUsers, nil
}

// shardedScanner is a user scanner but applies a filter to the users to check ownership.
type shardedScanner struct {