feat(cache): update cache

jzero-io · Dec 7, 2024 · 6f1cf38 · 6f1cf38
1 parent dab3694
commit 6f1cf38
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/cache/redis.go b/cache/redis.go
@@ -4,7 +4,6 @@ import (
 	"context"
 	"time"
 
-	"github.com/pkg/errors"
 	"github.com/zeromicro/go-zero/core/jsonx"
 	zerocache "github.com/zeromicro/go-zero/core/stores/cache"
 	"github.com/zeromicro/go-zero/core/stores/redis"
@@ -76,10 +75,10 @@ func (c cacheNode) TakeWithExpireCtx(ctx context.Context, val any, key string, q
 	return c.node.TakeWithExpireCtx(ctx, val, key, query)
 }
 
-func NewRedisNode(rds *redis.Redis) Cache {
+func NewRedisNode(rds *redis.Redis, errNotFound error) Cache {
 	singleFlights := syncx.NewSingleFlight()
 	stats := zerocache.NewStat("redis-cache")
-	node := zerocache.NewNode(rds, singleFlights, stats, errors.New("cache not found"))
+	node := zerocache.NewNode(rds, singleFlights, stats, errNotFound)
 	return &cacheNode{
 		node: node,
 	}