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") }) }