mirror of
https://github.com/foxcpp/maddy.git
synced 2025-04-04 13:37:41 +03:00
feb1507c75
Now they are represented by implementations of the log.Output interface instead of just callbacks. This allows to add additional methods to it. Mainly, it was done for purpose of Close method for flushing and closing log files. This is important to make runtime logger reinitialization (e.g. log rotation) possible. Additionally, documentation now explains goroutine-safety of logger objects.
72 lines
1.7 KiB
Go
72 lines
1.7 KiB
Go
package maddy
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"os"
|
|
|
|
"github.com/foxcpp/maddy/config"
|
|
"github.com/foxcpp/maddy/log"
|
|
)
|
|
|
|
/*
|
|
Config matchers for module interfaces.
|
|
*/
|
|
|
|
// logOut structure wraps log.Output and preserves
|
|
// configuration directive it was constructed from, allowing
|
|
// dynamic reinitialization for purposes of log file rotation.
|
|
type logOut struct {
|
|
args []string
|
|
log.Output
|
|
}
|
|
|
|
func logOutput(m *config.Map, node *config.Node) (interface{}, error) {
|
|
if len(node.Args) == 0 {
|
|
return nil, m.MatchErr("expected at least 1 argument")
|
|
}
|
|
if len(node.Children) != 0 {
|
|
return nil, m.MatchErr("can't declare block here")
|
|
}
|
|
|
|
return LogOutputOption(node.Args)
|
|
}
|
|
|
|
func LogOutputOption(args []string) (log.Output, error) {
|
|
outs := make([]log.Output, 0, len(args))
|
|
for _, arg := range args {
|
|
switch arg {
|
|
case "stderr":
|
|
outs = append(outs, log.WriterOutput(os.Stderr, false))
|
|
case "stderr_ts":
|
|
outs = append(outs, log.WriterOutput(os.Stderr, true))
|
|
case "syslog":
|
|
syslogOut, err := log.SyslogOutput()
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to connect to syslog daemon: %v", err)
|
|
}
|
|
outs = append(outs, syslogOut)
|
|
case "off":
|
|
if len(args) != 1 {
|
|
return nil, errors.New("'off' can't be combined with other log targets")
|
|
}
|
|
return nil, nil
|
|
default:
|
|
w, err := os.OpenFile(arg, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0666)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to create log file: %v", err)
|
|
}
|
|
|
|
outs = append(outs, log.WriteCloserOutput(w, true))
|
|
}
|
|
}
|
|
|
|
if len(outs) == 1 {
|
|
return logOut{args, outs[0]}, nil
|
|
}
|
|
return logOut{args, log.MultiOutput(outs...)}, nil
|
|
}
|
|
|
|
func defaultLogOutput() (interface{}, error) {
|
|
return log.DefaultLogger.Out, nil
|
|
}
|