diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2020-02-28 13:14:29 +0000 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2020-02-28 13:14:29 +0000 |
| commit | 71d2786aeaa793d9cf51c389d2e91cf472d25f7a (patch) | |
| tree | b2cf5a8e3f86f05b5d4870809637bcd9b967906c /internal/server/handlers/mapcommand.go | |
| parent | cb2de4109632932bccf5d13e77f40157d4e84c18 (diff) | |
more on scheduled commands
Diffstat (limited to 'internal/server/handlers/mapcommand.go')
| -rw-r--r-- | internal/server/handlers/mapcommand.go | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/internal/server/handlers/mapcommand.go b/internal/server/handlers/mapcommand.go index 10372da..c3e600e 100644 --- a/internal/server/handlers/mapcommand.go +++ b/internal/server/handlers/mapcommand.go @@ -15,18 +15,16 @@ type mapCommand struct { // NewMapCommand returns a new server side mapreduce command. func newMapCommand(serverHandler *ServerHandler, argc int, args []string) (mapCommand, *server.Aggregate, error) { - mapCommand := mapCommand{ - server: serverHandler, - } + m := mapCommand{server: serverHandler} queryStr := strings.Join(args[1:], " ") aggregate, err := server.NewAggregate(queryStr) if err != nil { - return mapCommand, nil, err + return m, nil, err } - mapCommand.aggregate = aggregate - return mapCommand, aggregate, nil + m.aggregate = aggregate + return m, aggregate, nil } |
