-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathfileAppender.go
More file actions
65 lines (54 loc) · 1.21 KB
/
fileAppender.go
File metadata and controls
65 lines (54 loc) · 1.21 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
package log
import "os"
import "fmt"
type FileAppender struct {
*BaseAppender
}
type FileAppenderProvider struct {
IAppenderProvider
File *os.File
filePath string
RolloverSize int64
}
// TODO: rollover
func NewFileAppender(file string, rolloverSize int64) *FileAppender {
f, err := os.OpenFile(file, os.O_APPEND | os.O_CREATE | os.O_WRONLY, 0644)
if err != nil {
panic(err)
}
fa := &FileAppender{
BaseAppender: NewBaseAppender(),
}
fa.AppenderProvider = &FileAppenderProvider{
File: f,
RolloverSize: rolloverSize,
filePath: file,
}
return fa
}
func (c *FileAppenderProvider) log(event *LoggingEvent) {
fi, err := c.File.Stat()
if err == nil && fi.Size() >= c.RolloverSize {
// rollover
// try the filename exist
index := 1
for ; ; index++ {
path := fmt.Sprintf("%v.%v", c.filePath, index)
if _, err := os.Stat(path); os.IsNotExist(err) {
// not exist
c.File.Close()
os.Rename(c.filePath, path)
f, err := os.OpenFile(c.filePath, os.O_APPEND | os.O_CREATE | os.O_WRONLY, 0644)
if err != nil {
panic(err)
}
c.File = f
break
}
}
}
c.File.WriteString(fmt.Sprintln(basicLayout(event)))
}
func (c *FileAppender) GetName() string {
return "file"
}