Compare commits
5 Commits
Author | Date | ||
---|---|---|---|
a73906b74f | |||
![]() |
edecd4a8d7 | ||
![]() |
ec1b3b298f | ||
![]() |
6126b66f6a | ||
![]() |
e27ea9f370 |
16
global.go
16
global.go
@ -25,10 +25,14 @@ func Cleanup() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func SetLogLevel(newlv logLevel) (oldlv logLevel) {
|
func SetLogLevel(newlv LogLevel) (oldlv LogLevel) {
|
||||||
return mylog.SetLogLevel(newlv)
|
return mylog.SetLogLevel(newlv)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func SetLogLevelByName(newlv string) (oldlv string) {
|
||||||
|
return mylog.SetLogLevelByName(newlv)
|
||||||
|
}
|
||||||
|
|
||||||
func PrintPretty(prefix string, v interface{}) {
|
func PrintPretty(prefix string, v interface{}) {
|
||||||
mylog.PrintPretty(prefix, v)
|
mylog.PrintPretty(prefix, v)
|
||||||
}
|
}
|
||||||
@ -58,7 +62,7 @@ func Warningf(format string, v ...interface{}) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func Errorf(format string, v ...interface{}) {
|
func Errorf(format string, v ...interface{}) {
|
||||||
mylog.Warningf(format, v...)
|
mylog.Errorf(format, v...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func Panicf(format string, v ...interface{}) {
|
func Panicf(format string, v ...interface{}) {
|
||||||
@ -69,6 +73,14 @@ func Fatalf(format string, v ...interface{}) {
|
|||||||
mylog.Fatalf(format, v...)
|
mylog.Fatalf(format, v...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func Fatal(v ...interface{}){
|
||||||
|
mylog.Fatal(v...)
|
||||||
|
}
|
||||||
|
|
||||||
|
func Println(v ...interface{}){
|
||||||
|
mylog.Println(v...)
|
||||||
|
}
|
||||||
|
|
||||||
func TraceInto(format string, v ...interface{}) string {
|
func TraceInto(format string, v ...interface{}) string {
|
||||||
_, fn, line, _ := runtime.Caller(1)
|
_, fn, line, _ := runtime.Caller(1)
|
||||||
strfn := fmt.Sprintf("%s:%d", fn, line)
|
strfn := fmt.Sprintf("%s:%d", fn, line)
|
||||||
|
6
go.mod
6
go.mod
@ -2,4 +2,8 @@ module qoobing.com/gomod/log
|
|||||||
|
|
||||||
go 1.16
|
go 1.16
|
||||||
|
|
||||||
require qoobing.com/gomod/str v1.0.1
|
require (
|
||||||
|
github.com/tylerb/gls v0.0.0-20150407001822-e606233f194d
|
||||||
|
github.com/tylerb/is v2.1.4+incompatible // indirect
|
||||||
|
qoobing.com/gomod/str v1.0.1
|
||||||
|
)
|
||||||
|
107
log.go
107
log.go
@ -16,16 +16,38 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
PANIC logLevel = 0
|
PANIC LogLevel = 0
|
||||||
FATAL logLevel = 1
|
FATAL LogLevel = 1
|
||||||
ERROR logLevel = 2
|
ERROR LogLevel = 2
|
||||||
NOTICE logLevel = 3
|
NOTICE LogLevel = 3
|
||||||
WARNING logLevel = 4
|
WARNING LogLevel = 4
|
||||||
INFO logLevel = 5
|
INFO LogLevel = 5
|
||||||
DEBUG logLevel = 9
|
DEBUG LogLevel = 9
|
||||||
|
ErrLogLevel = "~~~~~invalid loglevel~~~~~"
|
||||||
ErrLogPanic = "~~~~panic~~~~~~"
|
ErrLogPanic = "~~~~panic~~~~~~"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
mapStrToLevel = map[string]LogLevel{
|
||||||
|
"PANIC": PANIC,
|
||||||
|
"FATAL": FATAL,
|
||||||
|
"ERROR": ERROR,
|
||||||
|
"NOTICE": NOTICE,
|
||||||
|
"WARNING": WARNING,
|
||||||
|
"INFO": INFO,
|
||||||
|
"DEBUG": DEBUG,
|
||||||
|
}
|
||||||
|
mapLevelToStr = map[LogLevel]string{
|
||||||
|
PANIC: "PANIC",
|
||||||
|
FATAL: "FATAL",
|
||||||
|
ERROR: "ERROR",
|
||||||
|
NOTICE: "NOTICE",
|
||||||
|
WARNING: "WARNING",
|
||||||
|
INFO: "INFO",
|
||||||
|
DEBUG: "DEBUG",
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
golog *log.Logger = nil
|
golog *log.Logger = nil
|
||||||
mylog *Logger = nil
|
mylog *Logger = nil
|
||||||
@ -33,11 +55,11 @@ var (
|
|||||||
modulelogs map[string]*Logger = map[string]*Logger{}
|
modulelogs map[string]*Logger = map[string]*Logger{}
|
||||||
)
|
)
|
||||||
|
|
||||||
type logLevel int
|
type LogLevel int
|
||||||
type Logger struct {
|
type Logger struct {
|
||||||
module string
|
module string
|
||||||
golog *log.Logger
|
golog *log.Logger
|
||||||
loglevel logLevel
|
loglevel LogLevel
|
||||||
}
|
}
|
||||||
|
|
||||||
type LogidCreator interface {
|
type LogidCreator interface {
|
||||||
@ -62,20 +84,41 @@ func New(module string) *Logger {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ////////////////////////////////////////////////////////////////
|
// SetLogLevel set new log level
|
||||||
func (log *Logger) SetLogLevel(newlv logLevel) (oldlv logLevel) {
|
func (log *Logger) SetLogLevel(newlv LogLevel) (oldlv LogLevel) {
|
||||||
oldlv = log.loglevel
|
oldlv = log.loglevel
|
||||||
log.loglevel = newlv
|
log.loglevel = newlv
|
||||||
return oldlv
|
return oldlv
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// SetLogLevelByName set new log level by level name
|
||||||
|
func (log *Logger) SetLogLevelByName(newlv string) (oldlv string) {
|
||||||
|
if newlevel, ok := mapStrToLevel[newlv]; ok {
|
||||||
|
oldlevel := log.loglevel
|
||||||
|
log.loglevel = newlevel
|
||||||
|
return mapLevelToStr[oldlevel]
|
||||||
|
}
|
||||||
|
return ErrLogLevel
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
func (log *Logger) Print(prefix string, v interface{}) {
|
func (log *Logger) Print(prefix string, v interface{}) {
|
||||||
preety, _ := json.Marshal(v)
|
var str = ""
|
||||||
log.logwrite(DEBUG, 3, prefix+"%s\n", preety)
|
if pkg, err := json.Marshal(v); err != nil {
|
||||||
|
str = err.Error()
|
||||||
|
} else {
|
||||||
|
str = string(pkg)
|
||||||
|
}
|
||||||
|
log.logwrite(DEBUG, 3, prefix+"%s\n", str)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (log *Logger) PrintPretty(prefix string, v interface{}) {
|
func (log *Logger) PrintPretty(prefix string, v interface{}) {
|
||||||
preety, _ := json.MarshalIndent(v, "==", " ")
|
var preety = ""
|
||||||
|
if pkg, err := json.MarshalIndent(v, "==", " "); err != nil {
|
||||||
|
preety = err.Error()
|
||||||
|
} else {
|
||||||
|
preety = string(pkg)
|
||||||
|
}
|
||||||
log.logwrite(DEBUG, 3, prefix+"%s\n", preety)
|
log.logwrite(DEBUG, 3, prefix+"%s\n", preety)
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -117,6 +160,15 @@ func (log *Logger) Panicf(format string, v ...interface{}) {
|
|||||||
log.logwrite(PANIC, 3, format, v...)
|
log.logwrite(PANIC, 3, format, v...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (log *Logger) Fatal(v ...interface{}){
|
||||||
|
log.logwrite(FATAL, 3, "%s", fmt.Sprintln(v...))
|
||||||
|
}
|
||||||
|
|
||||||
|
func (log *Logger) Println(v ...interface{}){
|
||||||
|
log.logwrite(DEBUG, 3, "%s", fmt.Sprintln(v...))
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
func (log *Logger) GetLogidStr(format string) string {
|
func (log *Logger) GetLogidStr(format string) string {
|
||||||
if logidCreator != nil {
|
if logidCreator != nil {
|
||||||
return fmt.Sprintf(format, logidCreator.GetLogid())
|
return fmt.Sprintf(format, logidCreator.GetLogid())
|
||||||
@ -124,7 +176,7 @@ func (log *Logger) GetLogidStr(format string) string {
|
|||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
func (log *Logger) logwrite(typ logLevel, calldepth int, format string, v ...interface{}) {
|
func (log *Logger) logwrite(typ LogLevel, calldepth int, format string, v ...interface{}) {
|
||||||
if typ > log.loglevel {
|
if typ > log.loglevel {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -143,7 +195,7 @@ func (log *Logger) logwrite(typ logLevel, calldepth int, format string, v ...int
|
|||||||
case WARNING:
|
case WARNING:
|
||||||
log.golog.SetPrefix("\x1b[32m" + "WARN ")
|
log.golog.SetPrefix("\x1b[32m" + "WARN ")
|
||||||
case ERROR:
|
case ERROR:
|
||||||
log.golog.SetPrefix("\x1b[32m" + "ERRO ")
|
log.golog.SetPrefix("\x1b[33m" + "ERRO ")
|
||||||
case INFO:
|
case INFO:
|
||||||
log.golog.SetPrefix("INFO ")
|
log.golog.SetPrefix("INFO ")
|
||||||
case NOTICE:
|
case NOTICE:
|
||||||
@ -184,6 +236,13 @@ func needWriteLogToFile() bool {
|
|||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func needWriteLogToStdout() bool {
|
||||||
|
if cls, ok := os.LookupEnv("QOOLOG_CLOSE_STDLOG"); ok && (cls == "Y" || cls == "y") {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
// //////////////////////////////////////////////////////////////////////////////////
|
// //////////////////////////////////////////////////////////////////////////////////
|
||||||
// ///////////////////////Initialize/////////////////////////////////////////////////
|
// ///////////////////////Initialize/////////////////////////////////////////////////
|
||||||
// //////////////////////////////////////////////////////////////////////////////////
|
// //////////////////////////////////////////////////////////////////////////////////
|
||||||
@ -206,14 +265,14 @@ func initlog() {
|
|||||||
gologFlags = log.Ldate | log.Lmicroseconds | log.Lshortfile
|
gologFlags = log.Ldate | log.Lmicroseconds | log.Lshortfile
|
||||||
)
|
)
|
||||||
|
|
||||||
// Step 2. init golog(golang std logger) & mylog(myself defined logger)
|
// Step 2.1 add stdout to base writer if need
|
||||||
golog = log.New(NewCacheWriter(baseWriter), "", gologFlags)
|
if needWriteLogToStdout() {
|
||||||
mylog = New("system")
|
baseWriter.stdw = os.Stdout
|
||||||
|
}
|
||||||
// Step 3. backgroud split log (log rotate) if need
|
// Step 2.2 rotate log(split log ) if need
|
||||||
if needWriteLogToFile() {
|
if needWriteLogToFile() {
|
||||||
go func() {
|
|
||||||
baseWriter.OpenLogFile(logDir, logName, logDirsOptional)
|
baseWriter.OpenLogFile(logDir, logName, logDirsOptional)
|
||||||
|
go func() {
|
||||||
for {
|
for {
|
||||||
tag := time.Now().Local().Format(logSplitTag)
|
tag := time.Now().Local().Format(logSplitTag)
|
||||||
baseWriter.TryBackupLogFile(tag)
|
baseWriter.TryBackupLogFile(tag)
|
||||||
@ -221,4 +280,8 @@ func initlog() {
|
|||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Step 3. init golog(golang std logger) & mylog(myself defined logger)
|
||||||
|
golog = log.New(NewCacheWriter(baseWriter), "", gologFlags)
|
||||||
|
mylog = New("system")
|
||||||
}
|
}
|
||||||
|
9
log_test.go
Normal file
9
log_test.go
Normal file
@ -0,0 +1,9 @@
|
|||||||
|
package log
|
||||||
|
|
||||||
|
import "testing"
|
||||||
|
|
||||||
|
func TestLog(t *testing.T) {
|
||||||
|
Println("aaa", 1,3)
|
||||||
|
Fatal("aaa", 1,3)
|
||||||
|
Fatalf("aaa=%d", 1)
|
||||||
|
}
|
@ -1,4 +1,5 @@
|
|||||||
// +build glslogid
|
// +build glslogid
|
||||||
|
|
||||||
package log
|
package log
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
@ -1,4 +1,5 @@
|
|||||||
// +build runtimelogid
|
// +build runtimelogid
|
||||||
|
|
||||||
package log
|
package log
|
||||||
|
|
||||||
//// Format writes the source file path and line number of the record to the buf.
|
//// Format writes the source file path and line number of the record to the buf.
|
||||||
|
Loading…
Reference in New Issue
Block a user