package/storage
1
0
Fork 0
mirror of https://github.com/gofiber/storage.git synced 2025-10-04 16:22:52 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

🎑 update tests

Browse Source
This commit is contained in:
Fenny
2020-11-05 05:36:27 +01:00
parent 504e8c31f8
commit 8440b5e3c0
8 changed files with 29 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
memcache/memcache.go
View File

@@ -72,6 +72,10 @@ func (s *Storage) Get(key string) ([]byte, error) {
// Set key with value
func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
// Ain't Nobody Got Time For That
if len(val) <= 0 {
return nil
}
item := s.acquireItem()
item.Key = key
item.Value = val

4
memory/memory.go
View File

@@ -52,6 +52,10 @@ func (s *Storage) Get(key string) ([]byte, error) {
// Set key with value
func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
// Ain't Nobody Got Time For That
if len(val) <= 0 {
return nil
}
var expire int64
if exp != 0 {
expire = time.Now().Add(exp).Unix()

5
mongodb/mongodb.go
View File

@@ -127,6 +127,11 @@ func (s *Storage) Get(key string) ([]byte, error) {
//
// document will be remove automatically if exp is set, based on MongoDB TTL Indexes
func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
// Ain't Nobody Got Time For That
if len(val) <= 0 {
return nil
}
filter := bson.M{"key": key}
item := s.acquireItem()
item.Key = key

4
mysql/mysql.go
View File

@@ -118,6 +118,10 @@ func (s *Storage) Get(key string) ([]byte, error) {
// Set key with value
func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
// Ain't Nobody Got Time For That
if len(val) <= 0 {
return nil
}
var expSeconds int64
if exp != 0 {
expSeconds = time.Now().Add(exp).Unix()

4
postgres/postgres.go
View File

@@ -138,6 +138,10 @@ func (s *Storage) Get(key string) ([]byte, error) {
// Set key with value
func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
// Ain't Nobody Got Time For That
if len(val) <= 0 {
return nil
}
_, err := s.db.Exec(s.sqlInsert, key, utils.UnsafeString(val), time.Now().Add(exp).Unix())
return err
}

4
redis/redis.go
View File

@@ -59,6 +59,10 @@ func (s *Storage) Get(key string) ([]byte, error) {
// Set key with value
func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
// Ain't Nobody Got Time For That
if len(val) <= 0 {
return nil
}
return s.db.Set(context.Background(), key, val, exp).Err()
}

BIN
sqlite3/fiber.sqlite3
View File

Binary file not shown.

4
sqlite3/sqlite3.go
View File

@@ -117,6 +117,10 @@ func (s *Storage) Get(key string) ([]byte, error) {
// Set key with value
func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
// Ain't Nobody Got Time For That
if len(val) <= 0 {
return nil
}
var expSeconds int64
if exp != 0 {
expSeconds = time.Now().Add(exp).Unix()