Skip to content

Commit 38e8369

Browse files
committed
remove internal logger trace callbacks for insert and remove cluster events
1 parent effc1a5 commit 38e8369

File tree

1 file changed

+0
-30
lines changed

1 file changed

+0
-30
lines changed

log/driver.go

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -463,36 +463,6 @@ func Driver(l Logger, details trace.Details) (t trace.Driver) {
463463
}
464464
}
465465
}
466-
//nolint:staticcheck
467-
t.OnClusterInsert = func(info trace.DriverClusterInsertStartInfo) func(trace.DriverClusterInsertDoneInfo) {
468-
endpoint := info.Endpoint.String()
469-
l.Debugf(`insert start {endpoint:%v}`,
470-
endpoint,
471-
)
472-
start := time.Now()
473-
return func(info trace.DriverClusterInsertDoneInfo) {
474-
l.Infof(`insert done {endpoint:%v,latency:"%v",state:"%s"}`,
475-
endpoint,
476-
time.Since(start),
477-
info.State,
478-
)
479-
}
480-
}
481-
//nolint:staticcheck
482-
t.OnClusterRemove = func(info trace.DriverClusterRemoveStartInfo) func(trace.DriverClusterRemoveDoneInfo) {
483-
endpoint := info.Endpoint.String()
484-
l.Debugf(`remove start {endpoint:%v}`,
485-
endpoint,
486-
)
487-
start := time.Now()
488-
return func(info trace.DriverClusterRemoveDoneInfo) {
489-
l.Infof(`remove done {endpoint:%v,latency:"%v",state:"%s"}`,
490-
endpoint,
491-
time.Since(start),
492-
info.State,
493-
)
494-
}
495-
}
496466
t.OnPessimizeNode = func(info trace.DriverPessimizeNodeStartInfo) func(trace.DriverPessimizeNodeDoneInfo) {
497467
endpoint := info.Endpoint.String()
498468
l.Warnf(`pessimize start {endpoint:%v,cause:"%s",version:"%s"}`,

0 commit comments

Comments
 (0)