mirror of
https://github.com/langhuihui/monibuca.git
synced 2025-10-28 12:41:27 +08:00
48 lines
1.3 KiB
Go
48 lines
1.3 KiB
Go
package plugin_vmlog
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlselect"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlstorage"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/lib/fs"
|
|
"log/slog"
|
|
"m7s.live/m7s/v5"
|
|
"net/http"
|
|
//"m7s.live/m7s/v5/plugin/logrotate/pb"
|
|
)
|
|
|
|
// todo 配置
|
|
type VmLogPlugin struct {
|
|
m7s.Plugin
|
|
//Path string `default:"./logs" desc:"日志文件存放目录"`
|
|
//Size uint64 `default:"1048576" desc:"日志文件大小，单位：字节"`
|
|
//Days int `default:"1" desc:"日志文件保留天数"`
|
|
//Formatter string `default:"2006-01-02T15" desc:"日志文件名格式"`
|
|
//MaxFiles uint64 `default:"7" desc:"最大日志文件数量"`
|
|
//Level string `default:"info" desc:"日志级别"`
|
|
handler slog.Handler
|
|
}
|
|
|
|
var _ = m7s.InstallPlugin[VmLogPlugin]()
|
|
|
|
func (config *VmLogPlugin) OnInit() (err error) {
|
|
config.handler, err = NewVmLogHandler(nil, nil)
|
|
if err == nil {
|
|
config.AddLogHandler(config.handler)
|
|
}
|
|
return
|
|
}
|
|
|
|
func (config *VmLogPlugin) OnExit() {
|
|
vlinsert.Stop()
|
|
vlselect.Stop()
|
|
vlstorage.Stop()
|
|
fs.MustStopDirRemover()
|
|
fmt.Print("VmLogPlugin OnClose")
|
|
}
|
|
|
|
func (config *VmLogPlugin) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
|
|
requestHandler(rw, r)
|
|
}
|