Skip to content
Snippets Groups Projects
Commit cba64561 authored by ensiouel's avatar ensiouel
Browse files

fix

parent 3f182d11
No related branches found
No related tags found
No related merge requests found
...@@ -77,7 +77,7 @@ func NewClient(conn *grpc.ClientConn, opts ...Option) *Content { ...@@ -77,7 +77,7 @@ func NewClient(conn *grpc.ClientConn, opts ...Option) *Content {
func WithCaching(client *Content, size int, ttl time.Duration) *Content { func WithCaching(client *Content, size int, ttl time.Duration) *Content {
c := *client c := *client
cacheMetrics := metrics.NewCacheMetrics(prometheus.DefaultRegisterer) cacheMetrics := metrics.NewCacheMetrics(prometheus.WrapRegistererWithPrefix("content_", prometheus.DefaultRegisterer))
c.Clients = clientsSvc.CachingMiddleware(cache.NewCache(size, ttl))(client.Clients) c.Clients = clientsSvc.CachingMiddleware(cache.NewCache(size, ttl))(client.Clients)
c.Environments = environmentsSvc.CachingMiddleware(cache.NewCache(size, ttl))(client.Environments) c.Environments = environmentsSvc.CachingMiddleware(cache.NewCache(size, ttl))(client.Environments)
......
...@@ -45,7 +45,7 @@ func NewClient(conn *grpc.ClientConn, opts ...Option) (delivery.Delivery, error) ...@@ -45,7 +45,7 @@ func NewClient(conn *grpc.ClientConn, opts ...Option) (delivery.Delivery, error)
func WithCaching(cfg *deliveryservice.Config, size int, ttl time.Duration) *deliveryservice.Config { func WithCaching(cfg *deliveryservice.Config, size int, ttl time.Duration) *deliveryservice.Config {
c := *cfg c := *cfg
cacheMetrics := metrics.NewCacheMetrics(prometheus.DefaultRegisterer) cacheMetrics := metrics.NewCacheMetrics(prometheus.WrapRegistererWithPrefix("delivery_", prometheus.DefaultRegisterer))
c.Environments = environments.CachingMiddleware(cache.NewCache(size, ttl))(cfg.Environments) c.Environments = environments.CachingMiddleware(cache.NewCache(size, ttl))(cfg.Environments)
c.Locales = locales.CachingMiddleware(cache.NewCache(size, ttl))(cfg.Locales) c.Locales = locales.CachingMiddleware(cache.NewCache(size, ttl))(cfg.Locales)
......
...@@ -34,7 +34,7 @@ func TestItemsCache(t *testing.T) { ...@@ -34,7 +34,7 @@ func TestItemsCache(t *testing.T) {
errNotFound := errors.NotFound(errors.New("not found")) errNotFound := errors.NotFound(errors.New("not found"))
ctx := context.Background() ctx := context.Background()
cacheMetrics := metrics.NewCacheMetrics(prometheus.DefaultRegisterer) cacheMetrics := metrics.NewCacheMetrics(prometheus.WrapRegistererWithPrefix("test_", prometheus.DefaultRegisterer))
t.Run("Get from cache", func(t *testing.T) { t.Run("Get from cache", func(t *testing.T) {
itms := &itmsmocks.Items{} itms := &itmsmocks.Items{}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment