Function NewScanner

pkg/util/users/scanner.go:29–45

(cfg UsersScannerConfig, bkt objstore.InstrumentedBucket, logger log.Logger, reg prometheus.Registerer)

}

func NewScanner(cfg UsersScannerConfig, bkt objstore.InstrumentedBucket, logger log.Logger, reg prometheus.Registerer) (Scanner, error) {
	var scanner Scanner
	switch cfg.Strategy {
	case UserScanStrategyList:
		scanner = &listScanner{bkt: bkt}
	case UserScanStrategyUserIndex:
		scanner = newUserIndexScanner(&listScanner{bkt: bkt}, cfg, bkt, logger, reg)
	default:
		return nil, ErrInvalidUserScannerStrategy
	}

	if cfg.CacheTTL > 0 {
		scanner = newCachedScanner(scanner, cfg, reg)
	}

	return scanner, nil
}

func NewShardedScanner(scanner Scanner, isOwned func(userID string) (bool, error), logger log.Logger) Scanner {
	return &shardedScanner{