diff --git a/weed/command/command.go b/weed/command/command.go index a82f3cdd0..9a41a8a7c 100644 --- a/weed/command/command.go +++ b/weed/command/command.go @@ -24,7 +24,7 @@ var Commands = []*Command{ cmdScaffold, cmdServer, cmdShell, - cmdTail, + cmdWatch, cmdUpload, cmdVersion, cmdVolume, diff --git a/weed/command/tail.go b/weed/command/watch.go similarity index 58% rename from weed/command/tail.go rename to weed/command/watch.go index e81a4cfe2..6a0f4e2aa 100644 --- a/weed/command/tail.go +++ b/weed/command/watch.go @@ -12,11 +12,11 @@ import ( ) func init() { - cmdTail.Run = runTail // break init cycle + cmdWatch.Run = runWatch // break init cycle } -var cmdTail = &Command{ - UsageLine: "tail [-filer=localhost:8888]", +var cmdWatch = &Command{ + UsageLine: "watch [-filer=localhost:8888] [-target=/]", Short: "see recent changes on a filer", Long: `See recent changes on a filer. @@ -24,19 +24,19 @@ var cmdTail = &Command{ } var ( - tailFiler = cmdTail.Flag.String("filer", "localhost:8888", "filer hostname:port") - tailTarget = cmdTail.Flag.String("target", "/", "a folder or file on filer") + watchFiler = cmdWatch.Flag.String("filer", "localhost:8888", "filer hostname:port") + watchTarget = cmdWatch.Flag.String("target", "/", "a folder or file on filer") ) -func runTail(cmd *Command, args []string) bool { +func runWatch(cmd *Command, args []string) bool { grpcDialOption := security.LoadClientTLS(util.GetViper(), "grpc.client") - tailErr := pb.WithFilerClient(*tailFiler, grpcDialOption, func(client filer_pb.SeaweedFilerClient) error { + watchErr := pb.WithFilerClient(*watchFiler, grpcDialOption, func(client filer_pb.SeaweedFilerClient) error { stream, err := client.ListenForEvents(context.Background(), &filer_pb.ListenForEventsRequest{ - ClientName: "tail", - Directory: *tailTarget, + ClientName: "watch", + Directory: *watchTarget, SinceNs: 0, }) if err != nil { @@ -55,8 +55,8 @@ func runTail(cmd *Command, args []string) bool { } }) - if tailErr != nil { - fmt.Printf("tail %s: %v\n", *tailFiler, tailErr) + if watchErr != nil { + fmt.Printf("watch %s: %v\n", *watchFiler, watchErr) } return true