Skip to content

Commit d7469d9

Browse files
rekbyrekby
committed
style fixes
1 parent 0ae84b1 commit d7469d9

File tree

4 files changed

+72
-72
lines changed

4 files changed

+72
-72
lines changed

‎log/coordination.go‎

Lines changed: 23 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -25,11 +25,11 @@ func internalCoordination(
2525
return nil
2626
}
2727
ctx := with(*info.Context, TRACE, "ydb", "coordination", "new")
28-
l.Log(ctx, "starting coordination client...")
28+
l.Log(ctx, "coordination client starting...")
2929
start := time.Now()
3030

3131
return func(info trace.CoordinationNewDoneInfo) {
32-
l.Log(WithLevel(ctx, INFO), "coordination client started",
32+
l.Log(WithLevel(ctx, INFO), "coordination client start done",
3333
kv.Latency(start),
3434
kv.Version(),
3535
)
@@ -40,18 +40,18 @@ func internalCoordination(
4040
return nil
4141
}
4242
ctx := with(*info.Context, TRACE, "ydb", "coordination", "node", "create")
43-
l.Log(ctx, "starting coordination node...",
43+
l.Log(ctx, "coordination node create starting...",
4444
kv.String("path", info.Path),
4545
)
4646
start := time.Now()
4747

4848
return func(info trace.CoordinationCreateNodeDoneInfo) {
4949
if info.Error == nil {
50-
l.Log(WithLevel(ctx, INFO), "coordination node started",
50+
l.Log(WithLevel(ctx, INFO), "coordination node create done",
5151
kv.Latency(start),
5252
)
5353
} else {
54-
l.Log(WithLevel(ctx, ERROR), "coordination node start failed",
54+
l.Log(WithLevel(ctx, ERROR), "coordination node create failed",
5555
kv.Latency(start),
5656
kv.Version(),
5757
)
@@ -63,18 +63,18 @@ func internalCoordination(
6363
return nil
6464
}
6565
ctx := with(*info.Context, TRACE, "ydb", "coordination", "node", "alter")
66-
l.Log(ctx, "starting alter coordination node...",
66+
l.Log(ctx, "coordination alter node starting...",
6767
kv.String("path", info.Path),
6868
)
6969
start := time.Now()
7070

7171
return func(info trace.CoordinationAlterNodeDoneInfo) {
7272
if info.Error == nil {
73-
l.Log(WithLevel(ctx, INFO), "alter coordination node done",
73+
l.Log(WithLevel(ctx, INFO), "coordination alter node done",
7474
kv.Latency(start),
7575
)
7676
} else {
77-
l.Log(WithLevel(ctx, ERROR), "alter coordination node failed",
77+
l.Log(WithLevel(ctx, ERROR), "coordination alter node failed",
7878
kv.Latency(start),
7979
kv.Version(),
8080
)
@@ -86,18 +86,18 @@ func internalCoordination(
8686
return nil
8787
}
8888
ctx := with(*info.Context, TRACE, "ydb", "coordination", "node", "drop")
89-
l.Log(ctx, "starting drop coordination node...",
89+
l.Log(ctx, "drop coordination node starting...",
9090
kv.String("path", info.Path),
9191
)
9292
start := time.Now()
9393

9494
return func(info trace.CoordinationDropNodeDoneInfo) {
9595
if info.Error == nil {
96-
l.Log(WithLevel(ctx, INFO), "coordination node dropped",
96+
l.Log(WithLevel(ctx, INFO), "drop coordination node done",
9797
kv.Latency(start),
9898
)
9999
} else {
100-
l.Log(WithLevel(ctx, ERROR), "coordination node drop failed",
100+
l.Log(WithLevel(ctx, ERROR), "drop coordination node failed",
101101
kv.Latency(start),
102102
kv.Version(),
103103
)
@@ -109,18 +109,18 @@ func internalCoordination(
109109
return nil
110110
}
111111
ctx := with(*info.Context, TRACE, "ydb", "coordination", "node", "describe")
112-
l.Log(ctx, "starting describe coordination node...",
112+
l.Log(ctx, "describe coordination node starting...",
113113
kv.String("path", info.Path),
114114
)
115115
start := time.Now()
116116

117117
return func(info trace.CoordinationDescribeNodeDoneInfo) {
118118
if info.Error == nil {
119-
l.Log(WithLevel(ctx, INFO), "describe node started",
119+
l.Log(WithLevel(ctx, INFO), "describe coordination node done",
120120
kv.Latency(start),
121121
)
122122
} else {
123-
l.Log(WithLevel(ctx, ERROR), "describe node start failed",
123+
l.Log(WithLevel(ctx, ERROR), "describe coordination node failed",
124124
kv.Latency(start),
125125
kv.Version(),
126126
)
@@ -132,12 +132,12 @@ func internalCoordination(
132132
return nil
133133
}
134134
ctx := with(*info.Context, TRACE, "ydb", "coordination", "node", "describe")
135-
l.Log(ctx, "starting create coordination session...")
135+
l.Log(ctx, "create coordination session starting...")
136136
start := time.Now()
137137

138138
return func(info trace.CoordinationSessionDoneInfo) {
139139
if info.Error == nil {
140-
l.Log(WithLevel(ctx, INFO), "coordination session created",
140+
l.Log(WithLevel(ctx, INFO), "create coordination session done",
141141
kv.Latency(start),
142142
)
143143
} else {
@@ -153,12 +153,12 @@ func internalCoordination(
153153
return nil
154154
}
155155
ctx := with(*info.Context, TRACE, "ydb", "coordination", "close")
156-
l.Log(ctx, "start closing coordination client...")
156+
l.Log(ctx, "close coordination client starting...")
157157
start := time.Now()
158158

159159
return func(info trace.CoordinationCloseDoneInfo) {
160160
if info.Error == nil {
161-
l.Log(WithLevel(ctx, INFO), "coordination client closed",
161+
l.Log(WithLevel(ctx, INFO), "close coordination client done",
162162
kv.Latency(start),
163163
)
164164
} else {
@@ -178,11 +178,11 @@ func internalCoordination(
178178
return nil
179179
}
180180
ctx := with(context.Background(), TRACE, "ydb", "coordination", "session", "stream", "new")
181-
l.Log(ctx, "starting new coordination session stam...")
181+
l.Log(ctx, "new coordination session stream starting...")
182182
start := time.Now()
183183

184184
return func(info trace.CoordinationSessionNewStreamDoneInfo) {
185-
l.Log(ctx, "new coordination session stream started",
185+
l.Log(ctx, "new coordination session stream done",
186186
kv.Latency(start),
187187
kv.Error(info.Error),
188188
kv.Version(),
@@ -274,11 +274,11 @@ func internalCoordination(
274274
return nil
275275
}
276276
ctx := with(context.Background(), TRACE, "ydb", "coordination", "session", "receive")
277-
l.Log(ctx, "starting coordination session receive")
277+
l.Log(ctx, "coordination session receive starting...")
278278
start := time.Now()
279279

280280
return func(info trace.CoordinationSessionReceiveDoneInfo) {
281-
l.Log(ctx, "coordination session received",
281+
l.Log(ctx, "coordination session receive done",
282282
kv.Latency(start),
283283
kv.Error(info.Error),
284284
kv.Stringer("response", info.Response),
@@ -313,7 +313,7 @@ func internalCoordination(
313313
return nil
314314
}
315315
ctx := with(context.Background(), TRACE, "ydb", "coordination", "session", "start")
316-
l.Log(ctx, "starting coordination session...")
316+
l.Log(ctx, "coordination session start starting...")
317317
start := time.Now()
318318

319319
return func(info trace.CoordinationSessionStartDoneInfo) {

‎log/discovery.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ func internalDiscovery(l Logger, d trace.Detailer) (t trace.Discovery) {
1818
return nil
1919
}
2020
ctx := with(*info.Context, DEBUG, "ydb", "discovery", "list", "endpoints")
21-
l.Log(ctx, "starting discovery...",
21+
l.Log(ctx, "discovery starting...",
2222
kv.String("address", info.Address),
2323
kv.String("database", info.Database),
2424
)
@@ -44,7 +44,7 @@ func internalDiscovery(l Logger, d trace.Detailer) (t trace.Discovery) {
4444
return nil
4545
}
4646
ctx := with(*info.Context, TRACE, "ydb", "discovery", "whoAmI")
47-
l.Log(ctx, "starting discovery whoami")
47+
l.Log(ctx, "discovery whoami starting...")
4848
start := time.Now()
4949

5050
return func(info trace.DiscoveryWhoAmIDoneInfo) {

‎log/driver.go‎

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
2828
ctx := with(context.Background(), TRACE, "ydb", "driver", "resolver", "update")
2929
target := info.Target
3030
addresses := info.Resolved
31-
l.Log(ctx, "driver starting resolve...",
31+
l.Log(ctx, "driver resolve starting...",
3232
kv.String("target", target),
3333
kv.Strings("resolved", addresses),
3434
)
@@ -57,7 +57,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
5757
database := info.Database
5858
secure := info.Secure
5959
ctx := with(*info.Context, DEBUG, "ydb", "driver", "resolver", "init")
60-
l.Log(ctx, "driver starting init...",
60+
l.Log(ctx, "driver init starting...",
6161
kv.String("endpoint", endpoint),
6262
kv.String("database", database),
6363
kv.Bool("secure", secure),
@@ -89,7 +89,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
8989
return nil
9090
}
9191
ctx := with(*info.Context, TRACE, "ydb", "driver", "resolver", "close")
92-
l.Log(ctx, "driver starting close...")
92+
l.Log(ctx, "driver close starting...")
9393
start := time.Now()
9494

9595
return func(info trace.DriverCloseDoneInfo) {
@@ -112,19 +112,19 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
112112
}
113113
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "dial")
114114
endpoint := info.Endpoint
115-
l.Log(ctx, "driver starting dial...",
115+
l.Log(ctx, "driver connection dial starting...",
116116
kv.Stringer("endpoint", endpoint),
117117
)
118118
start := time.Now()
119119

120120
return func(info trace.DriverConnDialDoneInfo) {
121121
if info.Error == nil {
122-
l.Log(ctx, "driver dial done",
122+
l.Log(ctx, "driver connection dial done",
123123
kv.Stringer("endpoint", endpoint),
124124
kv.Latency(start),
125125
)
126126
} else {
127-
l.Log(WithLevel(ctx, WARN), "driver dial failed",
127+
l.Log(WithLevel(ctx, WARN), "driver connection dial failed",
128128
kv.Error(info.Error),
129129
kv.Stringer("endpoint", endpoint),
130130
kv.Latency(start),
@@ -139,7 +139,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
139139
}
140140
ctx := with(context.Background(), TRACE, "ydb", "driver", "conn", "state", "change")
141141
endpoint := info.Endpoint
142-
l.Log(ctx, "driver starting state change...",
142+
l.Log(ctx, "driver state change starting...",
143143
kv.Stringer("endpoint", endpoint),
144144
kv.Stringer("state", info.State),
145145
)
@@ -159,7 +159,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
159159
}
160160
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "close")
161161
endpoint := info.Endpoint
162-
l.Log(ctx, "driver starting connection close...",
162+
l.Log(ctx, "driver connection close starting...",
163163
kv.Stringer("endpoint", endpoint),
164164
)
165165
start := time.Now()
@@ -187,7 +187,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
187187
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "invoke")
188188
endpoint := info.Endpoint
189189
method := string(info.Method)
190-
l.Log(ctx, "driver starting connection invoke...",
190+
l.Log(ctx, "driver connection invoke starting...",
191191
kv.Stringer("endpoint", endpoint),
192192
kv.String("method", method),
193193
)
@@ -224,7 +224,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
224224
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "New")
225225
endpoint := info.Endpoint
226226
method := string(info.Method)
227-
l.Log(ctx, "driver starting new connection stream...",
227+
l.Log(ctx, "driver new connection stream starting...",
228228
kv.Stringer("endpoint", endpoint),
229229
kv.String("method", method),
230230
)
@@ -255,7 +255,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
255255
return nil
256256
}
257257
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "CloseSend")
258-
l.Log(ctx, "driver starting send stream close...")
258+
l.Log(ctx, "driver send stream close starting...")
259259
start := time.Now()
260260

261261
return func(info trace.DriverConnStreamCloseSendDoneInfo) {
@@ -277,7 +277,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
277277
return nil
278278
}
279279
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "SendMsg")
280-
l.Log(ctx, "driver starting send stream msg...")
280+
l.Log(ctx, "driver send stream msg starting...")
281281
start := time.Now()
282282

283283
return func(info trace.DriverConnStreamSendMsgDoneInfo) {
@@ -299,7 +299,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
299299
return nil
300300
}
301301
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "stream", "RecvMsg")
302-
l.Log(ctx, "driver starting receive stream msg...")
302+
l.Log(ctx, "driver receive stream msg starting...")
303303
start := time.Now()
304304

305305
return func(info trace.DriverConnStreamRecvMsgDoneInfo) {
@@ -323,7 +323,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
323323
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "ban")
324324
endpoint := info.Endpoint
325325
cause := info.Cause
326-
l.Log(ctx, "driver starting connection ban...",
326+
l.Log(ctx, "driver connection ban starting...",
327327
kv.Stringer("endpoint", endpoint),
328328
kv.NamedError("cause", cause),
329329
)
@@ -345,7 +345,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
345345
}
346346
ctx := with(*info.Context, TRACE, "ydb", "driver", "conn", "allow")
347347
endpoint := info.Endpoint
348-
l.Log(ctx, "driver starting connection allow...",
348+
l.Log(ctx, "driver connection allow starting...",
349349
kv.Stringer("endpoint", endpoint),
350350
)
351351
start := time.Now()
@@ -365,7 +365,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
365365
ctx := with(*info.Context, TRACE, "ydb", "driver", "repeater", "wake", "up")
366366
name := info.Name
367367
event := info.Event
368-
l.Log(ctx, "driver starting repeater wakeup...",
368+
l.Log(ctx, "driver repeater wakeup starting...",
369369
kv.String("name", name),
370370
kv.String("event", event),
371371
)
@@ -394,7 +394,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
394394
return nil
395395
}
396396
ctx := with(*info.Context, TRACE, "ydb", "driver", "balancer", "init")
397-
l.Log(ctx, "driver starting balancer init...")
397+
l.Log(ctx, "driver balancer init starting...")
398398
start := time.Now()
399399

400400
return func(info trace.DriverBalancerInitDoneInfo) {
@@ -408,7 +408,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
408408
return nil
409409
}
410410
ctx := with(*info.Context, TRACE, "ydb", "driver", "balancer", "close")
411-
l.Log(ctx, "driver starting balancer close...")
411+
l.Log(ctx, "driver balancer close starting...")
412412
start := time.Now()
413413

414414
return func(info trace.DriverBalancerCloseDoneInfo) {
@@ -434,7 +434,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
434434
return nil
435435
}
436436
ctx := with(*info.Context, TRACE, "ydb", "driver", "balancer", "choose", "endpoint")
437-
l.Log(ctx, "driver starting balancer choose endpoint...")
437+
l.Log(ctx, "driver balancer choose endpoint starting...")
438438
start := time.Now()
439439

440440
return func(info trace.DriverBalancerChooseEndpointDoneInfo) {
@@ -461,7 +461,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
461461
return nil
462462
}
463463
ctx := with(*info.Context, TRACE, "ydb", "driver", "balancer", "update")
464-
l.Log(ctx, "driver starting balancer update...",
464+
l.Log(ctx, "driver balancer update starting...",
465465
kv.Bool("needLocalDC", info.NeedLocalDC),
466466
kv.String("database", info.Database),
467467
)
@@ -482,7 +482,7 @@ func internalDriver(l Logger, d trace.Detailer) trace.Driver {
482482
return nil
483483
}
484484
ctx := with(*info.Context, TRACE, "ydb", "driver", "credentials", "get")
485-
l.Log(ctx, "driver starting get credentials...")
485+
l.Log(ctx, "driver get credentials starting...")
486486
start := time.Now()
487487

488488
return func(info trace.DriverGetCredentialsDoneInfo) {

0 commit comments

Comments
 (0)