summaryrefslogtreecommitdiff
path: root/internal/clients/handlers/maprhandler.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@dionysus>2020-09-19 18:38:36 +0100
committerPaul Buetow <paul@dionysus>2020-09-19 18:38:36 +0100
commitbad8e04bb4410b94b8e875ccde287f74ab94121a (patch)
tree9fb8f7aea4e240e5de49acd4e6fd18c5a0282b57 /internal/clients/handlers/maprhandler.go
parent813d2d00ec581c801d64091c7774988b559c3e93 (diff)
server handler context refactoring
Diffstat (limited to 'internal/clients/handlers/maprhandler.go')
-rw-r--r--internal/clients/handlers/maprhandler.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/internal/clients/handlers/maprhandler.go b/internal/clients/handlers/maprhandler.go
index 5d98690..fb71c8f 100644
--- a/internal/clients/handlers/maprhandler.go
+++ b/internal/clients/handlers/maprhandler.go
@@ -3,6 +3,7 @@ package handlers
import (
"strings"
+ "github.com/mimecast/dtail/internal"
"github.com/mimecast/dtail/internal/io/logger"
"github.com/mimecast/dtail/internal/mapr"
"github.com/mimecast/dtail/internal/mapr/client"
@@ -24,7 +25,7 @@ func NewMaprHandler(server string, query *mapr.Query, globalGroup *mapr.GlobalGr
shellStarted: false,
commands: make(chan string),
status: -1,
- done: NewDone(),
+ done: internal.NewDone(),
},
query: query,
aggregate: client.NewAggregate(server, query, globalGroup),