multi exec and discardmulti/execute

1 files changed, 15 insertions, 17 deletions

diff --git a/pkg/commands/keys.go b/pkg/commands/keys.go
index b233964..40d9277 100644
--- a/pkg/commands/keys.go
+++ b/pkg/commands/keys.go
@@ -19,23 +19,21 @@ func Keys(args []string, getShard func(k string) *core.Shard) interface{} {
 		limit = val
 	}
 
-	return dbInstance.ExecuteReadAll(func(shards []*core.Shard) interface{} {
-		var matches []string
-		for _, shard := range shards {
-			for key := range shard.Data {
-				matched, err := filepath.Match(pattern, key)
-				if err != nil {
-					return errors.New("illegal glob pattern")
-				}
-				if matched {
-					matches = append(matches, key)
-				}
+	var matches []string
+	for _, shard := range dbInstance.Shards {
+		for key := range shard.Data {
+			matched, err := filepath.Match(pattern, key)
+			if err != nil {
+				return errors.New("illegal glob pattern")
+			}
+			if matched {
+				matches = append(matches, key)
 			}
 		}
-		sort.Strings(matches)
-		if limit != -1 && len(matches) > limit {
-			matches = matches[:limit]
-		}
-		return matches
-	})
+	}
+	sort.Strings(matches)
+	if limit != -1 && len(matches) > limit {
+		matches = matches[:limit]
+	}
+	return matches
 }