mirror of https://github.com/1Panel-dev/1Panel
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
88 lines
1.8 KiB
88 lines
1.8 KiB
package badger_db
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/dgraph-io/badger/v3"
|
|
"github.com/pkg/errors"
|
|
"time"
|
|
)
|
|
|
|
type Cache struct {
|
|
db *badger.DB
|
|
}
|
|
|
|
func NewCacheDB(db *badger.DB) *Cache {
|
|
return &Cache{
|
|
db: db,
|
|
}
|
|
}
|
|
|
|
func (c *Cache) SetNX(key string, value interface{}) error {
|
|
err := c.db.Update(func(txn *badger.Txn) error {
|
|
_, err := txn.Get([]byte(key))
|
|
if errors.Is(err, badger.ErrKeyNotFound) {
|
|
v := []byte(fmt.Sprintf("%v", value))
|
|
return txn.Set([]byte(key), v)
|
|
}
|
|
return err
|
|
})
|
|
return err
|
|
}
|
|
|
|
func (c *Cache) Set(key string, value interface{}) error {
|
|
err := c.db.Update(func(txn *badger.Txn) error {
|
|
v := []byte(fmt.Sprintf("%v", value))
|
|
return txn.Set([]byte(key), v)
|
|
})
|
|
return err
|
|
}
|
|
|
|
func (c *Cache) Del(key string) error {
|
|
err := c.db.Update(func(txn *badger.Txn) error {
|
|
return txn.Delete([]byte(key))
|
|
})
|
|
return err
|
|
}
|
|
|
|
func (c *Cache) Get(key string) ([]byte, error) {
|
|
var result []byte
|
|
err := c.db.View(func(txn *badger.Txn) error {
|
|
item, err := txn.Get([]byte(key))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
err = item.Value(func(val []byte) error {
|
|
result = append([]byte{}, val...)
|
|
return nil
|
|
})
|
|
return err
|
|
})
|
|
return result, err
|
|
}
|
|
|
|
func (c *Cache) SetWithTTL(key string, value interface{}, duration time.Duration) error {
|
|
err := c.db.Update(func(txn *badger.Txn) error {
|
|
v := []byte(fmt.Sprintf("%v", value))
|
|
e := badger.NewEntry([]byte(key), v).WithTTL(duration)
|
|
return txn.SetEntry(e)
|
|
})
|
|
return err
|
|
}
|
|
|
|
func (c *Cache) PrefixScanKey(prefixStr string) ([]string, error) {
|
|
var res []string
|
|
err := c.db.View(func(txn *badger.Txn) error {
|
|
it := txn.NewIterator(badger.DefaultIteratorOptions)
|
|
defer it.Close()
|
|
prefix := []byte(prefixStr)
|
|
for it.Seek(prefix); it.ValidForPrefix(prefix); it.Next() {
|
|
item := it.Item()
|
|
k := item.Key()
|
|
res = append(res, string(k))
|
|
return nil
|
|
}
|
|
return nil
|
|
})
|
|
return res, err
|
|
}
|