summaryrefslogtreecommitdiff
path: root/internal/clients/maprclient.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2021-10-09 21:10:29 +0300
committerPaul Buetow <paul@buetow.org>2021-10-10 13:36:41 +0300
commit97747ea0f3178f7f5890512d483fdccaa82846b0 (patch)
tree9ff1335ca26afc90e55fd6de416457e252d75a35 /internal/clients/maprclient.go
parent7a7169791a64190e1002e38bc9c04ad0d5c1ce1f (diff)
vetting and linting and some code restyling
Diffstat (limited to 'internal/clients/maprclient.go')
-rw-r--r--internal/clients/maprclient.go13
1 files changed, 4 insertions, 9 deletions
diff --git a/internal/clients/maprclient.go b/internal/clients/maprclient.go
index 412a219..04f258d 100644
--- a/internal/clients/maprclient.go
+++ b/internal/clients/maprclient.go
@@ -107,15 +107,14 @@ func (c *MaprClient) Start(ctx context.Context, statsCh <-chan string) (status i
return
}
-// NEXT: Make this a callback function rather trying to use polymorphism to call this.
-// This applies to all clients.
+// NEXT: Make this a callback function rather trying to use polymorphism to call
+// this. This applies to all clients.
func (c MaprClient) makeHandler(server string) handlers.Handler {
return handlers.NewMaprHandler(server, c.query, c.globalGroup)
}
func (c MaprClient) makeCommands() (commands []string) {
commands = append(commands, fmt.Sprintf("map %s", c.query.RawQuery))
-
modeStr := "cat"
if c.Mode == omode.TailClient {
modeStr = "tail"
@@ -134,7 +133,6 @@ func (c MaprClient) makeCommands() (commands []string) {
commands = append(commands, fmt.Sprintf("%s:%s %s %s",
modeStr, c.Args.SerializeOptions(), file, regex))
}
-
return
}
@@ -155,7 +153,6 @@ func (c *MaprClient) reportResults() {
c.writeResultsToOutfile()
return
}
-
c.printResults()
}
@@ -176,7 +173,6 @@ func (c *MaprClient) printResults() {
} else {
result, numRows, err = c.globalGroup.SwapOut().Result(c.query, rowsLimit)
}
-
if err != nil {
dlog.Client.FatalPanic(err)
}
@@ -202,8 +198,8 @@ func (c *MaprClient) printResults() {
dlog.Client.Raw(rawQuery)
if rowsLimit > 0 && numRows > rowsLimit {
- dlog.Client.Warn(fmt.Sprintf("Got %d results but limited terminal output to %d rows! Use 'limit' clause to override!",
- numRows, rowsLimit))
+ dlog.Client.Warn(fmt.Sprintf("Got %d results but limited terminal output "+
+ "to %d rows! Use 'limit' clause to override!", numRows, rowsLimit))
}
dlog.Client.Raw(result)
}
@@ -215,7 +211,6 @@ func (c *MaprClient) writeResultsToOutfile() {
}
return
}
-
if err := c.globalGroup.SwapOut().WriteResult(c.query); err != nil {
dlog.Client.FatalPanic(err)
}