summaryrefslogtreecommitdiff
path: root/internal/server/handlers/mapcommand.go
diff options
context:
space:
mode:
authorPaul Buetow <pbuetow@mimecast.com>2020-02-28 13:14:29 +0000
committerPaul Buetow <pbuetow@mimecast.com>2020-02-28 13:14:29 +0000
commit71d2786aeaa793d9cf51c389d2e91cf472d25f7a (patch)
treeb2cf5a8e3f86f05b5d4870809637bcd9b967906c /internal/server/handlers/mapcommand.go
parentcb2de4109632932bccf5d13e77f40157d4e84c18 (diff)
more on scheduled commands
Diffstat (limited to 'internal/server/handlers/mapcommand.go')
-rw-r--r--internal/server/handlers/mapcommand.go10
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
}