diff --git a/pkg/db/redis.go b/pkg/db/redis.go index 5e8e6fd4..8a33058e 100644 --- a/pkg/db/redis.go +++ b/pkg/db/redis.go @@ -169,3 +169,8 @@ func (r *Redis) Data(page, pageSize int) ([]RedisKV, error) { return result, nil } + +func (r *Redis) Clear() error { + _, err := r.conn.Do("FLUSHDB") + return err +}