前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >聊聊klog的header

聊聊klog的header

作者头像
code4it
发布2021-01-12 14:53:53
1K0
发布2021-01-12 14:53:53
举报
文章被收录于专栏:码匠的流水账

本文主要研究一下klog的header

println

k8s.io/klog/v2@v2.4.0/klog.go

代码语言:javascript
复制
func (l *loggingT) println(s severity, logr logr.Logger, filter LogFilter, args ...interface{}) {
    buf, file, line := l.header(s, 0)
    // if logr is set, we clear the generated header as we rely on the backing
    // logr implementation to print headers
    if logr != nil {
        l.putBuffer(buf)
        buf = l.getBuffer()
    }
    if filter != nil {
        args = filter.Filter(args)
    }
    fmt.Fprintln(buf, args...)
    l.output(s, logr, buf, file, line, false)
}

println方法先执行l.header(s, 0),若logr不为nil则先l.putBuffer(buf),然后重新设置buf

header

k8s.io/klog/v2@v2.4.0/klog.go

代码语言:javascript
复制
func (l *loggingT) header(s severity, depth int) (*buffer, string, int) {
    _, file, line, ok := runtime.Caller(3 + depth)
    if !ok {
        file = "???"
        line = 1
    } else {
        if slash := strings.LastIndex(file, "/"); slash >= 0 {
            path := file
            file = path[slash+1:]
            if l.addDirHeader {
                if dirsep := strings.LastIndex(path[:slash], "/"); dirsep >= 0 {
                    file = path[dirsep+1:]
                }
            }
        }
    }
    return l.formatHeader(s, file, line), file, line
}

header方法最后执行l.formatHeader

formatHeader

k8s.io/klog/v2@v2.4.0/klog.go

代码语言:javascript
复制
// formatHeader formats a log header using the provided file name and line number.
func (l *loggingT) formatHeader(s severity, file string, line int) *buffer {
    now := timeNow()
    if line < 0 {
        line = 0 // not a real line number, but acceptable to someDigits
    }
    if s > fatalLog {
        s = infoLog // for safety.
    }
    buf := l.getBuffer()
    if l.skipHeaders {
        return buf
    }

    // Avoid Fprintf, for speed. The format is so simple that we can do it quickly by hand.
    // It's worth about 3X. Fprintf is hard.
    _, month, day := now.Date()
    hour, minute, second := now.Clock()
    // Lmmdd hh:mm:ss.uuuuuu threadid file:line]
    buf.tmp[0] = severityChar[s]
    buf.twoDigits(1, int(month))
    buf.twoDigits(3, day)
    buf.tmp[5] = ' '
    buf.twoDigits(6, hour)
    buf.tmp[8] = ':'
    buf.twoDigits(9, minute)
    buf.tmp[11] = ':'
    buf.twoDigits(12, second)
    buf.tmp[14] = '.'
    buf.nDigits(6, 15, now.Nanosecond()/1000, '0')
    buf.tmp[21] = ' '
    buf.nDigits(7, 22, pid, ' ') // TODO: should be TID
    buf.tmp[29] = ' '
    buf.Write(buf.tmp[:30])
    buf.WriteString(file)
    buf.tmp[0] = ':'
    n := buf.someDigits(1, line)
    buf.tmp[n+1] = ']'
    buf.tmp[n+2] = ' '
    buf.Write(buf.tmp[:n+3])
    return buf
}

如果设置了l.skipHeaders,则不会进行format

实例

代码语言:javascript
复制
func headerDemo() {
    flag.Set("skip_headers", "true")
    klog.Info("hello by Info")
    klog.InfoDepth(0, "hello by InfoDepth 0")
    klog.InfoDepth(1, "hello by InfoDepth 1")
    klog.Infoln("hello by Infoln")
    klog.Infof("hello by %s", "Infof")
    klog.InfoS("Pod status updated", "pod", "kubedns", "status", "ready")
}

输出

代码语言:javascript
复制
hello by Info
hello by InfoDepth 0
hello by InfoDepth 1
hello by Infoln
hello by Infof
"Pod status updated" pod="kubedns" status="ready"

默认带header输出如下

代码语言:javascript
复制
I1229 23:45:57.827487    2176 klog_demo.go:41] hello by Info
I1229 23:45:57.827591    2176 klog_demo.go:42] hello by InfoDepth 0
I1229 23:45:57.827600    2176 klog_demo.go:31] hello by InfoDepth 1
I1229 23:45:57.827605    2176 klog_demo.go:44] hello by Infoln
I1229 23:45:57.827608    2176 klog_demo.go:45] hello by Infof
I1229 23:45:57.827617    2176 klog_demo.go:46] "Pod status updated" pod="kubedns" status="ready"

小结

如果设置klog的skip_headers为true,则其l.skipHeaders为true,则不会格式化并输出header信息。

doc

  • klog
本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2020-12-29,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 码匠的流水账 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • println
  • header
  • formatHeader
  • 实例
  • 小结
  • doc
相关产品与服务
容器服务
腾讯云容器服务(Tencent Kubernetes Engine, TKE)基于原生 kubernetes 提供以容器为核心的、高度可扩展的高性能容器管理服务,覆盖 Serverless、边缘计算、分布式云等多种业务部署场景,业内首创单个集群兼容多种计算节点的容器资源管理模式。同时产品作为云原生 Finops 领先布道者,主导开源项目Crane,全面助力客户实现资源优化、成本控制。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档