syslog writer

writer.go

@@ -22,7 +22,9 @@ package zap
 
 import (
  "io/ioutil"
+ "log/syslog"
  "os"
+ p "path"
 
  "go.uber.org/zap/zapcore"
 
@@ -65,6 +67,28 @@ func open(paths []string) ([]zapcore.WriteSyncer, func(), error) {
  writers = append(writers, os.Stderr)
  // Don't close standard error.
  continue
+ case "syslog":
+ // returns address for syslog to write on
+ syslogAddress, ok := os.LookupEnv("SYSLOG")
+ if !ok || (syslogAddress == "0") || (syslogAddress == "false") {
+ continue
+ }
+
+ // returns name of application that called logger to be used as value of tag in syslog connection
+ // or uses specific tag from env
+ syslogTag := p.Base(os.Args[0])
+ if tag, ok := os.LookupEnv("SYSLOG_TAG"); ok {
+ syslogTag = tag
+ }
+
+ // establishes connection via udp to specific address and returns writer
+ sys, err := syslog.Dial("udp", syslogAddress, syslog.LOG_LOCAL5, syslogTag)
+ if err != nil {
+ continue
+ }
+
+ writers = append(writers, AddSync(sys))
+ continue
  }
  f, err := os.OpenFile(path, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0644)
  openErr = multierr.Append(openErr, err)

writer_test.go

@@ -21,12 +21,15 @@
 package zap
 
 import (
+ "fmt"
  "io/ioutil"
+ "log/syslog"
  "os"
  "testing"
 
  "github.com/stretchr/testify/assert"
  "github.com/stretchr/testify/require"
+ "go.uber.org/zap"
  "go.uber.org/zap/zapcore"
 )
 
@@ -123,3 +126,20 @@ func TestCombineWriteSyncers(t *testing.T) {
  w := CombineWriteSyncers(tw)
  w.Write([]byte("test"))
 }
+
+func TestSyslogConnection(t *testing.T) {
+ sysLog, err := syslog.Dial("udp", "127.0.0.1:514", syslog.LOG_LOCAL5, "testtag")
+ if err != nil {
+ fmt.Println(err)
+ }
+ sysLog.Write([]byte("test"))
+}
+
+func TestSyslog(t *testing.T) {
+ // needs to be tested with env
+ config := zap.NewProductionConfig()
+ config.OutputPaths = "syslog"
+ logger, _ := config.Build()
+ defer logger.Sync()
+ logger.Info("msg")
+}