qlog/elog.go at main · FortuneW/qlog · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
package qlog

import (
	"fmt"

	"github.com/FortuneW/qlog/internal"
)

// 只是一个日志通道不做真实存储和打印,在子进程中写入管道等待主进程获取即可
type eLogger struct {
	moduleName string
	traceId    string
}

type ELogItem struct {
	Level   uint32
	Content string
}

var eLogItems = make(chan *ELogItem, 1024)

func sendToELogItems(item *ELogItem) {
	select {
	case eLogItems <- item:
	default:
	}
}

func (e eLogger) Trace(args ...interface{}) {
	val := fmt.Sprint(args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.TraceLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelTrace, e.formatMessage(val)),
	})
}

func (e eLogger) Debug(args ...interface{}) {
	val := fmt.Sprint(args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.DebugLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelDebug, e.formatMessage(val)),
	})
}

func (e eLogger) Info(args ...interface{}) {
	val := fmt.Sprint(args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.InfoLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelInfo, e.formatMessage(val)),
	})
}

func (e eLogger) Warn(args ...interface{}) {
	val := fmt.Sprint(args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.WarnLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelWarn, e.formatMessage(val)),
	})
}

func (e eLogger) Error(args ...interface{}) {
	val := fmt.Sprint(args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.ErrorLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelError, e.formatMessage(val)),
	})
}

func (e eLogger) Tracef(format string, args ...interface{}) {
	val := fmt.Sprintf(format, args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.TraceLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelTrace, e.formatMessage(val)),
	})
}

func (e eLogger) Debugf(format string, args ...interface{}) {
	val := fmt.Sprintf(format, args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.DebugLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelDebug, e.formatMessage(val)),
	})
}

func (e eLogger) Infof(format string, args ...interface{}) {
	val := fmt.Sprintf(format, args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.InfoLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelInfo, e.formatMessage(val)),
	})
}

func (e eLogger) Warnf(format string, args ...interface{}) {
	val := fmt.Sprintf(format, args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.WarnLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelWarn, e.formatMessage(val)),
	})
}

func (e eLogger) Errorf(format string, args ...interface{}) {
	val := fmt.Sprintf(format, args...)
	if len(val) == 0 {
		return
	}
	sendToELogItems(&ELogItem{
		Level:   internal.ErrorLevel,
		Content: internal.GetOutputStringFormatted(internal.LevelError, e.formatMessage(val)),
	})
}

// WriteELogItem elog 本身不用实现写入函数,统一由主进程的ALog负责写入
func (e eLogger) WriteELogItem(item *ELogItem) {
	return
}

// GetPopELogItemChannel 获取回去的日志通道调用者不可以close,如果担心外部线程长期阻塞或需要中断时，外面可以通过select实现
func (e eLogger) GetPopELogItemChannel() chan *ELogItem {
	return eLogItems
}

func (e eLogger) WithTraceId(traceId string) RLogger {
	return &eLogger{moduleName: e.moduleName, traceId: traceId}
}

func (e eLogger) formatMessage(msg string) string {
	if e.traceId != "" {
		return fmt.Sprintf("[%s] [%s] %s", e.moduleName, e.traceId, msg)
	}
	return fmt.Sprintf("[%s] %s", e.moduleName, msg)
}