From 662d420d534bfee225f611b3bd734d3427b44b6d Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Wed, 19 May 2021 14:32:12 +0100 Subject: [PATCH] fix increment/decrement in cache --- pkg/cache/cache.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/cache/cache.go b/pkg/cache/cache.go index 2d6d68d..b24cedf 100644 --- a/pkg/cache/cache.go +++ b/pkg/cache/cache.go @@ -66,7 +66,7 @@ func (c *cache) Context(ctx context.Context) Cache { return c } return &cache{ - LRU: c.LRU, + LRU: c.LRU, Store: c.Store, Prefix: t, } @@ -156,7 +156,7 @@ func (c *cache) Increment(key string, value int64) (int64, error) { defer c.Unlock() var val int64 - if err := c.Get(key, &val); err != nil { + if err := c.Get(key, &val); err != nil && err != ErrNotFound { return 0, err } val += value @@ -171,7 +171,7 @@ func (c *cache) Decrement(key string, value int64) (int64, error) { defer c.Unlock() var val int64 - if err := c.Get(key, &val); err != nil { + if err := c.Get(key, &val); err != nil && err != ErrNotFound { return 0, err } val -= value