Function NewProvider

modules/cache/cache.go:29–67

NewProvider creates a new cache provider with the given config.

(cfg *Config, logger log.Logger)

// NewProvider creates a new cache provider with the given config.
func NewProvider(cfg *Config, logger log.Logger) (cache.Provider, error) {
	p := &provider{
		caches: map[cache.Role]cache.Cache{},
	}

	err := cfg.Validate()
	if err != nil {
		return nil, fmt.Errorf("invalid cache config: %w", err)
	}

	statMemcached.Set(0)
	statRedis.Set(0)

	for _, cacheCfg := range cfg.Caches {
		var c cache.Cache

		if cacheCfg.MemcachedConfig != nil {
			level.Info(logger).Log("msg", "configuring memcached client", "roles", cacheCfg.Name())

			statMemcached.Add(1)
			c = memcached.NewClient(cacheCfg.MemcachedConfig, cfg.Background, cacheCfg.Name(), logger)
		}

		if cacheCfg.RedisConfig != nil {
			level.Info(logger).Log("msg", "configuring redis client", "roles", cacheCfg.Name())

			statRedis.Add(1)
			c = redis.NewClient(cacheCfg.RedisConfig, cfg.Background, cacheCfg.Name(), logger)
		}

		// add this cache for all claimed roles
		for _, role := range cacheCfg.Role {
			p.caches[role] = c
		}
	}

	p.Service = services.NewIdleService(p.starting, p.stopping)
	return p, nil
}

// CacheFor is used to retrieve a cache for a given role.
func (p *provider) CacheFor(role cache.Role) cache.Cache {