mirror of
				https://github.com/coredns/coredns.git
				synced 2025-10-31 10:13:14 -04:00 
			
		
		
		
	* New plugin: loop Add a plugin that detects loops. It does this by sending an unique query to our selves. If we see the query more than twice we stop the process. If there isn't a loop, the plugin disables it self and becomes a noop plugin. Signed-off-by: Miek Gieben <miek@miek.nl>
		
			
				
	
	
		
			69 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			69 lines
		
	
	
		
			1.7 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| package log
 | |
| 
 | |
| import (
 | |
| 	"fmt"
 | |
| 	golog "log"
 | |
| 	"os"
 | |
| )
 | |
| 
 | |
| // P is a logger that includes the plugin doing the logging.
 | |
| type P struct {
 | |
| 	plugin string
 | |
| }
 | |
| 
 | |
| // NewWithPlugin returns a logger that includes "plugin/name: " in the log message.
 | |
| // I.e [INFO] plugin/<name>: message.
 | |
| func NewWithPlugin(name string) P { return P{name} }
 | |
| 
 | |
| func (p P) logf(level, format string, v ...interface{}) {
 | |
| 	s := level + pFormat(p.plugin) + fmt.Sprintf(format, v...)
 | |
| 	golog.Print(s)
 | |
| }
 | |
| 
 | |
| func (p P) log(level string, v ...interface{}) {
 | |
| 	s := level + pFormat(p.plugin) + fmt.Sprint(v...)
 | |
| 	golog.Print(s)
 | |
| }
 | |
| 
 | |
| // Debug logs as log.Debug.
 | |
| func (p P) Debug(v ...interface{}) {
 | |
| 	if !D {
 | |
| 		return
 | |
| 	}
 | |
| 	p.log(debug, v...)
 | |
| }
 | |
| 
 | |
| // Debugf logs as log.Debugf.
 | |
| func (p P) Debugf(format string, v ...interface{}) {
 | |
| 	if !D {
 | |
| 		return
 | |
| 	}
 | |
| 	p.logf(debug, format, v...)
 | |
| }
 | |
| 
 | |
| // Info logs as log.Info.
 | |
| func (p P) Info(v ...interface{}) { p.log(info, v...) }
 | |
| 
 | |
| // Infof logs as log.Infof.
 | |
| func (p P) Infof(format string, v ...interface{}) { p.logf(info, format, v...) }
 | |
| 
 | |
| // Warning logs as log.Warning.
 | |
| func (p P) Warning(v ...interface{}) { p.log(warning, v...) }
 | |
| 
 | |
| // Warningf logs as log.Warningf.
 | |
| func (p P) Warningf(format string, v ...interface{}) { p.logf(warning, format, v...) }
 | |
| 
 | |
| // Error logs as log.Error.
 | |
| func (p P) Error(v ...interface{}) { p.log(err, v...) }
 | |
| 
 | |
| // Errorf logs as log.Errorf.
 | |
| func (p P) Errorf(format string, v ...interface{}) { p.logf(err, format, v...) }
 | |
| 
 | |
| // Fatal logs as log.Fatal and calls os.Exit(1).
 | |
| func (p P) Fatal(v ...interface{}) { p.log(fatal, v...); os.Exit(1) }
 | |
| 
 | |
| // Fatalf logs as log.Fatalf and calls os.Exit(1).
 | |
| func (p P) Fatalf(format string, v ...interface{}) { p.logf(fatal, format, v...); os.Exit(1) }
 | |
| 
 | |
| func pFormat(s string) string { return "plugin/" + s + ": " }
 |