summaryrefslogtreecommitdiff
path: root/internal/clients/tailclient.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/clients/tailclient.go')
-rw-r--r--internal/clients/tailclient.go20
1 files changed, 11 insertions, 9 deletions
diff --git a/internal/clients/tailclient.go b/internal/clients/tailclient.go
index 853ef1d..35c01d4 100644
--- a/internal/clients/tailclient.go
+++ b/internal/clients/tailclient.go
@@ -6,7 +6,8 @@ import (
"strings"
"github.com/mimecast/dtail/internal/clients/handlers"
- "github.com/mimecast/dtail/internal/io/logger"
+ "github.com/mimecast/dtail/internal/config"
+ "github.com/mimecast/dtail/internal/io/dlog"
"github.com/mimecast/dtail/internal/omode"
)
@@ -16,9 +17,8 @@ type TailClient struct {
}
// NewTailClient returns a new TailClient.
-func NewTailClient(args Args) (*TailClient, error) {
+func NewTailClient(args config.Args) (*TailClient, error) {
args.Mode = omode.TailClient
-
c := TailClient{
baseClient: baseClient{
Args: args,
@@ -29,7 +29,6 @@ func NewTailClient(args Args) (*TailClient, error) {
c.init()
c.makeConnections(c)
-
return &c, nil
}
@@ -37,12 +36,15 @@ func (c TailClient) makeHandler(server string) handlers.Handler {
return handlers.NewClientHandler(server)
}
-func (c TailClient) makeCommands(options map[string]string) (commands []string) {
- optionsStr := c.commandOptionsToString(options)
+func (c TailClient) makeCommands() (commands []string) {
+ regex, err := c.Regex.Serialize()
+ if err != nil {
+ dlog.Client.FatalPanic(err)
+ }
for _, file := range strings.Split(c.What, ",") {
- commands = append(commands, fmt.Sprintf("%s:%s %s %s", c.Mode.String(), optionsStr, file, c.Regex.Serialize()))
+ commands = append(commands, fmt.Sprintf("%s:%s %s %s",
+ c.Mode.String(), c.Args.SerializeOptions(), file, regex))
}
- logger.Debug(commands)
-
+ dlog.Client.Debug(commands)
return
}