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 README files, use require.NoError

Browse Source
This commit is contained in:
Juan Calderon-Perez
2023-08-20 09:22:43 -04:00
parent 32af1f92eb
commit c0cc07ca93
37 changed files with 350 additions and 320 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
arangodb/README.md
View File

@@ -11,6 +11,8 @@ title: ArangoDB
A ArangoDB storage driver using `arangodb/go-driver` and [arangodb/go-driver](https://github.com/arangodb/go-driver).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

36
arangodb/arangodb_test.go
View File

@@ -18,7 +18,7 @@ func Test_ARANGODB_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_ARANGODB_Upsert(t *testing.T) {
@@ -28,10 +28,10 @@ func Test_ARANGODB_Upsert(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_ARANGODB_Get(t *testing.T) {
@@ -41,10 +41,10 @@ func Test_ARANGODB_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -56,7 +56,7 @@ func Test_ARANGODB_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -65,13 +65,13 @@ func Test_ARANGODB_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_ARANGODB_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -82,13 +82,13 @@ func Test_ARANGODB_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -96,20 +96,20 @@ func Test_ARANGODB_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -117,10 +117,10 @@ func Test_ARANGODB_Non_UTF8(t *testing.T) {
val := []byte("0xF5")
err := testStore.Set("0xF6", val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("0xF6")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}

2
azureblob/README.md
View File

@@ -11,7 +11,7 @@ title: Azure Blob
[Azure Blob storage](https://azure.microsoft.com/en-us/products/storage/blobs/#overview) is Microsoft's object storage solution for the cloud.
> NOTE: Go **1.18** or later is required. Source: [link](https://github.com/Azure/azure-sdk-for-go/blob/main/README.md)
**Note: Requires Go 1.19 and above**
### Table of Contents

28
azureblob/azureblob_test.go
View File

@@ -27,10 +27,10 @@ func Test_AzureBlob_Get(t *testing.T) {
testStore := newStore()
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -42,7 +42,7 @@ func Test_AzureBlob_Set(t *testing.T) {
testStore := newStore()
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_AzureBlob_Delete(t *testing.T) {
@@ -53,10 +53,10 @@ func Test_AzureBlob_Delete(t *testing.T) {
testStore := newStore()
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
if err != nil {
@@ -64,7 +64,7 @@ func Test_AzureBlob_Delete(t *testing.T) {
err = nil
}
}
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -76,10 +76,10 @@ func Test_AzureBlob_Override(t *testing.T) {
testStore := newStore()
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_AzureBlob_Get_NotExist(t *testing.T) {
@@ -90,7 +90,7 @@ func Test_AzureBlob_Get_NotExist(t *testing.T) {
err = nil
}
}
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -99,13 +99,13 @@ func Test_AzureBlob_Reset(t *testing.T) {
testStore := newStore()
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
if err != nil {
@@ -113,7 +113,7 @@ func Test_AzureBlob_Reset(t *testing.T) {
err = nil
}
}
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
@@ -122,7 +122,7 @@ func Test_AzureBlob_Reset(t *testing.T) {
err = nil
}
}
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
badger/README.md
View File

@@ -11,6 +11,8 @@ title: Badger
A fast key-value DB using [dgraph-io/badger](https://github.com/dgraph-io/badger)
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)

32
badger/badger_test.go
View File

@@ -16,7 +16,7 @@ func Test_Badger_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Badger_Set_Override(t *testing.T) {
@@ -26,10 +26,10 @@ func Test_Badger_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Badger_Get(t *testing.T) {
@@ -39,10 +39,10 @@ func Test_Badger_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -54,7 +54,7 @@ func Test_Badger_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -63,13 +63,13 @@ func Test_Badger_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_Badger_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -80,13 +80,13 @@ func Test_Badger_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -94,20 +94,20 @@ func Test_Badger_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
badger/config_test.go
View File

@@ -9,7 +9,7 @@ import (
func assertRecoveryPanic(t *testing.T) {
err := recover()
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Badger_Only_Name(t *testing.T) {

1
bbolt/README.md
View File

@@ -11,6 +11,7 @@ title: Bbolt
A Bbolt storage driver using [etcd-io/bbolt](https://github.com/etcd-io/bbolt). Bolt is a pure Go key/value store inspired by [Howard Chu's](https://twitter.com/hyc_symas) [LMDB project](https://www.symas.com/symas-embedded-database-lmdb). The goal of the project is to provide a simple, fast, and reliable database for projects that don't require a full database server such as Postgres or MySQL.
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)

28
bbolt/bbolt_test.go
View File

@@ -15,7 +15,7 @@ func Test_Bbolt_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Bbolt_Set_Override(t *testing.T) {
@@ -25,10 +25,10 @@ func Test_Bbolt_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Bbolt_Get(t *testing.T) {
@@ -38,16 +38,16 @@ func Test_Bbolt_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
func Test_Bbolt_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -58,13 +58,13 @@ func Test_Bbolt_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -72,20 +72,20 @@ func Test_Bbolt_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
couchbase/README.md
View File

@@ -11,6 +11,8 @@ title: Couchbase
A Couchbase storage driver using [couchbase/gocb](https://github.com/couchbase/gocb).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

26
couchbase/couchbase_test.go
View File

@@ -17,7 +17,7 @@ func TestSetCouchbase_ShouldReturnNoError(t *testing.T) {
err := testStorage.Set("test", []byte("test"), 0)
require.Nil(t, err)
require.NoError(t, err)
}
func TestGetCouchbase_ShouldReturnNil_WhenDocumentNotFound(t *testing.T) {
@@ -30,7 +30,7 @@ func TestGetCouchbase_ShouldReturnNil_WhenDocumentNotFound(t *testing.T) {
val, err := testStorage.Get("not_found_key")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(val))
}
@@ -43,11 +43,11 @@ func TestSetAndGet_GetShouldReturn_SettedValueWithoutError(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 0)
require.Nil(t, err)
require.NoError(t, err)
val, err := testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, []byte("fiber_test_value"))
}
@@ -60,13 +60,13 @@ func TestSetAndGet_GetShouldReturnNil_WhenTTLExpired(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 3*time.Second)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(6 * time.Second)
val, err := testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(val))
}
@@ -79,13 +79,13 @@ func TestSetAndDelete_DeleteShouldReturn_NoError(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStorage.Delete("test")
require.Nil(t, err)
require.NoError(t, err)
_, err = testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
}
func TestSetAndReset_ResetShouldReturn_NoError(t *testing.T) {
@@ -97,13 +97,13 @@ func TestSetAndReset_ResetShouldReturn_NoError(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStorage.Reset()
require.Nil(t, err)
require.NoError(t, err)
_, err = testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
}
func TestClose_CloseShouldReturn_NoError(t *testing.T) {
@@ -115,7 +115,7 @@ func TestClose_CloseShouldReturn_NoError(t *testing.T) {
})
err := testStorage.Close()
require.Nil(t, err)
require.NoError(t, err)
}
func TestGetConn_ReturnsNotNill(t *testing.T) {

2
dynamodb/README.md
View File

@@ -13,7 +13,7 @@ A DynamoDB storage driver using [aws/aws-sdk-go-v2](https://github.com/aws/aws-s
**Note:** If config fields of credentials not given, credentials are using from the environment variables, ~/.aws/credentials, or EC2 instance role. If config fields of credentials given, credentials are using from config. Look at: [specifying credentials](https://aws.github.io/aws-sdk-go-v2/docs/configuring-sdk/#specifying-credentials)
....
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)

28
dynamodb/dynamodb_test.go
View File

@@ -25,7 +25,7 @@ func Test_DynamoDB_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_DynamoDB_Set_Override(t *testing.T) {
@@ -35,10 +35,10 @@ func Test_DynamoDB_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_DynamoDB_Get(t *testing.T) {
@@ -48,16 +48,16 @@ func Test_DynamoDB_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
func Test_DynamoDB_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -68,13 +68,13 @@ func Test_DynamoDB_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -82,20 +82,20 @@ func Test_DynamoDB_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
etcd/README.md
View File

@@ -11,6 +11,8 @@ title: Etcd
A Etcd storage driver using [`etcd-io/etcd`](https://github.com/etcd-io/etcd).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

26
etcd/etcd_test.go
View File

@@ -18,7 +18,7 @@ func TestSetEtcd_ShouldReturnNoError(t *testing.T) {
)
err := testStorage.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func TestGetEtcd_ShouldReturnNil_WhenDocumentNotFound(t *testing.T) {
@@ -28,7 +28,7 @@ func TestGetEtcd_ShouldReturnNil_WhenDocumentNotFound(t *testing.T) {
val, err := testStorage.Get("not_found_key")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(val))
}
@@ -38,11 +38,11 @@ func TestSetAndGet_GetShouldReturn_SettedValueWithoutError(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 0)
require.Nil(t, err)
require.NoError(t, err)
val, err := testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, []byte("fiber_test_value"))
}
@@ -52,13 +52,13 @@ func TestSetAndGet_GetShouldReturnNil_WhenTTLExpired(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 3*time.Second)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(6 * time.Second)
val, err := testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(val))
}
@@ -68,13 +68,13 @@ func TestSetAndDelete_DeleteShouldReturn_NoError(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStorage.Delete("test")
require.Nil(t, err)
require.NoError(t, err)
_, err = testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
}
func TestSetAndReset_ResetShouldReturn_NoError(t *testing.T) {
@@ -83,13 +83,13 @@ func TestSetAndReset_ResetShouldReturn_NoError(t *testing.T) {
})
err := testStorage.Set("test", []byte("fiber_test_value"), 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStorage.Reset()
require.Nil(t, err)
require.NoError(t, err)
_, err = testStorage.Get("test")
require.Nil(t, err)
require.NoError(t, err)
}
func TestClose_CloseShouldReturn_NoError(t *testing.T) {
@@ -98,7 +98,7 @@ func TestClose_CloseShouldReturn_NoError(t *testing.T) {
})
err := testStorage.Close()
require.Nil(t, err)
require.NoError(t, err)
}
func TestGetConn_ReturnsNotNill(t *testing.T) {

2
memcache/README.md
View File

@@ -11,6 +11,8 @@ title: Memcache
A Memcache storage driver using [`bradfitz/gomemcache`](https://github.com/bradfitz/gomemcache).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

32
memcache/memcache_test.go
View File

@@ -16,7 +16,7 @@ func Test_Memcache_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Memcache_Set_Override(t *testing.T) {
@@ -26,10 +26,10 @@ func Test_Memcache_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Memcache_Get(t *testing.T) {
@@ -39,10 +39,10 @@ func Test_Memcache_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -54,7 +54,7 @@ func Test_Memcache_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -63,13 +63,13 @@ func Test_Memcache_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_Memcache_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -80,13 +80,13 @@ func Test_Memcache_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -94,20 +94,20 @@ func Test_Memcache_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
memory/README.md
View File

@@ -12,6 +12,8 @@ title: Memory
An in-memory storage driver.
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

32
memory/memory_test.go
View File

@@ -17,7 +17,7 @@ func Test_Storage_Memory_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Storage_Memory_Set_Override(t *testing.T) {
@@ -27,10 +27,10 @@ func Test_Storage_Memory_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Storage_Memory_Get(t *testing.T) {
@@ -40,10 +40,10 @@ func Test_Storage_Memory_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -55,7 +55,7 @@ func Test_Storage_Memory_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -64,13 +64,13 @@ func Test_Storage_Memory_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_Storage_Memory_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -81,13 +81,13 @@ func Test_Storage_Memory_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -95,20 +95,20 @@ func Test_Storage_Memory_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
mongodb/README.md
View File

@@ -11,6 +11,8 @@ title: MongoDB
A MongoDB storage driver using [mongodb/mongo-go-driver](https://github.com/mongodb/mongo-go-driver).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

32
mongodb/mongodb_test.go
View File

@@ -18,7 +18,7 @@ func Test_MongoDB_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_MongoDB_Set_Override(t *testing.T) {
@@ -28,10 +28,10 @@ func Test_MongoDB_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_MongoDB_Get(t *testing.T) {
@@ -41,10 +41,10 @@ func Test_MongoDB_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -56,7 +56,7 @@ func Test_MongoDB_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -65,13 +65,13 @@ func Test_MongoDB_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_MongoDB_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -82,13 +82,13 @@ func Test_MongoDB_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -96,20 +96,20 @@ func Test_MongoDB_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
mssql/README.md
View File

@@ -11,6 +11,8 @@ title: MSSQL
A MSSQL storage driver using [microsoft/go-mssqldb](https://github.com/microsoft/go-mssqldb).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

42
mssql/mssql_test.go
View File

@@ -23,7 +23,7 @@ func Test_MSSQL_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_MSSQL_Set_Override(t *testing.T) {
@@ -33,10 +33,10 @@ func Test_MSSQL_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_MSSQL_Get(t *testing.T) {
@@ -46,10 +46,10 @@ func Test_MSSQL_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -61,7 +61,7 @@ func Test_MSSQL_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -70,13 +70,13 @@ func Test_MSSQL_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_MSSQL_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -87,13 +87,13 @@ func Test_MSSQL_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -101,20 +101,20 @@ func Test_MSSQL_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -123,7 +123,7 @@ func Test_MSSQL_GC(t *testing.T) {
// This key should expire
err := testStore.Set("john", testVal, time.Nanosecond)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
row := testStore.db.QueryRow(testStore.sqlSelect, "john")
@@ -132,11 +132,11 @@ func Test_MSSQL_GC(t *testing.T) {
// This key should not expire
err = testStore.Set("john", testVal, 0)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
val, err := testStore.Get("john")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, testVal, val)
}
@@ -144,10 +144,10 @@ func Test_MSSQL_Non_UTF8(t *testing.T) {
val := []byte("0xF5")
err := testStore.Set("0xF6", val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("0xF6")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}

2
mysql/README.md
View File

@@ -11,6 +11,8 @@ title: MySQL
A MySQL storage driver using `database/sql` and [go-sql-driver/mysql](https://github.com/go-sql-driver/mysql).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

42
mysql/mysql_test.go
View File

@@ -54,7 +54,7 @@ func Test_MYSQL_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_MYSQL_Set_Override(t *testing.T) {
@@ -64,10 +64,10 @@ func Test_MYSQL_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_MYSQL_Get(t *testing.T) {
@@ -77,10 +77,10 @@ func Test_MYSQL_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -92,7 +92,7 @@ func Test_MYSQL_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -101,13 +101,13 @@ func Test_MYSQL_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_MYSQL_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -118,13 +118,13 @@ func Test_MYSQL_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -132,20 +132,20 @@ func Test_MYSQL_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -154,7 +154,7 @@ func Test_MYSQL_GC(t *testing.T) {
// This key should expire
err := testStore.Set("john", testVal, time.Nanosecond)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
row := testStore.db.QueryRow(testStore.sqlSelect, "john")
@@ -163,11 +163,11 @@ func Test_MYSQL_GC(t *testing.T) {
// This key should not expire
err = testStore.Set("john", testVal, 0)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
val, err := testStore.Get("john")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, testVal, val)
}
@@ -175,10 +175,10 @@ func Test_MYSQL_Non_UTF8(t *testing.T) {
val := []byte("0xF5")
err := testStore.Set("0xF6", val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("0xF6")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}

2
pebble/README.md
View File

@@ -11,6 +11,8 @@ title: Pebble
A fast key-value DB using [cockroachdb/pebble](https://github.com/cockroachdb/pebble)
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)

26
pebble/pebble_test.go
View File

@@ -19,7 +19,7 @@ func Test_Pebble_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Pebble_Set_Override(t *testing.T) {
@@ -29,10 +29,10 @@ func Test_Pebble_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Pebble_Get(t *testing.T) {
@@ -42,10 +42,10 @@ func Test_Pebble_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -57,7 +57,7 @@ func Test_Pebble_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -69,10 +69,10 @@ func Test_Pebble_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 20)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Equal(t, "pebble: not found", err.Error())
@@ -83,19 +83,19 @@ func Test_Pebble_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
_, err = testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
_, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Pebble_Close(t *testing.T) {

2
postgres/README.md
View File

@@ -11,6 +11,8 @@ title: Postgres
A Postgres storage driver using [jackc/pgx](https://github.com/jackc/pgx).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

42
postgres/postgres_test.go
View File

@@ -24,7 +24,7 @@ func Test_Postgres_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Postgres_Set_Override(t *testing.T) {
@@ -34,10 +34,10 @@ func Test_Postgres_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Postgres_Get(t *testing.T) {
@@ -47,10 +47,10 @@ func Test_Postgres_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -62,7 +62,7 @@ func Test_Postgres_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -71,13 +71,13 @@ func Test_Postgres_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_Postgres_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -88,13 +88,13 @@ func Test_Postgres_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -102,20 +102,20 @@ func Test_Postgres_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -124,7 +124,7 @@ func Test_Postgres_GC(t *testing.T) {
// This key should expire
err := testStore.Set("john", testVal, time.Nanosecond)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
row := testStore.db.QueryRow(context.Background(), testStore.sqlSelect, "john")
@@ -133,11 +133,11 @@ func Test_Postgres_GC(t *testing.T) {
// This key should not expire
err = testStore.Set("john", testVal, 0)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
val, err := testStore.Get("john")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, testVal, val)
}
@@ -145,10 +145,10 @@ func Test_Postgres_Non_UTF8(t *testing.T) {
val := []byte("0xF5")
err := testStore.Set("0xF6", val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("0xF6")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}

2
redis/README.md
View File

@@ -11,6 +11,8 @@ title: Redis
A Redis storage driver using [go-redis/redis](https://github.com/go-redis/redis).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

80
redis/redis_test.go
View File

@@ -20,7 +20,7 @@ func Test_Redis_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Redis_Set_Override(t *testing.T) {
@@ -30,10 +30,10 @@ func Test_Redis_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Redis_Get(t *testing.T) {
@@ -43,10 +43,10 @@ func Test_Redis_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -58,7 +58,7 @@ func Test_Redis_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -67,13 +67,13 @@ func Test_Redis_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_Redis_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -84,13 +84,13 @@ func Test_Redis_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -98,20 +98,20 @@ func Test_Redis_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -133,14 +133,14 @@ func Test_Redis_Initalize_WithURL(t *testing.T) {
)
err := testStoreUrl.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUrl.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUrl.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUrl.Close())
}
@@ -176,14 +176,14 @@ func Test_Redis_Initalize_WithURL_TLS(t *testing.T) {
)
err = testStoreUrl.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUrl.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUrl.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUrl.Close())
}
@@ -200,14 +200,14 @@ func Test_Redis_Universal_Addrs(t *testing.T) {
)
err := testStoreUniversal.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUniversal.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUniversal.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUniversal.Close())
}
@@ -226,14 +226,14 @@ func Test_Redis_Universal_With_URL_Undefined(t *testing.T) {
)
err := testStoreUniversal.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUniversal.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUniversal.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUniversal.Close())
}
@@ -252,14 +252,14 @@ func Test_Redis_Universal_With_URL_Defined(t *testing.T) {
)
err := testStoreUniversal.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUniversal.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUniversal.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUniversal.Close())
}
@@ -279,14 +279,14 @@ func Test_Redis_Universal_With_HostPort(t *testing.T) {
)
err := testStoreUniversal.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUniversal.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUniversal.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUniversal.Close())
}
@@ -307,14 +307,14 @@ func Test_Redis_Universal_With_HostPort_And_URL(t *testing.T) {
)
err := testStoreUniversal.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUniversal.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUniversal.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUniversal.Close())
}
@@ -337,14 +337,14 @@ func Test_Redis_Cluster(t *testing.T) {
)
err := testStoreUniversal.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStoreUniversal.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
err = testStoreUniversal.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
require.Nil(t, testStoreUniversal.Close())
}

2
ristretto/README.md
View File

@@ -11,6 +11,8 @@ title: Ristretto
A Memory-bound storage driver using [`dgraph-io/ristretto`](https://github.com/dgraph-io/ristretto).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

32
ristretto/ristretto_test.go
View File

@@ -17,7 +17,7 @@ func Test_Ristretto_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Ristretto_Set_Override(t *testing.T) {
@@ -27,10 +27,10 @@ func Test_Ristretto_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_Ristretto_Get(t *testing.T) {
@@ -45,7 +45,7 @@ func Test_Ristretto_Get(t *testing.T) {
// Set the value in a goroutine
go func() {
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
// Send a value on the channel to signal that the value has been set
done <- struct{}{}
@@ -56,7 +56,7 @@ func Test_Ristretto_Get(t *testing.T) {
case <-done:
// The value has been set, proceed with the test
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
case <-time.After(1 * time.Second):
// The value was not set within 1 second, fail the test
@@ -72,7 +72,7 @@ func Test_Ristretto_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
testStore.Reset()
}
@@ -81,13 +81,13 @@ func Test_Ristretto_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_Ristretto_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -103,7 +103,7 @@ func Test_Ristretto_Delete(t *testing.T) {
// Set the value in a goroutine
go func() {
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
// Send a value on the channel to signal that the value has been set
done <- struct{}{}
@@ -114,10 +114,10 @@ func Test_Ristretto_Delete(t *testing.T) {
case <-done:
// The value has been set, proceed with the test
err := testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
case <-time.After(1 * time.Second):
// The value was not set within 1 second, fail the test
@@ -129,20 +129,20 @@ func Test_Ristretto_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

1
s3/README.md
View File

@@ -13,6 +13,7 @@ A S3 storage driver using [aws/aws-sdk-go-v2](https://github.com/aws/aws-sdk-go-
**Note:** If config fields of credentials not given, credentials are using from the environment variables, ~/.aws/credentials, or EC2 instance role. If config fields of credentials given, credentials are using from config. Look at: [specifying credentials](https://aws.github.io/aws-sdk-go-v2/docs/configuring-sdk/#specifying-credentials)
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)

28
s3/s3_test.go
View File

@@ -25,7 +25,7 @@ func Test_S3_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_S3_Set_Override(t *testing.T) {
@@ -35,10 +35,10 @@ func Test_S3_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_S3_Get(t *testing.T) {
@@ -48,16 +48,16 @@ func Test_S3_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
func Test_S3_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -68,13 +68,13 @@ func Test_S3_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -82,20 +82,20 @@ func Test_S3_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}

2
sqlite3/README.md
View File

@@ -11,6 +11,8 @@ title: SQLite3
A SQLite3 storage driver using [mattn/go-sqlite3](https://github.com/mattn/go-sqlite3).
**Note: Requires Go 1.19 and above**
### Table of Contents
- [Signatures](#signatures)
- [Installation](#installation)

42
sqlite3/sqlite3_test.go
View File

@@ -20,7 +20,7 @@ func Test_SQLite3_Set(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_SQLite3_Set_Override(t *testing.T) {
@@ -30,10 +30,10 @@ func Test_SQLite3_Set_Override(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
}
func Test_SQLite3_Get(t *testing.T) {
@@ -43,10 +43,10 @@ func Test_SQLite3_Get(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}
@@ -58,7 +58,7 @@ func Test_SQLite3_Set_Expiration(t *testing.T) {
)
err := testStore.Set(key, val, exp)
require.Nil(t, err)
require.NoError(t, err)
time.Sleep(1100 * time.Millisecond)
}
@@ -67,13 +67,13 @@ func Test_SQLite3_Get_Expired(t *testing.T) {
key := "john"
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
func Test_SQLite3_Get_NotExist(t *testing.T) {
result, err := testStore.Get("notexist")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -84,13 +84,13 @@ func Test_SQLite3_Delete(t *testing.T) {
)
err := testStore.Set(key, val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Delete(key)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get(key)
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -98,20 +98,20 @@ func Test_SQLite3_Reset(t *testing.T) {
val := []byte("doe")
err := testStore.Set("john1", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Set("john2", val, 0)
require.Nil(t, err)
require.NoError(t, err)
err = testStore.Reset()
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("john1")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
result, err = testStore.Get("john2")
require.Nil(t, err)
require.NoError(t, err)
require.Zero(t, len(result))
}
@@ -120,7 +120,7 @@ func Test_SQLite3_GC(t *testing.T) {
// This key should expire
err := testStore.Set("john", testVal, time.Nanosecond)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
row := testStore.db.QueryRow(testStore.sqlSelect, "john")
@@ -129,11 +129,11 @@ func Test_SQLite3_GC(t *testing.T) {
// This key should not expire
err = testStore.Set("john", testVal, 0)
require.Nil(t, err)
require.NoError(t, err)
testStore.gc(time.Now())
val, err := testStore.Get("john")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, testVal, val)
}
@@ -141,10 +141,10 @@ func Test_SQLite3_Non_UTF8(t *testing.T) {
val := []byte("0xF5")
err := testStore.Set("0xF6", val, 0)
require.Nil(t, err)
require.NoError(t, err)
result, err := testStore.Get("0xF6")
require.Nil(t, err)
require.NoError(t, err)
require.Equal(t, val, result)
}