update deps
This commit is contained in:
parent
ec1d21254d
commit
82a1a185d4
2
go.mod
2
go.mod
|
@ -2,4 +2,4 @@ module git.kingecg.top/kingecg/godaemon
|
||||||
|
|
||||||
go 1.19
|
go 1.19
|
||||||
|
|
||||||
require git.kingecg.top/kingecg/gologger v1.0.4 // indirect
|
require git.kingecg.top/kingecg/gologger v1.0.10
|
||||||
|
|
6
go.sum
6
go.sum
|
@ -1,4 +1,2 @@
|
||||||
git.kingecg.top/kingecg/gologger v1.0.1 h1:snCb0ePlfDUglX+CHwNzq5MRK5uNTnPUks1Dnapl/p8=
|
git.kingecg.top/kingecg/gologger v1.0.10 h1:o6CNJ3TM9wOnKsV0hNasSSmZXEOMl5mBXZDnKJnC0a0=
|
||||||
git.kingecg.top/kingecg/gologger v1.0.1/go.mod h1:SNSl2jRHPzIpHSzdKOoVG798rtYMjPDPFyxUrEgivkY=
|
git.kingecg.top/kingecg/gologger v1.0.10/go.mod h1:auMA7VGipqttnF0jmtclhbaIr08gqtVPj6BSMknHTOE=
|
||||||
git.kingecg.top/kingecg/gologger v1.0.4 h1:uSStqVw1H1hPTbRiIhRBOxHMw/tRWMZEvsspIKnNpGk=
|
|
||||||
git.kingecg.top/kingecg/gologger v1.0.4/go.mod h1:SNSl2jRHPzIpHSzdKOoVG798rtYMjPDPFyxUrEgivkY=
|
|
||||||
|
|
|
@ -1,18 +0,0 @@
|
||||||
# ---> Go
|
|
||||||
# Binaries for programs and plugins
|
|
||||||
*.exe
|
|
||||||
*.exe~
|
|
||||||
*.dll
|
|
||||||
*.so
|
|
||||||
*.dylib
|
|
||||||
|
|
||||||
# Test binary, built with `go test -c`
|
|
||||||
*.test
|
|
||||||
|
|
||||||
# Output of the go coverage tool, specifically when used with LiteIDE
|
|
||||||
*.out
|
|
||||||
|
|
||||||
# Dependency directories (remove the comment below to include it)
|
|
||||||
# vendor/
|
|
||||||
|
|
||||||
log/
|
|
|
@ -1,3 +0,0 @@
|
||||||
# gologger
|
|
||||||
|
|
||||||
a logger used in go
|
|
|
@ -1,49 +0,0 @@
|
||||||
package gologger
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
)
|
|
||||||
|
|
||||||
const (
|
|
||||||
ErrorTemplate = "\033[1;31m%s\033[0m"
|
|
||||||
WarnTemplate = "\033[1;33m%s\033[0m"
|
|
||||||
InfoTemplate = "\033[1;32m%s\033[0m"
|
|
||||||
DebugTemplate = "\033[1;34m%s\033[0m"
|
|
||||||
TraceTemplate = "\033[1;35m%s\033[0m"
|
|
||||||
)
|
|
||||||
|
|
||||||
type ConsoleAppender struct {
|
|
||||||
}
|
|
||||||
|
|
||||||
// Close implements LoggerAppender.
|
|
||||||
func (c *ConsoleAppender) Close() {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *ConsoleAppender) GetName() string {
|
|
||||||
return "console"
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *ConsoleAppender) Append(logEvent LogEvent) {
|
|
||||||
|
|
||||||
logMsg := format(logEvent)
|
|
||||||
switch logEvent.Level {
|
|
||||||
case Error:
|
|
||||||
fmt.Printf(ErrorTemplate, logMsg)
|
|
||||||
case Warn:
|
|
||||||
fmt.Printf(WarnTemplate, logMsg)
|
|
||||||
case Info:
|
|
||||||
fmt.Printf(InfoTemplate, logMsg)
|
|
||||||
case Debug:
|
|
||||||
fmt.Printf(DebugTemplate, logMsg)
|
|
||||||
case Trace:
|
|
||||||
fmt.Printf(TraceTemplate, logMsg)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
func makeConsoleAppender(appenderConfig LogAppenderConfig) *LoggerAppender {
|
|
||||||
var appender LoggerAppender = &ConsoleAppender{}
|
|
||||||
return &appender
|
|
||||||
}
|
|
||||||
func init() {
|
|
||||||
RegistAppender("console", makeConsoleAppender)
|
|
||||||
}
|
|
|
@ -1,74 +0,0 @@
|
||||||
package gologger
|
|
||||||
|
|
||||||
import (
|
|
||||||
"os"
|
|
||||||
"path/filepath"
|
|
||||||
)
|
|
||||||
|
|
||||||
type FileAppender struct {
|
|
||||||
filePath string
|
|
||||||
lchan chan LogEvent
|
|
||||||
file *os.File
|
|
||||||
stopChan chan struct{}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Close implements LoggerAppender.
|
|
||||||
func (f *FileAppender) Close() {
|
|
||||||
//send stop signal
|
|
||||||
f.stopChan <- struct{}{}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (f *FileAppender) GetName() string {
|
|
||||||
return "FileAppender:" + f.filePath
|
|
||||||
}
|
|
||||||
|
|
||||||
func (f *FileAppender) start() {
|
|
||||||
f.lchan = make(chan LogEvent, 10)
|
|
||||||
f.stopChan = make(chan struct{})
|
|
||||||
if f.file == nil || int(f.file.Fd()) == -1 {
|
|
||||||
dirName := filepath.Dir(f.filePath)
|
|
||||||
_, err := os.Stat(dirName)
|
|
||||||
if err != nil && os.IsNotExist(err) {
|
|
||||||
os.MkdirAll(dirName, 0755)
|
|
||||||
}
|
|
||||||
f.file, _ = os.OpenFile(f.filePath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644)
|
|
||||||
}
|
|
||||||
|
|
||||||
go func() {
|
|
||||||
defer f.file.Close()
|
|
||||||
for {
|
|
||||||
select {
|
|
||||||
case <-f.stopChan:
|
|
||||||
return
|
|
||||||
case logEvent := <-f.lchan:
|
|
||||||
logMsg := format(logEvent)
|
|
||||||
f.file.WriteString(logMsg)
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
}
|
|
||||||
func (f *FileAppender) Append(logEvent LogEvent) {
|
|
||||||
|
|
||||||
f.lchan <- logEvent
|
|
||||||
}
|
|
||||||
|
|
||||||
func makeFileAppender(appenderConfig LogAppenderConfig) *LoggerAppender {
|
|
||||||
var logfile interface{}
|
|
||||||
var ok bool
|
|
||||||
logfile, ok = appenderConfig.Options["file"]
|
|
||||||
if !ok {
|
|
||||||
logfile = "default.log"
|
|
||||||
}
|
|
||||||
var ret LoggerAppender = &FileAppender{
|
|
||||||
filePath: logfile.(string),
|
|
||||||
}
|
|
||||||
|
|
||||||
ret.(*FileAppender).start()
|
|
||||||
|
|
||||||
return &ret
|
|
||||||
}
|
|
||||||
|
|
||||||
func init() {
|
|
||||||
RegistAppender("file", makeFileAppender)
|
|
||||||
}
|
|
|
@ -1,53 +0,0 @@
|
||||||
package gologger
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"strings"
|
|
||||||
)
|
|
||||||
|
|
||||||
const logTemplate = "[%s] %s : %s - %s\n"
|
|
||||||
|
|
||||||
func format(logEvent LogEvent) string {
|
|
||||||
data := logEvent.Ts.Format("2006-01-02 15:04:05")
|
|
||||||
msg := ""
|
|
||||||
firstMsg := logEvent.Data[0]
|
|
||||||
if isFormatString(firstMsg) {
|
|
||||||
msg = fmt.Sprintf(firstMsg.(string), logEvent.Data[1:]...)
|
|
||||||
} else {
|
|
||||||
msg = sprint(logEvent.Data)
|
|
||||||
}
|
|
||||||
|
|
||||||
ret := fmt.Sprintf(logTemplate, data, logEvent.Category, getLogLevelStr(logEvent.Level), msg)
|
|
||||||
return ret
|
|
||||||
}
|
|
||||||
|
|
||||||
func getLogLevelStr(level int) string {
|
|
||||||
for name, slevel := range logLevelMap {
|
|
||||||
if slevel == level {
|
|
||||||
return strings.ToUpper(name)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return "Unknown"
|
|
||||||
}
|
|
||||||
|
|
||||||
func isFormatString(f interface{}) bool {
|
|
||||||
s, ok := f.(string)
|
|
||||||
if !ok {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
// 尝试使用空接口来格式化字符串
|
|
||||||
m := fmt.Sprintf(s, []interface{}{}...)
|
|
||||||
return strings.Index(m, "MISSING") != -1
|
|
||||||
}
|
|
||||||
|
|
||||||
func sprint(s []interface{}) string {
|
|
||||||
str := make([]any, len(s))
|
|
||||||
for i, v := range s {
|
|
||||||
if i > 0 {
|
|
||||||
str[i] = fmt.Sprintf(" %v", v)
|
|
||||||
} else {
|
|
||||||
str[i] = fmt.Sprintf("%v", v)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return fmt.Sprint(str...)
|
|
||||||
}
|
|
|
@ -1,153 +0,0 @@
|
||||||
package gologger
|
|
||||||
|
|
||||||
import (
|
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
const (
|
|
||||||
NoLog = iota
|
|
||||||
Error
|
|
||||||
Warn
|
|
||||||
Info
|
|
||||||
Debug
|
|
||||||
Trace
|
|
||||||
)
|
|
||||||
|
|
||||||
var logLevelMap map[string]int = map[string]int{
|
|
||||||
"off": NoLog,
|
|
||||||
"error": Error,
|
|
||||||
"warn": Warn,
|
|
||||||
"info": Info,
|
|
||||||
"debug": Debug,
|
|
||||||
"trace": Trace,
|
|
||||||
}
|
|
||||||
var loggerMap map[string]*Logger = map[string]*Logger{}
|
|
||||||
var appenderFactoryMap map[string]func(LogAppenderConfig) *LoggerAppender = map[string]func(LogAppenderConfig) *LoggerAppender{}
|
|
||||||
var appenders map[string]*LoggerAppender = map[string]*LoggerAppender{}
|
|
||||||
var loggerConfig LoggersConfig
|
|
||||||
|
|
||||||
type LogAppenderConfig struct {
|
|
||||||
Type string `json:"type"`
|
|
||||||
Options map[string]interface{} `json:"options"`
|
|
||||||
}
|
|
||||||
type LogConfig struct {
|
|
||||||
Level string `json:"level"`
|
|
||||||
Appenders []string `json:"appenders"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type LoggersConfig struct {
|
|
||||||
Appenders map[string]LogAppenderConfig `json:"appenders"`
|
|
||||||
Categories map[string]LogConfig `json:"categories"`
|
|
||||||
}
|
|
||||||
type Logger struct {
|
|
||||||
category string
|
|
||||||
level int
|
|
||||||
appenders []*LoggerAppender
|
|
||||||
}
|
|
||||||
|
|
||||||
type LogEvent struct {
|
|
||||||
Category string
|
|
||||||
Ts time.Time
|
|
||||||
Level int
|
|
||||||
Data []interface{}
|
|
||||||
}
|
|
||||||
|
|
||||||
type LoggerAppender interface {
|
|
||||||
GetName() string
|
|
||||||
Append(logEvent LogEvent)
|
|
||||||
Close()
|
|
||||||
}
|
|
||||||
|
|
||||||
var consoleAppender LoggerAppender = &ConsoleAppender{}
|
|
||||||
var defaultLogger = &Logger{
|
|
||||||
|
|
||||||
level: Error,
|
|
||||||
appenders: []*LoggerAppender{&consoleAppender},
|
|
||||||
}
|
|
||||||
|
|
||||||
func (l *Logger) log(Level int, msg []interface{}) {
|
|
||||||
|
|
||||||
if Level <= l.level {
|
|
||||||
now := time.Now()
|
|
||||||
logEvent := LogEvent{l.category, now, Level, msg}
|
|
||||||
for _, appender := range l.appenders {
|
|
||||||
(*appender).Append(logEvent)
|
|
||||||
}
|
|
||||||
// l.Appender.Append(logEvent)
|
|
||||||
// fmt.Println(now.Format("2006-01-02 15:04:05"), " ", l.Name, ": ", msg)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (l *Logger) Error(msg ...interface{}) {
|
|
||||||
l.log(Error, msg)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (l *Logger) Warn(msg ...interface{}) {
|
|
||||||
l.log(Warn, msg)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (l *Logger) Info(msg ...interface{}) {
|
|
||||||
l.log(Info, msg)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (l *Logger) Debug(msg ...interface{}) {
|
|
||||||
l.log(Debug, msg)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (l *Logger) Trace(msg ...interface{}) {
|
|
||||||
l.log(Trace, msg)
|
|
||||||
}
|
|
||||||
func GetLogger(name string) *Logger {
|
|
||||||
if logger, ok := loggerMap[name]; ok {
|
|
||||||
return logger
|
|
||||||
} else {
|
|
||||||
logConfig, ok := loggerConfig.Categories[name]
|
|
||||||
if ok {
|
|
||||||
return makeLogger(name, logConfig)
|
|
||||||
}
|
|
||||||
if name == "default" {
|
|
||||||
return defaultLogger
|
|
||||||
}
|
|
||||||
l := *GetLogger("default")
|
|
||||||
l.category = name
|
|
||||||
loggerMap[name] = &l
|
|
||||||
return &l
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func makeLogger(name string, config LogConfig) *Logger {
|
|
||||||
logger := &Logger{category: name}
|
|
||||||
levelstr := strings.ToLower(config.Level)
|
|
||||||
logger.level = logLevelMap[levelstr]
|
|
||||||
|
|
||||||
if config.Appenders == nil || len(config.Appenders) == 0 {
|
|
||||||
logger.appenders = []*LoggerAppender{&consoleAppender}
|
|
||||||
} else {
|
|
||||||
logger.appenders = make([]*LoggerAppender, len(config.Appenders))
|
|
||||||
for i, appenderName := range config.Appenders {
|
|
||||||
logger.appenders[i] = appenders[appenderName]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
loggerMap[name] = logger
|
|
||||||
return logger
|
|
||||||
}
|
|
||||||
func Configure(config LoggersConfig) {
|
|
||||||
loggerConfig = config
|
|
||||||
for name, appenderConfig := range loggerConfig.Appenders {
|
|
||||||
appenderFactory, ok := appenderFactoryMap[appenderConfig.Type]
|
|
||||||
if ok {
|
|
||||||
appenders[name] = appenderFactory(appenderConfig)
|
|
||||||
} else {
|
|
||||||
appenders[name] = &consoleAppender
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for name, _ := range loggerConfig.Categories {
|
|
||||||
GetLogger(name)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func RegistAppender(typeName string, appenderCreatCb func(LogAppenderConfig) *LoggerAppender) {
|
|
||||||
|
|
||||||
appenderFactoryMap[typeName] = appenderCreatCb
|
|
||||||
}
|
|
|
@ -1,3 +1,3 @@
|
||||||
# git.pyer.club/kingecg/gologger v1.0.4
|
# git.kingecg.top/kingecg/gologger v1.0.10
|
||||||
## explicit; go 1.19
|
## explicit; go 1.19
|
||||||
git.pyer.club/kingecg/gologger
|
git.kingecg.top/kingecg/gologger
|
||||||
|
|
Loading…
Reference in New Issue