github/openwechat
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[style]: Deprecated NewJsonFileHotReloadStorage (#223)

Browse Source
This commit is contained in:
多吃点苹果 2023-02-02 10:06:17 +08:00 committed by GitHub
parent d77bb0a4cb
commit eccc25e66e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
stroage.go
View File

@ -25,15 +25,15 @@ type HotReloadStorageItem struct {
// HotReloadStorage 热登陆存储接口 // HotReloadStorage 热登陆存储接口
type HotReloadStorage io.ReadWriter type HotReloadStorage io.ReadWriter
// jsonFileHotReloadStorage 实现HotReloadStorage接口 // fileHotReloadStorage 实现HotReloadStorage接口
// 默认以json文件的形式存储 // 以文件的形式存储
type jsonFileHotReloadStorage struct { type fileHotReloadStorage struct {
filename string filename string
file *os.File file *os.File
lock sync.Mutex lock sync.Mutex
} }
func (j *jsonFileHotReloadStorage) Read(p []byte) (n int, err error) { func (j *fileHotReloadStorage) Read(p []byte) (n int, err error) {
j.lock.Lock() j.lock.Lock()
defer j.lock.Unlock() defer j.lock.Unlock()
if j.file == nil { if j.file == nil {
@ -48,7 +48,7 @@ func (j *jsonFileHotReloadStorage) Read(p []byte) (n int, err error) {
return j.file.Read(p) return j.file.Read(p)
} }
func (j *jsonFileHotReloadStorage) Write(p []byte) (n int, err error) { func (j *fileHotReloadStorage) Write(p []byte) (n int, err error) {
j.lock.Lock() j.lock.Lock()
defer j.lock.Unlock() defer j.lock.Unlock()
if j.file == nil { if j.file == nil {
@ -68,19 +68,27 @@ func (j *jsonFileHotReloadStorage) Write(p []byte) (n int, err error) {
return j.file.Write(p) return j.file.Write(p)
} }
func (j *jsonFileHotReloadStorage) Close() error { func (j *fileHotReloadStorage) Close() error {
j.lock.Lock()
defer j.lock.Unlock()
if j.file == nil { if j.file == nil {
return nil return nil
} }
return j.file.Close() return j.file.Close()
} }
// NewJsonFileHotReloadStorage 创建JsonFileHotReloadStorage // Deprecated: use NewFileHotReloadStorage instead
// 不再单纯以json的格式存储，支持了用户自定义序列化方式
func NewJsonFileHotReloadStorage(filename string) io.ReadWriteCloser { func NewJsonFileHotReloadStorage(filename string) io.ReadWriteCloser {
return &jsonFileHotReloadStorage{filename: filename} return NewFileHotReloadStorage(filename)
} }
var _ HotReloadStorage = (*jsonFileHotReloadStorage)(nil) // NewFileHotReloadStorage implements HotReloadStorage
func NewFileHotReloadStorage(filename string) io.ReadWriteCloser {
return &fileHotReloadStorage{filename: filename}
}
var _ HotReloadStorage = (*fileHotReloadStorage)(nil)
type HotReloadStorageSyncer struct { type HotReloadStorageSyncer struct {
duration time.Duration duration time.Duration