Add syslog Writer

flog.go

@@ -4,6 +4,8 @@ import (
 	"compress/gzip"
 	"fmt"
 	"io"
+	"log/syslog"
+	"net/url"
 	"os"
 	"path/filepath"
 	"strconv"
@@ -29,8 +31,8 @@ func Generate(option *Option) error {
 		interval = option.Sleep
 	}
 
-	logFileName := option.Output
-	writer, err := NewWriter(option.Type, logFileName)
+	outPut := option.Output
+	writer, err := NewWriter(option.Type, outPut)
 	if err != nil {
 		return err
 	}
@@ -53,10 +55,10 @@ func Generate(option *Option) error {
 
 			if (option.Type != "stdout") && (option.SplitBy > 0) && (line > option.SplitBy*splitCount) {
 				_ = writer.Close()
-				fmt.Println(logFileName, "is created.")
+				fmt.Println(outPut, "is created.")
 
-				logFileName = NewSplitFileName(option.Output, splitCount)
-				writer, _ = NewWriter(option.Type, logFileName)
+				outPut = NewSplitFileName(option.Output, splitCount)
+				writer, _ = NewWriter(option.Type, outPut)
 
 				splitCount++
 			}
@@ -73,10 +75,10 @@ func Generate(option *Option) error {
 			bytes += len(log)
 			if (option.Type != "stdout") && (option.SplitBy > 0) && (bytes > option.SplitBy*splitCount+1) {
 				_ = writer.Close()
-				fmt.Println(logFileName, "is created.")
+				fmt.Println(outPut, "is created.")
 
-				logFileName = NewSplitFileName(option.Output, splitCount)
-				writer, _ = NewWriter(option.Type, logFileName)
+				outPut = NewSplitFileName(option.Output, splitCount)
+				writer, _ = NewWriter(option.Type, outPut)
 
 				splitCount++
 			}
@@ -86,23 +88,38 @@ func Generate(option *Option) error {
 
 	if option.Type != "stdout" {
 		_ = writer.Close()
-		fmt.Println(logFileName, "is created.")
+		fmt.Println(outPut, "is created.")
 	}
 	return nil
 }
 
 // NewWriter returns a closeable writer corresponding to given log type
-func NewWriter(logType string, logFileName string) (io.WriteCloser, error) {
+func NewWriter(logType string, outPut string) (io.WriteCloser, error) {
 	switch logType {
 	case "stdout":
 		return os.Stdout, nil
+	case "syslog":
+		connectionString := outPut
+		conn, err := url.Parse(connectionString)
+		if err != nil {
+			return nil, err
+		}
+
+		sysLog, err := syslog.Dial(conn.Scheme, conn.Host, syslog.LOG_WARNING|syslog.LOG_DAEMON, "demotag")
+		if err != nil {
+			return nil, err
+		}
+
+		return sysLog, nil
 	case "log":
+		logFileName := outPut
 		logFile, err := os.Create(logFileName)
 		if err != nil {
 			return nil, err
 		}
 		return logFile, nil
 	case "gz":
+		logFileName := outPut
 		logFile, err := os.Create(logFileName)
 		if err != nil {
 			return nil, err

flog_test.go

@@ -11,7 +11,7 @@ import (
 )
 
 func ExampleNewLog() {
-	rand.Seed(11)
+	rand.New(rand.NewSource(11))
 
 	monkey.Patch(time.Now, func() time.Time { return stopped })
 	defer monkey.Unpatch(time.Now)

main.go

@@ -8,7 +8,7 @@ import (
 )
 
 func main() {
-	rand.Seed(time.Now().UnixNano())
+	rand.NewSource(time.Now().UnixNano())
 	opts := ParseOptions()
 	if err := Run(opts); err != nil {
 		cfmt.Warningln(err.Error())

option.go

@@ -3,6 +3,7 @@ package main
 import (
 	"errors"
 	"fmt"
+	"net/url"
 	"os"
 	"strconv"
 	"strings"
@@ -46,7 +47,7 @@ Options:
 `
 
 var validFormats = []string{"apache_common", "apache_combined", "apache_error", "rfc3164", "rfc5424", "common_log", "json"}
-var validTypes = []string{"stdout", "log", "gz"}
+var validTypes = []string{"stdout", "syslog", "log", "gz"}
 
 // Option defines log generator options
 type Option struct {
@@ -173,7 +174,7 @@ func ParseOptions() *Option {
 	help := pflag.BoolP("help", "h", false, "Show this help message")
 	version := pflag.BoolP("version", "v", false, "Show version")
 	format := pflag.StringP("format", "f", opts.Format, "Log format")
-	output := pflag.StringP("output", "o", opts.Output, "Path-like output filename")
+	output := pflag.StringP("output", "o", opts.Output, "Path-like output filename or IP address (for syslog)")
 	logType := pflag.StringP("type", "t", opts.Type, "Log output type")
 	number := pflag.IntP("number", "n", opts.Number, "Number of lines to generate")
 	bytes := pflag.IntP("bytes", "b", opts.Bytes, "Size of logs to generate. (in bytes)")
@@ -214,6 +215,18 @@ func ParseOptions() *Option {
 	if opts.SplitBy, err = ParseSplitBy(*splitBy); err != nil {
 		errorExit(err)
 	}
+
+	if opts.Type == "syslog" {
+		connectionString := *output
+		conn, err := url.Parse(connectionString)
+		if err != nil {
+			errorExit(err)
+		}
+		if (conn.Scheme == "" || conn.Host == "") || conn.Port() == "" {
+			errorExit(errors.New("invalid syslog address format. Please use the format: protocol://host:port (e.g. udp://localhost:514)"))
+		}
+	}
+
 	opts.Output = *output
 	opts.Overwrite = *overwrite
 	opts.Forever = *forever