From 2d21ab3aebdedf0c2c313403405bb8590bfcb365 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 10 Jan 2024 16:03:49 +0800 Subject: [PATCH] local cache --- pkg/common/localcache/cache.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/pkg/common/localcache/cache.go b/pkg/common/localcache/cache.go index 77e77ce5f..dedcf6aa9 100644 --- a/pkg/common/localcache/cache.go +++ b/pkg/common/localcache/cache.go @@ -32,15 +32,23 @@ type cache[V any] struct { } func (c *cache[V]) onEvict(key string, value V) { - for k := range c.link.Del(key) { + lks := c.link.Del(key) + for k := range lks { c.local.Del(k) } } func (c *cache[V]) del(key ...string) { for _, k := range key { + lks := c.link.Del(k) c.local.Del(k) + //fmt.Println(">>>", lks) + for k := range lks { + c.local.Del(k) + //fmt.Println("+++", k) + } } + //fmt.Println() } func (c *cache[V]) Get(ctx context.Context, key string, fetch func(ctx context.Context) (V, error), opts ...*opt.Option) (V, error) {