Function newCachedScanner

pkg/util/users/cache.go:26–39

(scanner Scanner, cfg UsersScannerConfig, reg prometheus.Registerer)

}

func newCachedScanner(scanner Scanner, cfg UsersScannerConfig, reg prometheus.Registerer) *cachedScanner {
	return &cachedScanner{
		scanner: scanner,
		ttl:     cfg.CacheTTL,
		requests: promauto.With(reg).NewCounter(prometheus.CounterOpts{
			Name: "cortex_cached_users_scanner_requests_total",
			Help: "Total number of scans made to the cache scanner",
		}),
		hits: promauto.With(reg).NewCounter(prometheus.CounterOpts{
			Name: "cortex_cached_users_scanner_hits_total",
			Help: "Total number of hits of scanner cache",
		}),
	}
}

func (s *cachedScanner) ScanUsers(ctx context.Context) ([]string, []string, []string, error) {
	s.requests.Inc()