Index: logdog/common/storage/bigtable/logdog_bigtable_test/main.go |
diff --git a/logdog/common/storage/bigtable/logdog_bigtable_test/main.go b/logdog/common/storage/bigtable/logdog_bigtable_test/main.go |
index d337608a73b2a1125627003ad0a5c82099a6b2a5..ab6e482d54ad46a55a596c36e142f20941460bb4 100644 |
--- a/logdog/common/storage/bigtable/logdog_bigtable_test/main.go |
+++ b/logdog/common/storage/bigtable/logdog_bigtable_test/main.go |
@@ -7,10 +7,10 @@ |
package main |
import ( |
- "bytes" |
"flag" |
"io" |
"os" |
+ "strings" |
"github.com/luci/luci-go/client/authcli" |
"github.com/luci/luci-go/common/auth" |
@@ -62,7 +62,7 @@ func (app *application) getBigTableClient(c context.Context) (storage.Storage, e |
a := auth.NewAuthenticator(c, auth.SilentLogin, app.authOpts) |
tsrc, err := a.TokenSource() |
if err != nil { |
- return nil, errors.Annotate(err).Reason("failed to get token source").Err() |
+ return nil, errors.Annotate(err, "failed to get token source").Err() |
} |
return bigtable.New(c, bigtable.Options{ |
@@ -147,11 +147,8 @@ func main() { |
} |
func renderErr(c context.Context, err error) { |
- rerr := errors.RenderStack(err) |
- |
- var buf bytes.Buffer |
- rerr.DumpTo(&buf) |
- log.Errorf(c, "Error encountered during operation: %s\n%s", err, buf.Bytes()) |
+ log.Errorf(c, "Error encountered during operation: %s\n%s", err, |
+ strings.Join(errors.RenderStack(err), "\n")) |
} |
func unmarshalAndDump(c context.Context, out io.Writer, data []byte, msg proto.Message) error { |
@@ -214,7 +211,7 @@ func (cmd *cmdRunGet) Run(baseApp subcommands.Application, args []string, _ subc |
stClient, err := app.getBigTableClient(c) |
if err != nil { |
- renderErr(c, errors.Annotate(err).Reason("failed to create storage client").Err()) |
+ renderErr(c, errors.Annotate(err, "failed to create storage client").Err()) |
return 1 |
} |
defer stClient.Close() |
@@ -246,11 +243,11 @@ func (cmd *cmdRunGet) Run(baseApp subcommands.Application, args []string, _ subc |
}) |
switch { |
case innerErr != nil: |
- renderErr(c, errors.Annotate(err).Reason("failed to process fetched log entries").Err()) |
+ renderErr(c, errors.Annotate(err, "failed to process fetched log entries").Err()) |
return 1 |
case err != nil: |
- renderErr(c, errors.Annotate(err).Reason("Failed to Get log entries.").Err()) |
+ renderErr(c, errors.Annotate(err, "Failed to Get log entries.").Err()) |
return 1 |
} |
} |
@@ -298,7 +295,7 @@ func (cmd *cmdRunTail) Run(baseApp subcommands.Application, args []string, _ sub |
stClient, err := app.getBigTableClient(c) |
if err != nil { |
- renderErr(c, errors.Annotate(err).Reason("failed to create storage client").Err()) |
+ renderErr(c, errors.Annotate(err, "failed to create storage client").Err()) |
return 1 |
} |
defer stClient.Close() |
@@ -307,7 +304,7 @@ func (cmd *cmdRunTail) Run(baseApp subcommands.Application, args []string, _ sub |
log.Infof(c, "Tail round %d.", round+1) |
e, err := stClient.Tail(cfgtypes.ProjectName(cmd.project), types.StreamPath(cmd.path)) |
if err != nil { |
- renderErr(c, errors.Annotate(err).Reason("failed to tail log entries").Err()) |
+ renderErr(c, errors.Annotate(err, "failed to tail log entries").Err()) |
return 1 |
} |
@@ -318,7 +315,7 @@ func (cmd *cmdRunTail) Run(baseApp subcommands.Application, args []string, _ sub |
le, err := e.GetLogEntry() |
if err != nil { |
- renderErr(c, errors.Annotate(err).Reason("failed to unmarshal log entry").Err()) |
+ renderErr(c, errors.Annotate(err, "failed to unmarshal log entry").Err()) |
return 1 |
} |
@@ -327,7 +324,7 @@ func (cmd *cmdRunTail) Run(baseApp subcommands.Application, args []string, _ sub |
"size": len(e.D), |
}.Debugf(c, "Dumping tail entry.") |
if err := unmarshalAndDump(c, os.Stdout, nil, le); err != nil { |
- renderErr(c, errors.Annotate(err).Reason("failed to dump log entry").Err()) |
+ renderErr(c, errors.Annotate(err, "failed to dump log entry").Err()) |
return 1 |
} |
} |