feat(cache): Add flush function from cache

Author: LinkinStars

cache/cache.go

@@ -12,4 +12,5 @@ type Cache interface {
 	GetInt64(ctx context.Context, key string) (int64, error)
 	SetInt64(ctx context.Context, key string, value int64, ttl time.Duration) error
 	Del(ctx context.Context, key string) error
+	Flush(ctx context.Context) error
 }

contrib/cache/memory/local.go

@@ -77,3 +77,9 @@ func (s *Cache) Del(ctx context.Context, Key string) error {
 	s.local.Delete(Key)
 	return nil
 }
+
+// Flush deletes all items from cache
+func (s *Cache) Flush(ctx context.Context) error {
+	s.local.Flush()
+	return nil
+}

contrib/cache/memory/local_test.go

@@ -44,3 +44,17 @@ func TestCache_Del(t *testing.T) {
 	got, err := myCache.GetString(context.TODO(), key)
 	assert.Equal(t, "", got)
 }
+
+func TestCache_Flush(t *testing.T) {
+	var key = "test"
+	var val = "test"
+	myCache := NewCache()
+	err := myCache.SetString(context.TODO(), key, val, -1)
+	assert.NoError(t, err)
+
+	err = myCache.Flush(context.TODO())
+	assert.NoError(t, err)
+
+	got, err := myCache.GetString(context.TODO(), key)
+	assert.Equal(t, "", got)
+}

contrib/cache/redis/redis.go

@@ -49,3 +49,9 @@ func (r *Cache) SetInt64(ctx context.Context, key string, value int64, ttl time.
 func (r *Cache) Del(ctx context.Context, key string) error {
 	return r.Client.Del(ctx, key).Err()
 }
+
+// Flush delete all cache entries
+func (r *Cache) Flush(ctx context.Context) error {
+	r.Client.FlushAll(ctx)
+	return nil
+}