add async write rotate log handler

log/handler.go

@@ -5,6 +5,7 @@ import (
  "io"
  "net"
  "os"
+ "path"
  "reflect"
  "sync"
 
@@ -70,6 +71,21 @@ func FileHandler(path string, fmtr Format) (Handler, error) {
  return closingHandler{f, StreamHandler(f, fmtr)}, nil
 }
 
+// RotatingFileHandler returns a handler which writes log records to file chunks
+// at the given path. When a file's size reaches the limit, the handler creates
+// a new file named after the timestamp of the first log record it will contain.
+func RotatingFileHandler(filePath string, limit uint, formatter Format) (Handler, error) {
+ if _, err := os.Stat(path.Dir(filePath)); os.IsNotExist(err) {
+ err := os.MkdirAll(path.Dir(filePath), 0755)
+ if err != nil {
+ return nil, fmt.Errorf("could not create directory %s, %v", path.Dir(filePath), err)
+ }
+ }
+ fileWriter := NewAsyncFileWriter(filePath, int64(limit))
+ fileWriter.Start()
+ return StreamHandler(fileWriter, formatter), nil
+}
+
 // NetHandler opens a socket to the given address and writes records
 // over the connection.
 func NetHandler(network, addr string, fmtr Format) (Handler, error) {

log/logger.go

@@ -243,3 +243,19 @@ func (c Ctx) toArray() []interface{} {
 
  return arr
 }
+
+func NewFileLvlHandler(logPath string, maxBytesSize uint, level string) Handler {
+ rfh, err := RotatingFileHandler(
+ logPath,
+ maxBytesSize,
+ LogfmtFormat(),
+ )
+ if err != nil {
+ panic(err)
+ }
+ logLevel, err := LvlFromString(level)
+ if err != nil {
+ panic(err)
+ }
+ return LvlFilterHandler(logLevel, rfh)
+}