aboutsummaryrefslogtreecommitdiff
path: root/pkg/commands/flushall.go
blob: 9f1316adf095d31c5d5c5a8a380dcf0254c58f73 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
package commands

import (
	"redisClone/pkg/core"
)

func Flushall(args []string, getShard func(k string) *core.Shard) interface{} {
	return dbInstance.ExecuteAll(func(shards []*core.Shard) interface{} {
		for _, shard := range shards {
			shard.Data = make(map[string]core.Item)
		}
		return core.SimpleString("OK")
	})
}