tidb filter 源码
tidb filter 代码
文件路径：/br/pkg/lightning/log/filter.go
// Copyright 2021 PingCAP, Inc. Licensed under Apache-2.0.
package log
import (
"strings"
"go.uber.org/zap/zapcore"
)
var _ zapcore.Core = (*FilterCore)(nil)
// FilterCore is a zapcore.Core implementation, it filters log by path-qualified
// package name.
type FilterCore struct {
zapcore.Core
filters []string
}
// NewFilterCore returns a FilterCore, only logs under allowPackages will be written.
//
// Example, only write br's log and ignore any other, `NewFilterCore(core, "github.com/pingcap/tidb/br/")`.
// Note, must set AddCaller() to the logger.
func NewFilterCore(core zapcore.Core, allowPackages ...string) *FilterCore {
return &FilterCore{
Core: core,
filters: allowPackages,
}
}
// With adds structured context to the Core.
func (f *FilterCore) With(fields []zapcore.Field) zapcore.Core {
return &FilterCore{
Core: f.Core.With(fields),
filters: f.filters,
}
}
// Check overrides wrapper core.Check and adds itself to zapcore.CheckedEntry.
func (f *FilterCore) Check(entry zapcore.Entry, ce *zapcore.CheckedEntry) *zapcore.CheckedEntry {
if f.Enabled(entry.Level) {
return ce.AddCore(entry, f)
}
return ce
}
// Write filters entry by checking if entry's Caller.Function matches filtered
// package path.
func (f *FilterCore) Write(entry zapcore.Entry, fields []zapcore.Field) error {
for i := range f.filters {
// Caller.Function is a package path-qualified function name.
if strings.Contains(entry.Caller.Function, f.filters[i]) {
return f.Core.Write(entry, fields)
}
}
return nil
}
相关信息
相关文章
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
6、 golang
-
7、 openharmony