Skip to content

Commit

Permalink
done coordinatino, discovery, driver logs
Browse files Browse the repository at this point in the history
  • Loading branch information
rekby committed Jan 29, 2025
1 parent 311abba commit 9f3c43a
Show file tree
Hide file tree
Showing 4 changed files with 69 additions and 69 deletions.
4 changes: 2 additions & 2 deletions log/coordination.go
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ func internalCoordination(

return func(info trace.CoordinationAlterNodeDoneInfo) {
if info.Error == nil {
l.Log(WithLevel(ctx, INFO), "alter coordination node completed",
l.Log(WithLevel(ctx, INFO), "alter coordination node done",
kv.Latency(start),
)
} else {
Expand Down Expand Up @@ -317,7 +317,7 @@ func internalCoordination(
start := time.Now()

return func(info trace.CoordinationSessionStartDoneInfo) {
l.Log(ctx, "coordination session start completed",
l.Log(ctx, "coordination session start done",
kv.Latency(start),
kv.Error(info.Error),
kv.Version(),
Expand Down
4 changes: 2 additions & 2 deletions log/discovery.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,13 +49,13 @@ func internalDiscovery(l Logger, d trace.Detailer) (t trace.Discovery) {

return func(info trace.DiscoveryWhoAmIDoneInfo) {
if info.Error == nil {
l.Log(ctx, "done discovery whoami",
l.Log(ctx, "discovery whoami done",
kv.Latency(start),
kv.String("user", info.User),
kv.Strings("groups", info.Groups),
)
} else {
l.Log(WithLevel(ctx, WARN), "failed discovery whoami",
l.Log(WithLevel(ctx, WARN), "discovery whoami failed",
kv.Error(info.Error),
kv.Latency(start),
kv.Version(),
Expand Down
Loading

0 comments on commit 9f3c43a

Please sign in to comment.