diff options
Diffstat (limited to 'pkg/commands/keys.go')
| -rw-r--r-- | pkg/commands/keys.go | 32 |
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 } |
