1 Star 0 Fork 0

h79/goutils

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
loader_file.go 1.32 KB
一键复制 编辑 原始数据 按行查看 历史
huqiuyun 提交于 2022-10-08 15:21 . 优化 loader
package loader
import (
"errors"
"gitee.com/h79/goutils/common/file"
"os"
)
type Filer struct {
Loader
path string
lastModifyTime int64
da Data
}
func NewFiler(path string, format string, data Data) *Loader {
l := &Filer{
Loader: initLoader(),
path: path,
da: data,
}
return l.WithFormat(format).WithLoadFunc(l.load)
}
func (f *Filer) load() (Data, error) {
lastModify, data, err := LoadFile(f.path, f.lastModifyTime, func(v []byte) (Data, error) {
er := f.unmarshal.Unmarshal(v, f.da)
return f.da, er
})
f.lastModifyTime = lastModify
return data, err
}
type DecodeFunc func(v []byte) (Data, error)
func LoadFile(path string, lastModifyTime int64, decoder DecodeFunc) (int64, Data, error) {
f, er := os.Open(path)
if er != nil {
return lastModifyTime, nil, er
}
defer f.Close()
fileInfo, err := f.Stat()
if err != nil {
return lastModifyTime, nil, err
}
curModifyTime := fileInfo.ModTime().Unix()
if curModifyTime > lastModifyTime {
body, err := file.ReadFile(f)
if err != nil {
return lastModifyTime, nil, err
}
data, err := decoder(body)
if err != nil {
return lastModifyTime, nil, err
}
lastModifyTime = curModifyTime
return lastModifyTime, data, nil
}
return lastModifyTime, nil, ErrNoModified
}
var ErrNoModified = errors.New("file not modified")
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/h79/goutils.git
git@gitee.com:h79/goutils.git
h79
goutils
goutils
v1.2.10

搜索帮助