| 116 | } |
| 117 | |
| 118 | type userIndexScanner struct { |
| 119 | bkt objstore.InstrumentedBucket |
| 120 | logger log.Logger |
| 121 | baseScanner Scanner |
| 122 | |
| 123 | // Maximum period of time to consider the user index as stale. |
| 124 | maxStalePeriod time.Duration |
| 125 | |
| 126 | fallbackScans *prometheus.CounterVec |
| 127 | succeededScans prometheus.Counter |
| 128 | userIndexUpdateDelay prometheus.Gauge |
| 129 | } |
| 130 | |
| 131 | func newUserIndexScanner(baseScanner Scanner, cfg UsersScannerConfig, bkt objstore.InstrumentedBucket, logger log.Logger, reg prometheus.Registerer) *userIndexScanner { |
| 132 | return &userIndexScanner{ |
nothing calls this directly
no outgoing calls
no test coverage detected