-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathfilesrotator.go
83 lines (63 loc) · 1.38 KB
/
filesrotator.go
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
package filesrotator
import (
"fmt"
"io/ioutil"
"os"
"path"
"sort"
)
type sFiles []os.FileInfo
func (f sFiles) Len() int {
return len(f)
}
func (f sFiles) Swap(i, j int) { f[i], f[j] = f[j], f[i] }
type sByFilename struct {
sFiles
}
func (s sByFilename) Less(i, j int) bool {
return s.sFiles[i].Name() > s.sFiles[j].Name()
}
type sByModTime struct {
sFiles
}
func (s sByModTime) Less(i, j int) bool {
return s.sFiles[i].ModTime().Unix() < s.sFiles[j].ModTime().Unix()
}
func RotateByFilename(directory string, maxfiles int) (err error) {
directoryFiles, err := getDirFiles(directory)
sort.Sort(sByFilename{directoryFiles})
err = removeOlder(directory, directoryFiles, maxfiles)
return
}
func getDirFiles(directory string) (files sFiles, err error) {
var directoryFiles []os.FileInfo
files, err = ioutil.ReadDir(directory)
if err != nil {
return
}
for _, f := range files {
if !f.IsDir() {
directoryFiles = append(directoryFiles, f)
}
}
return
}
func removeOlder(directory string, files []os.FileInfo, maxFilesInDir int) (err error) {
var c int
var filename string
for _, f := range files {
filename = path.Join(directory, f.Name())
if c++; c > maxFilesInDir {
err = os.Remove(filename)
if err != nil {
return
}
}
}
return
}
func printFilelist(directoryFiles sFiles) {
for _, f := range directoryFiles {
fmt.Printf("%s\n", f.Name())
}
}