feat: run.sh四模式(dev/docker/build/binary) + CLI flags + Redka内嵌Redis + Agent复制修复 + 服务器编辑IP字段 + 安装Agent按钮
This commit is contained in:
1 parent
d0b94d39c0
commit
2354959811
14 files changed
+1355
-575
No files matched your search
@@ -0,0 +1,98 @@
|
||||
// redka 内嵌 Redis 兼容存储实现(v0.2.x API)
|
||||
// 使用 github.com/nalgeon/redka — 基于 SQLite 的 Redis 替代方案 // Logan.Li
|
||||
// 零外部依赖,数据存在本地文件中,非常适合独立二进制部署
|
||||
package redis
|
||||
|
||||
import (
|
||||
"context"
|
||||
"time"
|
||||
|
||||
"github.com/nalgeon/redka"
|
||||
)
|
||||
|
||||
// redkaCache 基于 Redka v0.2.x 的缓存实现 // Logan.Li
|
||||
type redkaCache struct {
|
||||
db *redka.DB
|
||||
}
|
||||
|
||||
func newRedka(cfg Config) (Cache, error) {
|
||||
dataDir := cfg.DataDir
|
||||
if dataDir == "" {
|
||||
dataDir = "data/redka"
|
||||
}
|
||||
|
||||
// Redka v0.2.x: Open(path, opts) // Logan.Li
|
||||
db, err := redka.Open(dataDir+"/redka.db", nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return &redkaCache{db: db}, nil
|
||||
}
|
||||
|
||||
func (r *redkaCache) Get(ctx context.Context, key string) (string, error) {
|
||||
// Redka v0.2.x: Str().Get() 返回 core.Value // Logan.Li
|
||||
val, err := r.db.Str().Get(key)
|
||||
if err == redka.ErrNotFound {
|
||||
return "", nil
|
||||
}
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
return val.String(), nil
|
||||
}
|
||||
|
||||
func (r *redkaCache) Set(ctx context.Context, key string, value string, expiration time.Duration) error {
|
||||
// Redka v0.2.x: Str().Set() 返回 error // Logan.Li
|
||||
if err := r.db.Str().Set(key, value); err != nil {
|
||||
return err
|
||||
}
|
||||
if expiration > 0 {
|
||||
_, err := r.db.Key().Expire(key, expiration)
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (r *redkaCache) Del(ctx context.Context, keys ...string) error {
|
||||
for _, key := range keys {
|
||||
if _, err := r.db.Key().Delete(key); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (r *redkaCache) Exists(ctx context.Context, keys ...string) (int64, error) {
|
||||
var count int64
|
||||
for _, key := range keys {
|
||||
ok, err := r.db.Key().Exists(key)
|
||||
if err != nil {
|
||||
return 0, err
|
||||
}
|
||||
if ok {
|
||||
count++
|
||||
}
|
||||
}
|
||||
return count, nil
|
||||
}
|
||||
|
||||
func (r *redkaCache) Expire(ctx context.Context, key string, expiration time.Duration) error {
|
||||
ok, err := r.db.Key().Expire(key, expiration)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if !ok {
|
||||
return redka.ErrNotFound
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (r *redkaCache) Ping(ctx context.Context) error {
|
||||
// Redka 始终可用(内嵌数据库)// Logan.Li
|
||||
return nil
|
||||
}
|
||||
|
||||
func (r *redkaCache) Close() error {
|
||||
return r.db.Close()
|
||||
}
|
||||
Reference in new issue
Block a user