Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(55)

Unified Diff: client/cmd/logdog_butler/subcommand_stream.go

Issue 1975683002: LogDog: Implement prefix registration in Butler. (Closed) Base URL: https://github.com/luci/luci-go@logdog-butler-register-collector
Patch Set: Rebarse Created 4 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « client/cmd/logdog_butler/subcommand_serve.go ('k') | client/internal/logdog/butler/bundler/bundler.go » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: client/cmd/logdog_butler/subcommand_stream.go
diff --git a/client/cmd/logdog_butler/subcommand_stream.go b/client/cmd/logdog_butler/subcommand_stream.go
index 17e8268eea093bca036001db1fd301cad323b578..2d1324c8e6de784b435601eafcf7014803800334 100644
--- a/client/cmd/logdog_butler/subcommand_stream.go
+++ b/client/cmd/logdog_butler/subcommand_stream.go
@@ -68,8 +68,16 @@ func (cmd *streamCommandRun) Run(app subcommands.Application, args []string) int
streamFile = file
}
+ // We think everything should work. Configure our Output instance.
+ output, err := a.configOutput()
+ if err != nil {
+ log.WithError(err).Errorf(a, "Failed to create output instance.")
+ return runtimeErrorReturnCode
+ }
+ defer output.Close()
+
// Instantiate our Processor.
- err := a.Main(func(b *butler.Butler) error {
+ err = a.runWithButler(output, func(b *butler.Butler) error {
if err := b.AddStream(streamFile, cmd.stream.properties()); err != nil {
return err
}
« no previous file with comments | « client/cmd/logdog_butler/subcommand_serve.go ('k') | client/internal/logdog/butler/bundler/bundler.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698