(scanner Scanner, isOwned func(userID string) (bool, error), logger log.Logger)
| 45 | } |
| 46 | |
| 47 | func NewShardedScanner(scanner Scanner, isOwned func(userID string) (bool, error), logger log.Logger) Scanner { |
| 48 | return &shardedScanner{ |
| 49 | scanner: scanner, |
| 50 | isOwned: isOwned, |
| 51 | logger: logger, |
| 52 | } |
| 53 | } |
| 54 | |
| 55 | type listScanner struct { |
| 56 | bkt objstore.InstrumentedBucket |