Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in /s3 (#428)

Bumps [github.com/aws/aws-sdk-go-v2/feature/s3/manager](https://github.com/aws/aws-sdk-go-v2) from 1.9.1 to 1.11.21.
- [Release notes](https://github.com/aws/aws-sdk-go-v2/releases)
- [Changelog](https://github.com/aws/aws-sdk-go-v2/blob/main/CHANGELOG.md)
- [Commits](https://github.com/aws/aws-sdk-go-v2/compare/v1.9.1...feature/s3/manager/v1.11.21)

---
updated-dependencies:
- dependency-name: github.com/aws/aws-sdk-go-v2/feature/s3/manager
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

.github/dependabot.yml

@@ -2,111 +2,93 @@
 
 version: 2
 updates:
+    - package-ecosystem: "github-actions"
+      directory: "/"
+      schedule:
+          interval: daily
+      labels:
+          - "🤖 Dependencies"
     -   package-ecosystem: "gomod"
         directory: "/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/arangodb/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/badger/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/dynamodb/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/memcache/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/memory/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/mongodb/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/mysql/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/postgres/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/redis/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/sqlite3/" # Location of package manifests
-        default_labels:
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/ristretto/" # Location of package manifests
-        default_labels:
+        labels:
+            - "🤖 Dependencies"
+        schedule:
+            interval: "daily"
+    -   package-ecosystem: "gomod"
+        directory: "/s3/" # Location of package manifests
+        labels:
+            - "🤖 Dependencies"
+        schedule:
+            interval: "daily"
+    -   package-ecosystem: "gomod"
+        directory: "/bbolt/" # Location of package manifests
+        labels:
             - "🤖 Dependencies"
         schedule:
             interval: "daily"
-        automerged_updates:
-            -   match:
-                    dependency_name: "gofiber/fiber/*"

.github/workflows/codeql-analysis.yml

@@ -16,7 +16,7 @@ jobs:
 
     steps:
     - name: Checkout repository
-      uses: actions/checkout@v2
+      uses: actions/checkout@v3
       with:
         # We must fetch at least the immediate parents so that if this is
         # a pull request then we can checkout the head.
@@ -29,7 +29,7 @@ jobs:
 
     # Initializes the CodeQL tools for scanning.
     - name: Initialize CodeQL
-      uses: github/codeql-action/init@v1
+      uses: github/codeql-action/init@v2
       # Override language selection by uncommenting this and choosing your languages
       with:
         languages: go
@@ -37,7 +37,7 @@ jobs:
     # Autobuild attempts to build any compiled languages  (C/C++, C#, or Java).
     # If this step fails, then you should remove it and run the build manually (see below)
     - name: Autobuild
-      uses: github/codeql-action/autobuild@v1
+      uses: github/codeql-action/autobuild@v2
 
     # ℹ️ Command-line programs to run using the OS shell.
     # 📚 https://git.io/JvXDl
@@ -51,4 +51,4 @@ jobs:
     #   make release
 
     - name: Perform CodeQL Analysis
-      uses: github/codeql-action/analyze@v1
+      uses: github/codeql-action/analyze@v2

.github/workflows/linter.yml

@@ -5,8 +5,8 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Fetch Repository
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
       - name: Run Golint
-        uses: reviewdog/action-golangci-lint@v1
+        uses: reviewdog/action-golangci-lint@v2
         with:
           golangci_lint_flags: "--tests=false"

.github/workflows/security.yml

@@ -5,18 +5,18 @@ jobs:
         runs-on: ubuntu-latest
         steps:
             -   name: Fetch Repository
-                uses: actions/checkout@v2
+                uses: actions/checkout@v3
             -   name: Install Go
-                uses: actions/setup-go@v2
+                uses: actions/setup-go@v3
                 with:
                     go-version: '^1.17.6'
             -   name: Install Gosec
                 run: |
                     export PATH=${PATH}:`go env GOPATH`/bin
-                    go get -u github.com/securego/gosec/v2/cmd/gosec
+                    go install github.com/securego/gosec/v2/cmd/gosec@latest
             -   name: Run Gosec (root)
                 working-directory: .
-                run: "`go env GOPATH`/bin/gosec -exclude-dir=internal -exclude-dir=arangodb -exclude-dir=badger -exclude-dir=dynamodb -exclude-dir=memcache -exclude-dir=memory -exclude-dir=mongodb -exclude-dir=mysql -exclude-dir=postgres -exclude-dir=redis -exclude-dir=ristretto -exclude-dir=sqlite3 ./..."
+                run: "`go env GOPATH`/bin/gosec -exclude-dir=internal -exclude-dir=arangodb -exclude-dir=badger -exclude-dir=dynamodb -exclude-dir=memcache -exclude-dir=memory -exclude-dir=mongodb -exclude-dir=mysql -exclude-dir=postgres -exclude-dir=redis -exclude-dir=ristretto -exclude-dir=sqlite3 -exclude-dir=s3 -exclude-dir=bbolt ./..."
                 # -----
             -   name: Run Gosec (arangodb)
                 working-directory: ./arangodb
@@ -58,7 +58,15 @@ jobs:
                 working-directory: ./sqlite3
                 run: "`go env GOPATH`/bin/gosec -exclude-dir=internal ./..."
                 # -----
+            -   name: Run Gosec (s3)
+                working-directory: ./s3
+                run: "`go env GOPATH`/bin/gosec -exclude-dir=internal ./..."
+                # -----
             -   name: Run Gosec (ristretto)
                 working-directory: ./ristretto
                 run: "`go env GOPATH`/bin/gosec -exclude-dir=internal ./..."
                 # -----
+            -   name: Run Gosec (bbolt)
+                working-directory: ./bbolt
+                run: "`go env GOPATH`/bin/gosec -exclude-dir=internal ./..."
+                # -----

.github/workflows/test-arangodb.yml

@@ -1,33 +1,51 @@
-'on':
-  - push
-  - pull_request
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
 name: ArangoDB
 jobs:
-  Tests:
-    runs-on: ubuntu-latest
-    services:
-      arangodb:
-        image: 'arangodb:latest'
-        env:
-          ARANGO_NO_AUTH: 1
-        ports:
-          - '8529:8529'
-    strategy:
-      matrix:
-        go-version:
-          - 1.14.x
-          - 1.15.x
-          - 1.16.x
-          - 1.17.x
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    steps:
-      - name: Install Go
-        uses: actions/setup-go@v1
-        with:
-          go-version: '${{ matrix.go-version }}'
-      - name: Fetch Repository
-        uses: actions/checkout@v2
-      - name: Run Test
-        run: cd ./arangodb && go test ./... -v -race
+    Tests:
+        runs-on: ubuntu-latest
+        services:
+            arangodb:
+                image: 'arangodb:latest'
+                env:
+                    ARANGO_NO_AUTH: 1
+                ports:
+                    - '8529:8529'
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Run Test
+                run: cd ./arangodb && go test ./... -v -race

.github/workflows/test-bbolt.yml

@@ -0,0 +1,44 @@
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
+name: Bbolt
+jobs:
+    Tests:
+        runs-on: ubuntu-latest
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Run Test
+                run: cd ./bbolt && go mod tidy && go test ./... -v -race

.github/workflows/test-dynamodb.yml

@@ -0,0 +1,49 @@
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
+name: DynamoDB
+jobs:
+    Tests:
+        runs-on: ubuntu-latest
+        services:
+            mongo:
+                image: 'amazon/dynamodb-local:latest'
+                ports:
+                    - '8000:8000'
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Run Test
+                run: cd ./dynamodb && go test ./... -v -race

.github/workflows/test-memcache.yml

@@ -1,31 +1,49 @@
-'on':
-  - push
-  - pull_request
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
 name: Memcache
 jobs:
-  Tests:
-    runs-on: ubuntu-latest
-    services:
-      mongo:
-        image: 'memcached:latest'
-        ports:
-          - '11211:11211'
-    strategy:
-      matrix:
-        go-version:
-          - 1.14.x
-          - 1.15.x
-          - 1.16.x
-          - 1.17.x
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    steps:
-      - name: Install Go
-        uses: actions/setup-go@v1
-        with:
-          go-version: '${{ matrix.go-version }}'
-      - name: Fetch Repository
-        uses: actions/checkout@v2
-      - name: Run Test
-        run: cd ./memcache && go test ./... -v -race
+    Tests:
+        runs-on: ubuntu-latest
+        services:
+            mongo:
+                image: 'memcached:latest'
+                ports:
+                    - '11211:11211'
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Run Test
+                run: cd ./memcache && go test ./... -v -race

.github/workflows/test-mongodb.yml

@@ -1,31 +1,49 @@
-'on':
-  - push
-  - pull_request
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
 name: MongoDB
 jobs:
-  Tests:
-    runs-on: ubuntu-latest
-    services:
-      mongo:
-        image: 'mongo:latest'
-        ports:
-          - '27017:27017'
-    strategy:
-      matrix:
-        go-version:
-          - 1.14.x
-          - 1.15.x
-          - 1.16.x
-          - 1.17.x
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    steps:
-      - name: Install Go
-        uses: actions/setup-go@v1
-        with:
-          go-version: '${{ matrix.go-version }}'
-      - name: Fetch Repository
-        uses: actions/checkout@v2
-      - name: Run Test
-        run: cd ./mongodb && go test ./... -v -race
+    Tests:
+        runs-on: ubuntu-latest
+        services:
+            mongo:
+                image: 'mongo:latest'
+                ports:
+                    - '27017:27017'
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Run Test
+                run: cd ./mongodb && go test ./... -v -race

.github/workflows/test-mysql.yml

@@ -1,43 +1,61 @@
-'on':
-  - push
-  - pull_request
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
 name: MySQL
 jobs:
-  Tests:
-    runs-on: ubuntu-latest
-    services:
-      mysql:
-        image: 'mysql:latest'
-        env:
-          MYSQL_DATABASE: fiber
-          MYSQL_USER: username
-          MYSQL_PASSWORD: password
-          MYSQL_ROOT_PASSWORD: password
-        ports:
-          - '3306:3306'
-        options: >-
-          --health-cmd "mysqladmin ping" --health-interval 10s --health-timeout
-          5s --health-retries 5
-    strategy:
-      matrix:
-        go-version:
-          - 1.14.x
-          - 1.15.x
-          - 1.16.x
-          - 1.17.x
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    steps:
-      - name: Install Go
-        uses: actions/setup-go@v1
-        with:
-          go-version: '${{ matrix.go-version }}'
-      - name: Fetch Repository
-        uses: actions/checkout@v2
-      - name: Run Test
-        run: cd ./mysql && go test ./... -v -race
-        env:
-          MYSQL_USERNAME: username
-          MYSQL_PASSWORD: password
-          MYSQL_DATABASE: fiber
+    Tests:
+        runs-on: ubuntu-latest
+        services:
+            mysql:
+                image: 'mysql:latest'
+                env:
+                    MYSQL_DATABASE: fiber
+                    MYSQL_USER: username
+                    MYSQL_PASSWORD: password
+                    MYSQL_ROOT_PASSWORD: password
+                ports:
+                    - '3306:3306'
+                options: >-
+                    --health-cmd "mysqladmin ping" --health-interval 10s --health-timeout
+                    5s --health-retries 5
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Run Test
+                run: cd ./mysql && go test ./... -v -race
+                env:
+                    MYSQL_USERNAME: username
+                    MYSQL_PASSWORD: password
+                    MYSQL_DATABASE: fiber

.github/workflows/test-postgres.yml

@@ -1,42 +1,60 @@
-'on':
-  - push
-  - pull_request
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
 name: Postgres
 jobs:
-  Tests:
-    runs-on: ubuntu-latest
-    services:
-      postgres:
-        image: 'postgres:latest'
-        ports:
-          - '5432:5432'
-        env:
-          POSTGRES_DB: fiber
-          POSTGRES_USER: username
-          POSTGRES_PASSWORD: password
-        options: >-
-          --health-cmd pg_isready --health-interval 10s --health-timeout 5s
-          --health-retries 5
-    strategy:
-      matrix:
-        go-version:
-          - 1.14.x
-          - 1.15.x
-          - 1.16.x
-          - 1.17.x
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    steps:
-      - name: Install Go
-        uses: actions/setup-go@v1
-        with:
-          go-version: '${{ matrix.go-version }}'
-      - name: Fetch Repository
-        uses: actions/checkout@v2
-      - name: Run Test
-        run: cd ./postgres && go test ./... -v -race
-        env:
-          POSTGRES_DATABASE: fiber
-          POSTGRES_USERNAME: username
-          POSTGRES_PASSWORD: password
+    Tests:
+        runs-on: ubuntu-latest
+        services:
+            postgres:
+                image: 'postgres:latest'
+                ports:
+                    - '5432:5432'
+                env:
+                    POSTGRES_DB: fiber
+                    POSTGRES_USER: username
+                    POSTGRES_PASSWORD: password
+                options: >-
+                    --health-cmd pg_isready --health-interval 10s --health-timeout 5s
+                    --health-retries 5
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Run Test
+                run: cd ./postgres && go test ./... -v -race
+                env:
+                    POSTGRES_DATABASE: fiber
+                    POSTGRES_USERNAME: username
+                    POSTGRES_PASSWORD: password

.github/workflows/test-redis.yml

@@ -1,43 +1,62 @@
-'on':
-  - push
-  - pull_request
-name: Redis
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
+name: S3
 jobs:
-  Tests:
-    runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        go-version:
-          - 1.14.x
-          - 1.15.x
-          - 1.16.x
-          - 1.17.x
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    steps:
-    - name: Fetch Repository
-      uses: actions/checkout@v2
+    Tests:
+        runs-on: ubuntu-latest
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
 
-    - name: Setup Redis
-      uses: shogo82148/actions-setup-redis@v1
-      with:
-        redis-version: 'latest'
-        auto-start: 'false'
-        redis-port: '6379'
-        redis-tls-port: '6380'
+            -   name: Setup Redis
+                uses: shogo82148/actions-setup-redis@v1
+                with:
+                    redis-version: '6.x'
+                    auto-start: 'false'
+                    redis-port: '6379'
+                    redis-tls-port: '6380'
 
-    - name: Run Redis
-      run: |
-        redis-server --tls-port 6380 --port 6379 \
-        --tls-cert-file ./redis/tests/tls/redis.crt \
-        --tls-key-file ./redis/tests/tls/redis.key \
-        --tls-ca-cert-file ./redis/tests/tls/ca.crt&
+            -   name: Run Redis
+                run: |
+                    redis-server --tls-port 6380 --port 6379 \
+                    --tls-cert-file ./redis/tests/tls/redis.crt \
+                    --tls-key-file ./redis/tests/tls/redis.key \
+                    --tls-ca-cert-file ./redis/tests/tls/ca.crt&
 
-    - name: Install Go
-      uses: actions/setup-go@v1
-      with:
-        go-version: '${{ matrix.go-version }}'
-    
-    - name: Run Test
-      run: cd ./redis && go test ./... -v -race
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+
+            -   name: Run Test
+                run: cd ./redis && go test ./... -v -race

.github/workflows/test-ristretto.yml

@@ -1,24 +1,44 @@
-'on':
-  - push
-  - pull_request
-name: Ristretto
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
+name: S3
 jobs:
-  Tests:
-    runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        go-version:
-          - 1.16.x
-          - 1.17.x
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    steps:
-      - name: Install Go
-        uses: actions/setup-go@v1
-        with:
-          go-version: '${{ matrix.go-version }}'
-      - name: Fetch Repository
-        uses: actions/checkout@v2
-      - name: Run Test
-        run: cd ./ristretto && go mod tidy && go test ./... -v -race
+    Tests:
+        runs-on: ubuntu-latest
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+        -   name: Install Go
+            uses: actions/setup-go@v3
+            with:
+                go-version: '${{ matrix.go-version }}'
+        -   name: Setup Golang caches
+            uses: actions/cache@v3
+            with:
+                # In order:
+                # * Module download cache
+                # * Build cache (Linux)
+                # * Build cache (Mac)
+                # * Build cache (Windows)
+                path: |
+                    ~/go/pkg/mod
+                    ~/.cache/go-build
+                    ~/Library/Caches/go-build
+                    ~\AppData\Local\go-build
+                key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                restore-keys: |
+                    ${{ runner.os }}-go-${{ matrix.go-version }}-
+        -   name: Fetch Repository
+            uses: actions/checkout@v3
+        -   name: Run Test
+            run: cd ./ristretto && go mod tidy && go test ./... -v -race

.github/workflows/test-s3.yml

@@ -0,0 +1,53 @@
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
+name: S3
+jobs:
+    Tests:
+        runs-on: ubuntu-latest
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        steps:
+        -   name: Install MinIO
+            run: |
+                docker run -d -p 9000:9000 --name minio minio/minio server /data
+
+                export AWS_ACCESS_KEY_ID=minioadmin
+                export AWS_SECRET_ACCESS_KEY=minioadmin
+                export AWS_EC2_METADATA_DISABLED=true
+
+                aws --endpoint-url http://127.0.0.1:9000/ s3 mb s3://testbucket
+        -   name: Install Go
+            uses: actions/setup-go@v3
+            with:
+                go-version: '${{ matrix.go-version }}'
+        -   name: Setup Golang caches
+            uses: actions/cache@v3
+            with:
+                # In order:
+                # * Module download cache
+                # * Build cache (Linux)
+                # * Build cache (Mac)
+                # * Build cache (Windows)
+                path: |
+                    ~/go/pkg/mod
+                    ~/.cache/go-build
+                    ~/Library/Caches/go-build
+                    ~\AppData\Local\go-build
+                key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                restore-keys: |
+                    ${{ runner.os }}-go-${{ matrix.go-version }}-
+        -   name: Fetch Repository
+            uses: actions/checkout@v3
+        -   name: Run Test
+            run: cd ./s3 && go test ./... -v -race

.github/workflows/test.yml

@@ -1,30 +1,53 @@
-'on':
-  - push
-  - pull_request
+on:
+    push:
+        branches:
+            - master
+            - main
+    pull_request:
 name: Local Storage
 jobs:
-  Tests:
-    strategy:
-      matrix:
-        go-version:
-          - 1.14.x
-          - 1.15.x
-          - 1.16.x
-          - 1.17.x         
-        platform:
-          - ubuntu-latest
-          - windows-latest
-    runs-on: '${{ matrix.platform }}'
-    steps:
-      - name: Install Go
-        uses: actions/setup-go@v1
-        with:
-          go-version: '${{ matrix.go-version }}'
-      - name: Fetch Repository
-        uses: actions/checkout@v2
-      - name: Test Badger
-        run: cd ./badger && go test ./... -v -race
-      - name: Test Memory
-        run: cd ./memory && go test ./... -v -race
-      - name: Test SQLite3
-        run: cd ./sqlite3 && go test ./... -v -race
+    Tests:
+        strategy:
+            matrix:
+                go-version:
+                    - 1.14.x
+                    - 1.16.x
+                    - 1.19.x
+                platform:
+                    - ubuntu-latest
+                    - windows-latest
+        runs-on: '${{ matrix.platform }}'
+        steps:
+            -   name: Install Go
+                uses: actions/setup-go@v3
+                with:
+                    go-version: '${{ matrix.go-version }}'
+            -   name: Setup Golang caches
+                uses: actions/cache@v3
+                with:
+                    # In order:
+                    # * Module download cache
+                    # * Build cache (Linux)
+                    # * Build cache (Mac)
+                    # * Build cache (Windows)
+                    path: |
+                        ~/go/pkg/mod
+                        ~/.cache/go-build
+                        ~/Library/Caches/go-build
+                        ~\AppData\Local\go-build
+                    key: ${{ runner.os }}-go-${{ matrix.go-version }}-${{ hashFiles('**/go.sum') }}
+                    restore-keys: |
+                        ${{ runner.os }}-go-${{ matrix.go-version }}-
+
+            -   name: Fetch Repository
+                uses: actions/checkout@v3
+            -   name: Test Badger
+                run: cd ./badger && go test ./... -v -race
+            -   name: Test Memory
+                run: cd ./memory && go test ./... -v -race
+            -   name: Test SQLite3 - with -race check
+                if: runner.os != 'Windows'
+                run: cd ./sqlite3 && go test ./... -v -race
+            -   name: Test SQLite3 - without -race check
+                if: runner.os == 'Windows'
+                run: cd ./sqlite3 && go test ./... -v

README.md

@@ -81,3 +81,9 @@ type Storage interface {
 * [SQLite3](/sqlite3) <a href="https://github.com/gofiber/storage/actions?query=workflow%3A%22Local+Storage%22">
     <img src="https://img.shields.io/github/workflow/status/gofiber/storage/Local%20Storage?label=%F0%9F%A7%AA%20&style=flat&color=75C46B">
   </a>
+* [S3](/s3) <a href="https://github.com/gofiber/storage/actions?query=workflow%3A%22S3%22">
+    <img src="https://img.shields.io/github/workflow/status/gofiber/storage/S3?label=%F0%9F%A7%AA%20&style=flat&color=75C46B">
+  </a>
+* [Bbolt](/bbolt) <a href="https://github.com/gofiber/storage/actions?query=workflow%3A%22Bbolt%22">
+    <img src="https://img.shields.io/github/workflow/status/gofiber/storage/Bbolt?label=%F0%9F%A7%AA%20&style=flat&color=75C46B">
+  </a>

arangodb/go.mod

@@ -3,6 +3,6 @@ module github.com/gofiber/storage/arangodb
 go 1.14
 
 require (
-	github.com/arangodb/go-driver v1.2.1
+	github.com/arangodb/go-driver v1.3.3
 	github.com/gofiber/utils v0.1.2
 )

arangodb/go.sum

@@ -1,5 +1,5 @@
-github.com/arangodb/go-driver v1.2.1 h1:HREDHhDmzdIWxHmfkfTESbYUnRjESjPh4WUuXq7FZa8=
-github.com/arangodb/go-driver v1.2.1/go.mod h1:zdDkJJnCj8DAkfbtIjIXnsTrWIiy6VhP3Vy14p+uQeY=
+github.com/arangodb/go-driver v1.3.3 h1:UEV74zLYvvAvQgQgNHORdvaADtDX2uTVZH+1H7WAFAQ=
+github.com/arangodb/go-driver v1.3.3/go.mod h1:5GAx3XvK72DJPhJgyjZOtYAGc4SpY7rZDb3LyhCvLcQ=
 github.com/arangodb/go-velocypack v0.0.0-20200318135517-5af53c29c67e h1:Xg+hGrY2LcQBbxd0ZFdbGSyRKTYMZCfBbw/pMJFOk1g=
 github.com/arangodb/go-velocypack v0.0.0-20200318135517-5af53c29c67e/go.mod h1:mq7Shfa/CaixoDxiyAAc5jZ6CVBAyPaNQCGS7mkj4Ho=
 github.com/coreos/go-iptables v0.4.3/go.mod h1:/mVI274lEDI2ns62jHCDnCyBF9Iwsmekav8Dbxlm1MU=

bbolt/README.md

@@ -0,0 +1,92 @@
+# 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.
+
+
+### Table of Contents
+- [Signatures](#signatures)
+- [Installation](#installation)
+- [Examples](#examples)
+- [Config](#config)
+- [Default Config](#default-config)
+
+### Signatures
+```go
+func New(config ...Config) Storage
+func (s *Storage) Get(key string) ([]byte, error)
+func (s *Storage) Set(key string, val []byte, exp time.Duration) error
+func (s *Storage) Delete(key string) error
+func (s *Storage) Reset() error
+func (s *Storage) Close() error
+```
+### Installation
+Bbolt is tested on the 2 last [Go versions](https://golang.org/dl/) with support for modules. So make sure to initialize one first if you didn't do that yet:
+```bash
+go mod init github.com/<user>/<repo>
+```
+And then install the s3 implementation:
+```bash
+go get github.com/gofiber/storage/bbolt
+```
+
+### Examples
+Import the storage package.
+```go
+import "github.com/gofiber/storage/bbolt"
+```
+
+You can use the following possibilities to create a storage:
+```go
+// Initialize default config
+store := bbolt.New()
+
+// Initialize custom config
+store := bbolt.New(bbolt.Config{
+	Database: "my_database.db",
+	Bucket:   "my-bucket",
+	Reset:    false,
+})
+```
+
+### Config
+```go
+// Config defines the config for storage.
+type Config struct {
+	// Database path
+	//
+	// Optional. Default is "fiber.db"
+	Database string
+
+	// Bbolt bucket name
+	//
+	// Optional. Default is "fiber_storage"
+	Bucket string
+
+	// Timeout is the amount of time to wait to obtain a file lock.
+	// Only available on Darwin and Linux.
+	//
+	// Optional. Default is 60 * time.Second.
+	Timeout time.Duration
+
+	// Open database in read-only mode.
+	//
+	// Optional. Default is false
+	ReadOnly bool
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+}
+```
+
+### Default Config
+```go
+// ConfigDefault is the default config
+var ConfigDefault = Config{
+	Database: "fiber.db",
+	Bucket:   "fiber_storage",
+	Timeout:  60 * time.Second,
+	ReadOnly: false,
+	Reset:    false,
+}
+```

bbolt/bbolt.go

@@ -0,0 +1,106 @@
+package bbolt
+
+import (
+	"time"
+
+	"github.com/gofiber/utils"
+	"go.etcd.io/bbolt"
+)
+
+// Storage interface that is implemented by storage providers
+type Storage struct {
+	conn   *bbolt.DB
+	bucket string
+}
+
+// New creates a new storage
+func New(config ...Config) *Storage {
+	// Set default config
+	cfg := configDefault(config...)
+
+	conn, err := bbolt.Open(cfg.Database, 0666, &bbolt.Options{
+		Timeout:  cfg.Timeout,
+		ReadOnly: cfg.ReadOnly,
+	})
+	if err != nil {
+		panic(err)
+	}
+
+	// Reset bucket if field selected
+	if cfg.Reset {
+		if err := removeBucket(cfg, conn); err != nil {
+			panic(err)
+		}
+	}
+
+	// Create bucket if not exists
+	if err := createBucket(cfg, conn); err != nil {
+		panic(err)
+	}
+
+	return &Storage{
+		conn:   conn,
+		bucket: cfg.Bucket,
+	}
+
+}
+
+// Get value by key
+func (s *Storage) Get(key string) ([]byte, error) {
+	if len(key) <= 0 {
+		return nil, nil
+	}
+
+	var value []byte
+
+	err := s.conn.View(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+		value = b.Get(utils.UnsafeBytes(key))
+
+		return nil
+	})
+
+	return value, err
+}
+
+// Set key with value
+func (s *Storage) Set(key string, value []byte, exp time.Duration) error {
+	if len(key) <= 0 || len(value) <= 0 {
+		return nil
+	}
+
+	return s.conn.Update(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+
+		return b.Put(utils.UnsafeBytes(key), value)
+	})
+}
+
+// Delete entry by key
+func (s *Storage) Delete(key string) error {
+	if len(key) <= 0 {
+		return nil
+	}
+
+	return s.conn.Update(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+
+		return b.Delete(utils.UnsafeBytes(key))
+	})
+}
+
+// Reset all entries
+func (s *Storage) Reset() error {
+	return s.conn.Update(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+
+		return b.ForEach(func(k, _ []byte) error {
+			return b.Delete(k)
+		})
+	})
+}
+
+// Close the database
+func (s *Storage) Close() error {
+	return s.conn.Close()
+}

bbolt/bbolt_test.go

@@ -0,0 +1,97 @@
+package bbolt
+
+import (
+	"testing"
+
+	"github.com/gofiber/utils"
+)
+
+var testStore = New()
+
+func Test_Bbolt_Set(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_Bbolt_Set_Override(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_Bbolt_Get(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, val, result)
+}
+
+func Test_Bbolt_Get_NotExist(t *testing.T) {
+
+	result, err := testStore.Get("notexist")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_Bbolt_Delete(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Delete(key)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_Bbolt_Reset(t *testing.T) {
+	var (
+		val = []byte("doe")
+	)
+
+	err := testStore.Set("john1", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set("john2", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Reset()
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get("john1")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+
+	result, err = testStore.Get("john2")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_Bbolt_Close(t *testing.T) {
+	utils.AssertEqual(t, nil, testStore.Close())
+}

bbolt/config.go

@@ -0,0 +1,63 @@
+package bbolt
+
+import "time"
+
+// Config defines the config for storage.
+type Config struct {
+	// Database path
+	//
+	// Optional. Default is "fiber.db"
+	Database string
+
+	// Bbolt bucket name
+	//
+	// Optional. Default is "fiber_storage"
+	Bucket string
+
+	// Timeout is the amount of time to wait to obtain a file lock.
+	// Only available on Darwin and Linux.
+	//
+	// Optional. Default is set to 60 * time.Second.
+	Timeout time.Duration
+
+	// Open database in read-only mode.
+	//
+	// Optional. Default is false
+	ReadOnly bool
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+}
+
+// ConfigDefault is the default config
+var ConfigDefault = Config{
+	Database: "fiber.db",
+	Bucket:   "fiber_storage",
+	Timeout:  60 * time.Second,
+	ReadOnly: false,
+	Reset:    false,
+}
+
+// Helper function to set default values
+func configDefault(config ...Config) Config {
+	// Return default config if nothing provided
+	if len(config) < 1 {
+		return ConfigDefault
+	}
+
+	// Override default config
+	cfg := config[0]
+
+	// Set default values
+	if cfg.Database == "" {
+		cfg.Database = ConfigDefault.Database
+	}
+
+	if cfg.Bucket == "" {
+		cfg.Bucket = ConfigDefault.Bucket
+	}
+
+	return cfg
+}

bbolt/go.mod

@@ -0,0 +1,10 @@
+module github.com/gofiber/storage/bbolt
+
+go 1.16
+
+require (
+	github.com/gofiber/utils v0.1.2
+	go.etcd.io/bbolt v1.3.6
+)
+
+require golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a // indirect

bbolt/go.sum

@@ -0,0 +1,7 @@
+github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
+github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
+go.etcd.io/bbolt v1.3.6 h1:/ecaJf0sk1l4l6V4awd65v2C3ILy7MSj+s/x1ADCIMU=
+go.etcd.io/bbolt v1.3.6/go.mod h1:qXsaaIqmgQH0T+OPdb99Bf+PKfBBQVAdyD6TY9G8XM4=
+golang.org/x/sys v0.0.0-20200923182605-d9f96fdee20d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a h1:ppl5mZgokTT8uPkmYOyEUmPTr3ypaKkg5eFOGrAmxxE=
+golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

bbolt/utils.go

@@ -0,0 +1,20 @@
+package bbolt
+
+import (
+	"github.com/gofiber/utils"
+	"go.etcd.io/bbolt"
+)
+
+func createBucket(cfg Config, conn *bbolt.DB) error {
+	return conn.Update(func(tx *bbolt.Tx) error {
+		_, err := tx.CreateBucketIfNotExists(utils.UnsafeBytes(cfg.Bucket))
+
+		return err
+	})
+}
+
+func removeBucket(cfg Config, conn *bbolt.DB) error {
+	return conn.Update(func(tx *bbolt.Tx) error {
+		return tx.DeleteBucket(utils.UnsafeBytes(cfg.Bucket))
+	})
+}

dynamodb/README.md

@@ -1,4 +1,7 @@
-# ⚠ DynamoDB is still in development, do not use in production!
+# DynamoDB
+A DynamoDB storage driver using [aws/aws-sdk-go-v2](https://github.com/aws/aws-sdk-go-v2).
+
+**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)
 
 ....
 
@@ -60,28 +63,70 @@ type Config struct {
 	// Optional ("fiber_storage" by default).
 	Table string
 
-	// AWS access key ID (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_ACCESS_KEY_ID".
-	AWSaccessKeyID string
-
-	// AWS secret access key (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_SECRET_ACCESS_KEY".
-	AWSsecretAccessKey string
-
 	// CustomEndpoint allows you to set a custom DynamoDB service endpoint.
 	// This is especially useful if you're running a "DynamoDB local" Docker container for local testing.
 	// Typical value for the Docker container: "http://localhost:8000".
 	// See https://hub.docker.com/r/amazon/dynamodb-local/.
 	// Optional ("" by default)
-	CustomEndpoint string
+	Endpoint string
+
+	// Credentials overrides AWS access key and AWS secret access key. Not recommended.
+	//
+	// Optional. Default is Credentials{}
+	Credentials Credentials
+
+	// The maximum number of times requests that encounter retryable failures should be attempted.
+	//
+	// Optional. Default is 3
+	MaxAttempts int
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+
+	// ReadCapacityUnits of the table.
+	// Only required when the table doesn't exist yet and is created by gokv.
+	// Optional (5 by default, which is the same default value as when creating a table in the web console)
+	// 25 RCUs are included in the free tier (across all tables).
+	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
+	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
+	ReadCapacityUnits int64
+
+	// ReadCapacityUnits of the table.
+	// Only required when the table doesn't exist yet and is created by gokv.
+	// Optional (5 by default, which is the same default value as when creating a table in the web console)
+	// 25 RCUs are included in the free tier (across all tables).
+	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
+	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
+	WriteCapacityUnits int64
+
+	// If the table doesn't exist yet, gokv creates it.
+	// If WaitForTableCreation is true, gokv will block until the table is created, with a timeout of 15 seconds.
+	// If the table still doesn't exist after 15 seconds, an error is returned.
+	// If WaitForTableCreation is false, gokv returns the client immediately.
+	// In the latter case you need to make sure that you don't read from or write to the table before it's created,
+	// because otherwise you will get ResourceNotFoundException errors.
+	// Optional (true by default).
+	WaitForTableCreation *bool
 }
+
+type Credentials struct {
+	AccessKey       string
+	SecretAccessKey string
+}
+
 ```
 
 ### Default Config
 ```go
 var ConfigDefault = Config{
-	Table: "fiber_storage",
+	Table:                "fiber_storage",
+	Credentials:          Credentials{},
+	MaxAttempts:          3,
+	Reset:                false,
+	ReadCapacityUnits:    5,
+	WriteCapacityUnits:   5,
+	WaitForTableCreation: aws.Bool(true),
 }
 ```

dynamodb/config.go

@@ -1,6 +1,6 @@
 package dynamodb
 
-import "github.com/aws/aws-sdk-go/aws"
+import "github.com/aws/aws-sdk-go-v2/aws"
 
 // Config defines the config for storage.
 type Config struct {
@@ -15,22 +15,27 @@ type Config struct {
 	// Optional ("fiber_storage" by default).
 	Table string
 
-	// AWS access key ID (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_ACCESS_KEY_ID".
-	AWSaccessKeyID string
-
-	// AWS secret access key (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_SECRET_ACCESS_KEY".
-	AWSsecretAccessKey string
-
 	// CustomEndpoint allows you to set a custom DynamoDB service endpoint.
 	// This is especially useful if you're running a "DynamoDB local" Docker container for local testing.
 	// Typical value for the Docker container: "http://localhost:8000".
 	// See https://hub.docker.com/r/amazon/dynamodb-local/.
 	// Optional ("" by default)
-	CustomEndpoint string
+	Endpoint string
+
+	// Credentials overrides AWS access key and AWS secret access key. Not recommended.
+	//
+	// Optional. Default is Credentials{}
+	Credentials Credentials
+
+	// The maximum number of times requests that encounter retryable failures should be attempted.
+	//
+	// Optional. Default is 3
+	MaxAttempts int
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
 
 	// ReadCapacityUnits of the table.
 	// Only required when the table doesn't exist yet and is created by gokv.
@@ -38,14 +43,16 @@ type Config struct {
 	// 25 RCUs are included in the free tier (across all tables).
 	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
 	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
-	readCapacityUnits int64
+	ReadCapacityUnits int64
+
 	// ReadCapacityUnits of the table.
 	// Only required when the table doesn't exist yet and is created by gokv.
 	// Optional (5 by default, which is the same default value as when creating a table in the web console)
 	// 25 RCUs are included in the free tier (across all tables).
 	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
 	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
-	writeCapacityUnits int64
+	WriteCapacityUnits int64
+
 	// If the table doesn't exist yet, gokv creates it.
 	// If WaitForTableCreation is true, gokv will block until the table is created, with a timeout of 15 seconds.
 	// If the table still doesn't exist after 15 seconds, an error is returned.
@@ -53,15 +60,23 @@ type Config struct {
 	// In the latter case you need to make sure that you don't read from or write to the table before it's created,
 	// because otherwise you will get ResourceNotFoundException errors.
 	// Optional (true by default).
-	waitForTableCreation *bool
+	WaitForTableCreation *bool
+}
+
+type Credentials struct {
+	AccessKey       string
+	SecretAccessKey string
 }
 
 // ConfigDefault is the default config
 var ConfigDefault = Config{
 	Table:                "fiber_storage",
-	readCapacityUnits:    5,
-	writeCapacityUnits:   5,
-	waitForTableCreation: aws.Bool(true),
+	Credentials:          Credentials{},
+	MaxAttempts:          3,
+	Reset:                false,
+	ReadCapacityUnits:    5,
+	WriteCapacityUnits:   5,
+	WaitForTableCreation: aws.Bool(true),
 }
 
 // configDefault is a helper function to set default values
@@ -78,5 +93,18 @@ func configDefault(config ...Config) Config {
 	if cfg.Table == "" {
 		cfg.Table = ConfigDefault.Table
 	}
+	if cfg.MaxAttempts == 0 {
+		cfg.MaxAttempts = ConfigDefault.MaxAttempts
+	}
+	if cfg.ReadCapacityUnits == 0 {
+		cfg.ReadCapacityUnits = ConfigDefault.ReadCapacityUnits
+	}
+	if cfg.WriteCapacityUnits == 0 {
+		cfg.WriteCapacityUnits = ConfigDefault.WriteCapacityUnits
+	}
+	if cfg.WaitForTableCreation == nil {
+		cfg.WaitForTableCreation = ConfigDefault.WaitForTableCreation
+	}
+
 	return cfg
 }

dynamodb/dynamodb.go

@@ -3,90 +3,23 @@ package dynamodb
 import (
 	"context"
 	"errors"
+	"fmt"
 	"time"
 
-	"github.com/aws/aws-sdk-go/aws"
-	"github.com/aws/aws-sdk-go/aws/awserr"
-	"github.com/aws/aws-sdk-go/aws/credentials"
-	"github.com/aws/aws-sdk-go/aws/session"
-	awsdynamodb "github.com/aws/aws-sdk-go/service/dynamodb"
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/aws/retry"
+	awsconfig "github.com/aws/aws-sdk-go-v2/config"
+	"github.com/aws/aws-sdk-go-v2/credentials"
+	"github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue"
+	awsdynamodb "github.com/aws/aws-sdk-go-v2/service/dynamodb"
+	"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
 )
 
 // Storage interface that is implemented by storage providers
 type Storage struct {
-	db    *awsdynamodb.DynamoDB
-	table string
-}
-
-// New creates a new storage
-func New(config Config) *Storage {
-	// Set default config
-	cfg := configDefault(config)
-
-	// Create db
-	var creds *credentials.Credentials
-	if (cfg.AWSaccessKeyID != "" && cfg.AWSsecretAccessKey == "") || (cfg.AWSaccessKeyID == "" && cfg.AWSsecretAccessKey != "") {
-		panic("[DynamoDB] You need to set BOTH AWSaccessKeyID AND AWSsecretAccessKey")
-	} else if cfg.AWSaccessKeyID != "" {
-		// Due to the previous check we can be sure that in this case AWSsecretAccessKey is not empty as well.
-		creds = credentials.NewStaticCredentials(cfg.AWSaccessKeyID, cfg.AWSsecretAccessKey, "")
-	}
-
-	// Set database options
-	opt := aws.NewConfig()
-	if cfg.Region != "" {
-		opt = opt.WithRegion(cfg.Region)
-	}
-	if creds != nil {
-		opt = opt.WithCredentials(creds)
-	}
-	if cfg.CustomEndpoint != "" {
-		opt = opt.WithEndpoint(cfg.CustomEndpoint)
-	}
-
-	sessionOpt := session.Options{
-		SharedConfigState: session.SharedConfigEnable,
-	}
-
-	// ...but allow overwrite of region and credentials if they are set in the options.
-	sessionOpt.Config.MergeIn(opt)
-	session, err := session.NewSessionWithOptions(sessionOpt)
-	if err != nil {
-		panic(err)
-	}
-	svc := awsdynamodb.New(session)
-
-	timeoutCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
-	defer cancel()
-	describeTableInput := awsdynamodb.DescribeTableInput{
-		TableName: &cfg.Table,
-	}
-
-	_, err = svc.DescribeTableWithContext(timeoutCtx, &describeTableInput)
-	if err != nil {
-		awsErr, ok := err.(awserr.Error)
-		if !ok {
-			panic(err)
-		} else if awsErr.Code() == awsdynamodb.ErrCodeResourceNotFoundException {
-			err = createTable(cfg.Table, cfg.readCapacityUnits, cfg.writeCapacityUnits, *cfg.waitForTableCreation, describeTableInput, svc)
-			if err != nil {
-				panic(err)
-			}
-		} else {
-			panic(err)
-		}
-	}
-
-	// Create storage
-	store := &Storage{
-		db:    svc,
-		table: cfg.Table,
-	}
-
-	// Start garbage collector
-	//go store.gc()
-
-	return store
+	db             *awsdynamodb.Client
+	table          string
+	requestTimeout time.Duration
 }
 
 // "k" is used as table column name for the key.
@@ -95,126 +28,182 @@ var keyAttrName = "k"
 // "v" is used as table column name for the value.
 var valAttrName = "v"
 
+type table struct {
+	K string
+	V []byte
+}
+
+// New creates a new storage
+func New(config Config) *Storage {
+	// Set default config
+	cfg := configDefault(config)
+
+	awscfg, err := returnAWSConfig(cfg)
+	if err != nil {
+		panic(fmt.Sprintf("unable to load SDK config, %v", err))
+	}
+
+	// Create db
+	sess := awsdynamodb.NewFromConfig(awscfg)
+
+	timeoutCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+	describeTableInput := awsdynamodb.DescribeTableInput{
+		TableName: &cfg.Table,
+	}
+
+	// Create storage
+	store := &Storage{
+		db:    sess,
+		table: cfg.Table,
+	}
+
+	// Create table
+	_, err = sess.DescribeTable(timeoutCtx, &describeTableInput)
+	if err != nil {
+		var rnfe *types.ResourceNotFoundException
+		if errors.As(err, &rnfe) {
+			err := store.createTable(cfg, describeTableInput)
+			if err != nil {
+				panic(err)
+			}
+		} else {
+			panic(err)
+		}
+	}
+
+	return store
+}
+
 // Get value by key
 func (s *Storage) Get(key string) ([]byte, error) {
-	k := make(map[string]*awsdynamodb.AttributeValue)
-	k[keyAttrName] = &awsdynamodb.AttributeValue{
-		S: &key,
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
+	k := make(map[string]types.AttributeValue)
+	k[keyAttrName] = &types.AttributeValueMemberS{
+		Value: key,
 	}
 	getItemInput := awsdynamodb.GetItemInput{
 		TableName: &s.table,
 		Key:       k,
 	}
-	getItemOutput, err := s.db.GetItem(&getItemInput)
+	getItemOutput, err := s.db.GetItem(ctx, &getItemInput)
 	if err != nil {
+		var rnfe *types.ResourceNotFoundException
+		if errors.As(err, &rnfe) {
+			return nil, nil
+		}
+
 		return nil, err
 	} else if getItemOutput.Item == nil {
 		return nil, nil
 	}
-	attributeVal := getItemOutput.Item[valAttrName]
-	if attributeVal == nil {
-		return nil, nil
-	}
-	return attributeVal.B, nil
+
+	item := &table{}
+	err = attributevalue.UnmarshalMap(getItemOutput.Item, &item)
+
+	return item.V, err
 }
 
-// Set key with value
 // Set key with value
 func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
 	// Ain't Nobody Got Time For That
 	if len(key) <= 0 || len(val) <= 0 {
 		return nil
 	}
-	item := make(map[string]*awsdynamodb.AttributeValue)
-	item[keyAttrName] = &awsdynamodb.AttributeValue{
-		S: &key,
+
+	item := make(map[string]types.AttributeValue)
+	item[keyAttrName] = &types.AttributeValueMemberS{
+		Value: key,
 	}
-	item[valAttrName] = &awsdynamodb.AttributeValue{
-		B: val,
+	item[valAttrName] = &types.AttributeValueMemberB{
+		Value: val,
 	}
 	putItemInput := awsdynamodb.PutItemInput{
 		TableName: &s.table,
 		Item:      item,
 	}
-	_, err := s.db.PutItem(&putItemInput)
+
+	_, err := s.db.PutItem(ctx, &putItemInput)
 	return err
 }
 
 // Delete entry by key
 func (s *Storage) Delete(key string) error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
 	// Ain't Nobody Got Time For That
 	if len(key) <= 0 {
 		return nil
 	}
-	k := make(map[string]*awsdynamodb.AttributeValue)
-	k[keyAttrName] = &awsdynamodb.AttributeValue{
-		S: &key,
+
+	k := make(map[string]types.AttributeValue)
+	k[keyAttrName] = &types.AttributeValueMemberS{
+		Value: key,
 	}
 	deleteItemInput := awsdynamodb.DeleteItemInput{
 		TableName: &s.table,
 		Key:       k,
 	}
-	_, err := s.db.DeleteItem(&deleteItemInput)
+
+	_, err := s.db.DeleteItem(ctx, &deleteItemInput)
 	return err
 }
 
 // Reset all entries, including unexpired
 func (s *Storage) Reset() error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
 	deleteTableInput := awsdynamodb.DeleteTableInput{
 		TableName: &s.table,
 	}
-	_, err := s.db.DeleteTable(&deleteTableInput)
+	_, err := s.db.DeleteTable(ctx, &deleteTableInput)
 	return err
 }
 
 // Close the database
 func (s *Storage) Close() error {
-	// In the DynamoDB implementation this doesn't have any effect.
 	return nil
 }
 
-// GC deletes all expired entries
-// func (s *Storage) gc() {
-// 	ticker := time.NewTicker(s.gcInterval)
-// 	defer ticker.Stop()
-// 	for {
-// 		select {
-// 		case <-s.done:
-// 			return
-// 		case t := <-ticker.C:
-// 			_, _ = s.db.Exec(s.sqlGC, t.Unix())
-// 		}
-// 	}
-// }
+func (s *Storage) createTable(cfg Config, describeTableInput awsdynamodb.DescribeTableInput) error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
 
-func createTable(tableName string, readCapacityUnits, writeCapacityUnits int64, waitForTableCreation bool, describeTableInput awsdynamodb.DescribeTableInput, svc *awsdynamodb.DynamoDB) error {
 	keyAttrType := "S" // For "string"
 	keyType := "HASH"  // As opposed to "RANGE"
+
 	createTableInput := awsdynamodb.CreateTableInput{
-		TableName: &tableName,
-		AttributeDefinitions: []*awsdynamodb.AttributeDefinition{{
+		TableName: &s.table,
+		AttributeDefinitions: []types.AttributeDefinition{{
 			AttributeName: &keyAttrName,
-			AttributeType: &keyAttrType,
+			AttributeType: types.ScalarAttributeType(keyAttrType),
 		}},
-		KeySchema: []*awsdynamodb.KeySchemaElement{{
+		KeySchema: []types.KeySchemaElement{{
 			AttributeName: &keyAttrName,
-			KeyType:       &keyType,
+			KeyType:       types.KeyType(keyType),
 		}},
-		ProvisionedThroughput: &awsdynamodb.ProvisionedThroughput{
-			ReadCapacityUnits:  &readCapacityUnits,
-			WriteCapacityUnits: &writeCapacityUnits,
+		ProvisionedThroughput: &types.ProvisionedThroughput{
+			ReadCapacityUnits:  &cfg.ReadCapacityUnits,
+			WriteCapacityUnits: &cfg.WriteCapacityUnits,
 		},
 	}
-	_, err := svc.CreateTable(&createTableInput)
+	_, err := s.db.CreateTable(ctx, &createTableInput)
 	if err != nil {
 		return err
 	}
 	// If configured (true by default), block until the table is created.
 	// Typical table creation duration is 10 seconds.
-	if waitForTableCreation {
+	if *cfg.WaitForTableCreation {
 		for try := 1; try < 16; try++ {
-			describeTableOutput, err := svc.DescribeTable(&describeTableInput)
-			if err != nil || *describeTableOutput.Table.TableStatus == "CREATING" {
+			describeTableOutput, err := s.db.DescribeTable(ctx, &describeTableInput)
+			if err != nil || describeTableOutput.Table.TableStatus == "CREATING" {
 				time.Sleep(1 * time.Second)
 			} else {
 				break
@@ -222,14 +211,56 @@ func createTable(tableName string, readCapacityUnits, writeCapacityUnits int64,
 		}
 		// Last try (16th) after 15 seconds of waiting.
 		// Now handle error as such.
-		describeTableOutput, err := svc.DescribeTable(&describeTableInput)
+		describeTableOutput, err := s.db.DescribeTable(ctx, &describeTableInput)
 		if err != nil {
-			return errors.New("The DynamoDB table couldn't be created")
+			return errors.New("dynamodb: the table couldn't be created")
 		}
-		if *describeTableOutput.Table.TableStatus == "CREATING" {
-			return errors.New("The DynamoDB table took too long to be created")
+		if describeTableOutput.Table.TableStatus == "CREATING" {
+			return errors.New("dynamodb: the table took too long to be created")
 		}
 	}
 
 	return nil
 }
+
+// Context for making requests will timeout if a non-zero timeout is configured
+func (s *Storage) requestContext() (context.Context, context.CancelFunc) {
+	if s.requestTimeout > 0 {
+		return context.WithTimeout(context.Background(), s.requestTimeout)
+	}
+	return context.Background(), func() {}
+}
+
+func returnAWSConfig(cfg Config) (aws.Config, error) {
+	endpoint := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
+		if cfg.Endpoint != "" {
+			return aws.Endpoint{
+				PartitionID:       "aws",
+				URL:               cfg.Endpoint,
+				SigningRegion:     cfg.Region,
+				HostnameImmutable: true,
+			}, nil
+		}
+		return aws.Endpoint{}, &aws.EndpointNotFoundError{}
+	})
+
+	if cfg.Credentials != (Credentials{}) {
+		credentials := credentials.NewStaticCredentialsProvider(cfg.Credentials.AccessKey, cfg.Credentials.SecretAccessKey, "")
+		return awsconfig.LoadDefaultConfig(context.TODO(),
+			awsconfig.WithRegion(cfg.Region),
+			awsconfig.WithEndpointResolverWithOptions(endpoint),
+			awsconfig.WithCredentialsProvider(credentials),
+			awsconfig.WithRetryer(func() aws.Retryer {
+				return retry.AddWithMaxAttempts(retry.NewStandard(), cfg.MaxAttempts)
+			}),
+		)
+	}
+
+	return awsconfig.LoadDefaultConfig(context.TODO(),
+		awsconfig.WithRegion(cfg.Region),
+		awsconfig.WithEndpointResolverWithOptions(endpoint),
+		awsconfig.WithRetryer(func() aws.Retryer {
+			return retry.AddWithMaxAttempts(retry.NewStandard(), cfg.MaxAttempts)
+		}),
+	)
+}

dynamodb/dynamodb_test.go

@@ -1 +1,107 @@
 package dynamodb
+
+import (
+	"testing"
+
+	"github.com/gofiber/utils"
+)
+
+var testStore = New(
+	Config{
+		Table:    "fiber_storage",
+		Endpoint: "http://localhost:8000/",
+		Region:   "us-east-1",
+		Credentials: Credentials{
+			AccessKey:       "dummy",
+			SecretAccessKey: "dummy",
+		},
+	},
+)
+
+func Test_DynamoDB_Set(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_DynamoDB_Set_Override(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_DynamoDB_Get(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, val, result)
+}
+
+func Test_DynamoDB_Get_NotExist(t *testing.T) {
+
+	result, err := testStore.Get("notexist")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_DynamoDB_Delete(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Delete(key)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_DynamoDB_Reset(t *testing.T) {
+	var (
+		val = []byte("doe")
+	)
+
+	err := testStore.Set("john1", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set("john2", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Reset()
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get("john1")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+
+	result, err = testStore.Get("john2")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_DynamoDB_Close(t *testing.T) {
+	utils.AssertEqual(t, nil, testStore.Close())
+}

dynamodb/go.mod

@@ -2,4 +2,11 @@ module github.com/gofiber/storage/dynamodb
 
 go 1.14
 
-require github.com/aws/aws-sdk-go v1.42.38
+require (
+	github.com/aws/aws-sdk-go-v2 v1.16.8
+	github.com/aws/aws-sdk-go-v2/config v1.15.15
+	github.com/aws/aws-sdk-go-v2/credentials v1.12.10
+	github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.9.8
+	github.com/aws/aws-sdk-go-v2/service/dynamodb v1.15.10
+	github.com/gofiber/utils v0.1.2
+)

dynamodb/go.sum

@@ -1,23 +1,48 @@
-github.com/aws/aws-sdk-go v1.42.38 h1:/fNQTB4ZUQOa8+cfX7C7F0zyXRdiN1jGKKXt3+5nmzM=
-github.com/aws/aws-sdk-go v1.42.38/go.mod h1:OGr6lGMAKGlG9CVrYnWYDKIyb829c6EVBRjxqjmPepc=
+github.com/aws/aws-sdk-go-v2 v1.16.8 h1:gOe9UPR98XSf7oEJCcojYg+N2/jCRm4DdeIsP85pIyQ=
+github.com/aws/aws-sdk-go-v2 v1.16.8/go.mod h1:6CpKuLXg2w7If3ABZCl/qZ6rEgwtjZTn4eAf4RcEyuw=
+github.com/aws/aws-sdk-go-v2/config v1.15.15 h1:yBV+J7Au5KZwOIrIYhYkTGJbifZPCkAnCFSvGsF3ui8=
+github.com/aws/aws-sdk-go-v2/config v1.15.15/go.mod h1:A1Lzyy/o21I5/s2FbyX5AevQfSVXpvvIDCoVFD0BC4E=
+github.com/aws/aws-sdk-go-v2/credentials v1.12.10 h1:7gGcMQePejwiKoDWjB9cWnpfVdnz/e5JwJFuT6OrroI=
+github.com/aws/aws-sdk-go-v2/credentials v1.12.10/go.mod h1:g5eIM5XRs/OzIIK81QMBl+dAuDyoLN0VYaLP+tBqEOk=
+github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.9.8 h1:0ip7KxkhaxsDsxOGHl8/6PRzuvkBnNCKQQNXCrmBRA4=
+github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.9.8/go.mod h1:gYOUOID0SE7Sc7b/5TocldT6Veh7Hftd0RgszK0B9kg=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.9 h1:hz8tc+OW17YqxyFFPSkvfSikbqWcyyHRyPVSTzC0+aI=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.9/go.mod h1:KDCCm4ONIdHtUloDcFvK2+vshZvx4Zmj7UMDfusuz5s=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.15 h1:bx5F2mr6H6FC7zNIQoDoUr8wEKnvmwRncujT3FYRtic=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.15/go.mod h1:pWrr2OoHlT7M/Pd2y4HV3gJyPb3qj5qMmnPkKSNPYK4=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.9 h1:5sbyznZC2TeFpa4fvtpvpcGbzeXEEs1l1Jo51ynUNsQ=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.9/go.mod h1:08tUpeSGN33QKSO7fwxXczNfiwCpbj+GxK6XKwqWVv0=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.16 h1:f0ySVcmQhwmzn7zQozd8wBM3yuGBfzdpsOaKQ0/Epzw=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.16/go.mod h1:CYmI+7x03jjJih8kBEEFKRQc40UjUokT0k7GbvrhhTc=
+github.com/aws/aws-sdk-go-v2/service/dynamodb v1.15.10 h1:GLklbtMUQCToju09LyT+AjbwTQ0KCQudNLTA0H2xbBk=
+github.com/aws/aws-sdk-go-v2/service/dynamodb v1.15.10/go.mod h1:zM5dQf0mZfcW4s8OsJFXvzedbY5n1rO581X4xei6XcA=
+github.com/aws/aws-sdk-go-v2/service/dynamodbstreams v1.13.11 h1:ZhmeOIq1SIn2QRYbVX1RC+k2+V3o/Cb6Rb8l4NNs8sA=
+github.com/aws/aws-sdk-go-v2/service/dynamodbstreams v1.13.11/go.mod h1:SfaTqHKnCntSSFP9xjozom2kJVhNF4s9cxWdmMoc8Bo=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.3 h1:4n4KCtv5SUoT5Er5XV41huuzrCqepxlW3SDI9qHQebc=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.3/go.mod h1:gkb2qADY+OHaGLKNTYxMaQNacfeyQpZ4csDTQMeFmcw=
+github.com/aws/aws-sdk-go-v2/service/internal/endpoint-discovery v1.7.9 h1:COsLtfmOSgPGnKUreE99/5pIgtmGLzmLtVrQa12QzU4=
+github.com/aws/aws-sdk-go-v2/service/internal/endpoint-discovery v1.7.9/go.mod h1:IixPDVckNk0HhYDQwUmTonTAfQlfABg9E72whAbq5k0=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.9 h1:sHfDuhbOuuWSIAEDd3pma6p0JgUcR2iePxtCE8gfCxQ=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.9/go.mod h1:yQowTpvdZkFVuHrLBXmczat4W+WJKg/PafBZnGBLga0=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.13 h1:DQpf+al+aWozOEmVEdml67qkVZ6vdtGUi71BZZWw40k=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.13/go.mod h1:d7ptRksDDgvXaUvxyHZ9SYh+iMDymm94JbVcgvSYSzU=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.10 h1:7tquJrhjYz2EsCBvA9VTl+sBAAh1bv7h/sGASdZOGGo=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.10/go.mod h1:cftkHYN6tCDNfkSasAmclSfl4l7cySoay8vz7p/ce0E=
+github.com/aws/smithy-go v1.12.0 h1:gXpeZel/jPoWQ7OEmLIgCUnhkFftqNfwWUwAHSlp1v0=
+github.com/aws/smithy-go v1.12.0/go.mod h1:Tg+OJXh4MB2R/uN61Ko2f6hTZwB/ZYGOtib8J3gBHzA=
 github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
+github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
+github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg=
+github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg=
 github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1 h1:shLQSRRSCCPj3f2gpwzGwWFoC7ycTf1rcQZHOlsJ6N8=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
-github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-golang.org/x/net v0.0.0-20211216030914-fe4d6282115f h1:hEYJvxw1lSnWIl8X9ofsYMklzaDs90JI2az5YMd4fPM=
-golang.org/x/net v0.0.0-20211216030914-fe4d6282115f/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
-golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
-golang.org/x/text v0.3.6 h1:aRYxNxv6iGQlyVaZmk6ZgYEDa+Jg18DxebPSrd6bg1M=
-golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
-golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10=

go.mod

@@ -1,3 +1,3 @@
 module github.com/gofiber/storage
 
-go 1.14
+go 1.14

mongodb/go.mod

@@ -3,12 +3,8 @@ module github.com/gofiber/storage/mongodb
 go 1.14
 
 require (
-	github.com/go-stack/stack v1.8.1 // indirect
 	github.com/gofiber/utils v0.1.2
 	github.com/golang/snappy v0.0.4 // indirect
 	github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a // indirect
-	go.mongodb.org/mongo-driver v1.8.2
-	golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3 // indirect
-	golang.org/x/sync v0.0.0-20210220032951-036812b2e83c // indirect
-	golang.org/x/text v0.3.7 // indirect
+	go.mongodb.org/mongo-driver v1.10.1
 )

mongodb/go.sum

@@ -1,9 +1,6 @@
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
-github.com/go-stack/stack v1.8.1 h1:ntEHSVwIt7PNXNpgPmVfMrNhLtgjlmnZha2kOpuRiDw=
-github.com/go-stack/stack v1.8.1/go.mod h1:dcoOX6HbPZSZptuspn9bctJ+N/CnF5gGygcUP3XYfe4=
 github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
 github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
 github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
@@ -18,6 +15,7 @@ github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORN
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe h1:iruDEfMl2E6fbMZ9s0scYfZQ84/6SPL6zC8ACM2oIL0=
 github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe/go.mod h1:wL8QJuTMNUDYhXwkmfOly8iTdp5TEcJFWZD2D7SIkUc=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
@@ -30,46 +28,39 @@ github.com/tidwall/pretty v1.0.0 h1:HsD+QiTn7sK6flMKIvNmpqz1qrpP3Ps6jOKIKMooyg4=
 github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=
 github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
 github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
-github.com/xdg-go/scram v1.0.2 h1:akYIkZ28e6A96dkWNJQu3nmCzH3YfwMPQExUYDaRv7w=
-github.com/xdg-go/scram v1.0.2/go.mod h1:1WAq6h33pAW+iRreB34OORO2Nf7qel3VV3fjBj+hCSs=
-github.com/xdg-go/stringprep v1.0.2 h1:6iq84/ryjjeRmMJwxutI51F2GIPlP5BfTvXHeYjyhBc=
-github.com/xdg-go/stringprep v1.0.2/go.mod h1:8F9zXuvzgwmyT5DUm4GUfZGDdT3W+LCvS6+da4O5kxM=
+github.com/xdg-go/scram v1.1.1 h1:VOMT+81stJgXW3CpHyqHN3AXDYIMsx56mEFrB37Mb/E=
+github.com/xdg-go/scram v1.1.1/go.mod h1:RaEWvsqvNKKvBPvcKeFjrG2cJqOkHTiyTpzz23ni57g=
+github.com/xdg-go/stringprep v1.0.3 h1:kdwGpVNwPFtjs98xCGkHjQtGKh86rDcRZN17QEMCOIs=
+github.com/xdg-go/stringprep v1.0.3/go.mod h1:W3f5j4i+9rC0kuIEJL0ky1VpHXQU3ocBgklLGvcBnW8=
 github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
 github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a h1:fZHgsYlfvtyqToslyjUt3VOPF4J7aK/3MPcK7xp3PDk=
 github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a/go.mod h1:ul22v+Nro/R083muKhosV54bj5niojjWZvU8xrevuH4=
-go.mongodb.org/mongo-driver v1.8.2 h1:8ssUXufb90ujcIvR6MyE1SchaNj0SFxsakiZgxIyrMk=
-go.mongodb.org/mongo-driver v1.8.2/go.mod h1:0sQWfOeY63QTntERDJJ/0SuKK0T1uVSgKCuAROlKEPY=
+go.mongodb.org/mongo-driver v1.10.1 h1:NujsPveKwHaWuKUer/ceo9DzEe7HIj1SlJ6uvXZG0S4=
+go.mongodb.org/mongo-driver v1.10.1/go.mod h1:z4XpeoU6w+9Vht+jAFyLgVrD+jGSQQe0+CBWFHNiHt8=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20200302210943-78000ba7a073/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/crypto v0.0.0-20201216223049-8b5274cf687f/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I=
-golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3 h1:0es+/5331RGQPcXlMfP+WrnIIS6dNnNRe0WB02W0F4M=
-golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
-golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d h1:sK3txAijHtOK88l68nt020reeT1ZdKLIYetKl95FzVY=
+golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
-golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20210220032951-036812b2e83c h1:5KslGYwFpkhGh+Q16bwMP3cOontH8FOep7tGV86Y7SQ=
 golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
-golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.7 h1:olpwvP2KacW1ZWvsR7uQhoyTYvKAupfQrRGBFM352Gk=
 golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/tools v0.0.0-20190531172133-b3315ee88b7d/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

postgres/go.mod

@@ -4,5 +4,5 @@ go 1.14
 
 require (
 	github.com/gofiber/utils v0.1.2
-	github.com/lib/pq v1.10.4
+	github.com/lib/pq v1.10.6
 )

postgres/go.sum

@@ -1,4 +1,4 @@
 github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
 github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
-github.com/lib/pq v1.10.4 h1:SO9z7FRPzA03QhHKJrH5BXA6HU1rS4V2nIVrrNC1iYk=
-github.com/lib/pq v1.10.4/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
+github.com/lib/pq v1.10.6 h1:jbk+ZieJ0D7EVGJYpL9QTz7/YW6UHbmdnZWYyK5cdBs=
+github.com/lib/pq v1.10.6/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=

postgres/postgres.go

@@ -56,12 +56,16 @@ func New(config ...Config) *Storage {
 	if cfg.Username != "" || cfg.Password != "" {
 		dsn += "@"
 	}
-	dsn += fmt.Sprintf("%s:%d", url.QueryEscape(cfg.Host), cfg.Port)
+	// unix socket host path
+	if strings.HasPrefix(cfg.Host, "/") {
+		dsn += fmt.Sprintf("%s:%d", cfg.Host, cfg.Port)
+	} else {
+		dsn += fmt.Sprintf("%s:%d", url.QueryEscape(cfg.Host), cfg.Port)
+	}
 	dsn += fmt.Sprintf("/%s?connect_timeout=%d&sslmode=%s",
 		url.QueryEscape(cfg.Database),
 		int64(cfg.timeout.Seconds()),
-		cfg.SslMode,
-	)
+		cfg.SslMode)
 
 	// Create db
 	db, err := sql.Open("postgres", dsn)

redis/README.md

@@ -68,7 +68,7 @@ type Config struct {
 
 	// Port where the DB is listening on
 	//
-	// Optional. Default is 3306
+	// Optional. Default is 6379
 	Port int
 
 	// Server username

redis/config.go

@@ -11,7 +11,7 @@ type Config struct {
 
 	// Port where the DB is listening on
 	//
-	// Optional. Default is 3306
+	// Optional. Default is 6379
 	Port int
 
 	// Server username

redis/go.mod

@@ -3,6 +3,7 @@ module github.com/gofiber/storage/redis
 go 1.14
 
 require (
-	github.com/go-redis/redis/v8 v8.11.4
+	github.com/go-redis/redis/v8 v8.11.5
 	github.com/gofiber/utils v0.1.2
+	github.com/google/go-cmp v0.5.6 // indirect
 )

redis/go.sum

@@ -1,5 +1,8 @@
 github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
 github.com/cespare/xxhash/v2 v2.1.2/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
+github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
+github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
@@ -7,8 +10,8 @@ github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cu
 github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
 github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWoS4=
 github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
-github.com/go-redis/redis/v8 v8.11.4 h1:kHoYkfZP6+pe04aFTnhDH6GDROa5yJdHJVNxV3F46Tg=
-github.com/go-redis/redis/v8 v8.11.4/go.mod h1:2Z2wHZXdQpCDXEGzqMockDpNyYvi2l4Pxt6RJr792+w=
+github.com/go-redis/redis/v8 v8.11.5 h1:AcZZR7igkdvfVmQTPnu9WE37LRrO/YrBH5zWyjDC0oI=
+github.com/go-redis/redis/v8 v8.11.5/go.mod h1:gREzHqY1hg6oD9ngVRbLStwAWKhA0FEgq8Jd4h5lpwo=
 github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg7847qk6SyHyPtNmDHnmrv/HOrqktSC+C9fM+CJOE=
 github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
 github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
@@ -28,18 +31,24 @@ github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
 github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ=
 github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
 github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
+github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
 github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
 github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE=
 github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=
 github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
 github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk=
-github.com/onsi/ginkgo v1.16.4 h1:29JGrr5oVBm5ulCWet69zQkzWipVXIol6ygQUe/EzNc=
 github.com/onsi/ginkgo v1.16.4/go.mod h1:dX+/inL/fNMqNlz0e9LfyB9TswhZpCVdJM/Z6Vvnwo0=
+github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE=
+github.com/onsi/ginkgo v1.16.5/go.mod h1:+E8gABHa3K6zRBolWtd+ROzc/U5bkGt0FwiG042wbpU=
+github.com/onsi/ginkgo/v2 v2.0.0 h1:CcuG/HvWNkkaqCUpJifQY8z7qEMBJya6aLPx6ftGyjQ=
+github.com/onsi/ginkgo/v2 v2.0.0/go.mod h1:vw5CSIxN1JObi/U8gcbwft7ZxR2dgaR70JSE3/PpL4c=
 github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY=
 github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo=
-github.com/onsi/gomega v1.16.0 h1:6gjqkI8iiRHMvdccRJM8rVKjCWk6ZIm6FTm3ddIe4/c=
-github.com/onsi/gomega v1.16.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
+github.com/onsi/gomega v1.17.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
+github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE=
+github.com/onsi/gomega v1.18.1/go.mod h1:0q+aL8jAiMXy9hbwj2mr5GziHiwhAIQpFmmtT5hitRs=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
@@ -64,12 +73,14 @@ golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7w
 golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191204072324-ce4227a45e2e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210112080510-489259a85091/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210423082822-04245dca01da h1:b3NXsE2LusjYGGjL5bxEVZZORm/YEFFrWFjR8eFrw/c=
 golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e h1:fLOSk5Q00efkSvAm+4xcoXD+RRmLmmulPn5I3Y9F2EM=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=

ristretto/ristretto_test.go

@@ -42,6 +42,9 @@ func Test_Ristretto_Get(t *testing.T) {
 	err := testStore.Set(key, val, 0)
 	utils.AssertEqual(t, nil, err)
 
+	// stabilize with some delay in between -> bug already communicated
+	time.Sleep(10000)
+
 	result, err := testStore.Get(key)
 	utils.AssertEqual(t, nil, err)
 	utils.AssertEqual(t, val, result)
@@ -86,6 +89,9 @@ func Test_Ristretto_Delete(t *testing.T) {
 	err := testStore.Set(key, val, 0)
 	utils.AssertEqual(t, nil, err)
 
+	// stabilize with some delay in between -> bug already communicated
+	time.Sleep(10000)
+
 	err = testStore.Delete(key)
 	utils.AssertEqual(t, nil, err)
 

s3/README.md

@@ -0,0 +1,108 @@
+# S3
+
+A S3 storage driver using [aws/aws-sdk-go-v2](https://github.com/aws/aws-sdk-go-v2).
+
+**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)
+
+
+### Table of Contents
+- [Signatures](#signatures)
+- [Installation](#installation)
+- [Examples](#examples)
+- [Config](#config)
+- [Default Config](#default-config)
+
+### Signatures
+```go
+func New(config ...Config) Storage
+func (s *Storage) Get(key string) ([]byte, error)
+func (s *Storage) Set(key string, val []byte, exp time.Duration) error
+func (s *Storage) Delete(key string) error
+func (s *Storage) Reset() error
+func (s *Storage) Close() error
+```
+### Installation
+S3 is tested on the 2 last [Go versions](https://golang.org/dl/) with support for modules. So make sure to initialize one first if you didn't do that yet:
+```bash
+go mod init github.com/<user>/<repo>
+```
+And then install the s3 implementation:
+```bash
+go get github.com/gofiber/storage/s3
+```
+
+### Examples
+Import the storage package.
+```go
+import "github.com/gofiber/storage/s3"
+```
+
+You can use the following possibilities to create a storage:
+```go
+// Initialize default config
+store := s3.New()
+
+// Initialize custom config
+store := s3.New(s3.Config{
+	Bucket:   "my-bucket-url",
+	Endpoint: "my-endpoint",
+	Region:   "my-region",
+	Reset:    false,
+})
+```
+
+### Config
+```go
+// Config defines the config for storage.
+type Config struct {
+	// S3 bucket name
+	Bucket string
+
+	// AWS endpoint
+	Endpoint string
+
+	// AWS region
+	Region string
+
+	// Request timeout
+	//
+	// Optional. Default is 0 (no timeout)
+	RequestTimeout time.Duration
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+
+    // Credentials overrides AWS access key and AWS secret access key. Not recommended.
+	//
+	// Optional. Default is Credentials{}
+	Credentials Credentials
+
+	// The maximum number of times requests that encounter retryable failures should be attempted.
+	//
+	// Optional. Default is 3
+	MaxAttempts int
+
+}
+
+type Credentials struct {
+	AccessKey       string
+	SecretAccessKey string
+}
+```
+
+### Default Config
+The default configuration lacks Bucket, Region, and Endpoint which are all required and must be overwritten:
+```go
+// ConfigDefault is the default config
+var ConfigDefault = Config{
+	Bucket:         "",
+	Region:         "",
+	Endpoint:       "",
+	Credentials:    Credentials{},
+	MaxAttempts:    3,
+	RequestTimeout: 0,
+	Reset:          false,
+}
+```

s3/config.go

@@ -0,0 +1,69 @@
+package s3
+
+import "time"
+
+// Config defines the config for storage.
+type Config struct {
+	// S3 bucket name
+	Bucket string
+
+	// AWS endpoint
+	Endpoint string
+
+	// AWS region
+	Region string
+
+	// Request timeout
+	//
+	// Optional. Default is 0 (no timeout)
+	RequestTimeout time.Duration
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+
+	// Credentials overrides AWS access key and AWS secret access key. Not recommended.
+	//
+	// Optional. Default is Credentials{}
+	Credentials Credentials
+
+	// The maximum number of times requests that encounter retryable failures should be attempted.
+	//
+	// Optional. Default is 3
+	MaxAttempts int
+}
+
+type Credentials struct {
+	AccessKey       string
+	SecretAccessKey string
+}
+
+// ConfigDefault is the default config
+var ConfigDefault = Config{
+	Bucket:         "",
+	Region:         "",
+	Endpoint:       "",
+	Credentials:    Credentials{},
+	MaxAttempts:    3,
+	RequestTimeout: 0,
+	Reset:          false,
+}
+
+// Helper function to set default values
+func configDefault(config ...Config) Config {
+	// Return default config if nothing provided
+	if len(config) < 1 {
+		return ConfigDefault
+	}
+
+	// Override default config
+	cfg := config[0]
+
+	// Set default values
+	if cfg.Bucket == "" {
+		cfg.Bucket = ConfigDefault.Bucket
+	}
+
+	return cfg
+}

s3/go.mod

@@ -0,0 +1,12 @@
+module github.com/gofiber/storage/s3
+
+go 1.16
+
+require (
+	github.com/aws/aws-sdk-go-v2 v1.16.8
+	github.com/aws/aws-sdk-go-v2/config v1.15.15
+	github.com/aws/aws-sdk-go-v2/credentials v1.12.10
+	github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.11.21
+	github.com/aws/aws-sdk-go-v2/service/s3 v1.27.2
+	github.com/gofiber/utils v0.1.2
+)

s3/go.sum

@@ -0,0 +1,52 @@
+github.com/aws/aws-sdk-go-v2 v1.16.8 h1:gOe9UPR98XSf7oEJCcojYg+N2/jCRm4DdeIsP85pIyQ=
+github.com/aws/aws-sdk-go-v2 v1.16.8/go.mod h1:6CpKuLXg2w7If3ABZCl/qZ6rEgwtjZTn4eAf4RcEyuw=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.4.3 h1:S/ZBwevQkr7gv5YxONYpGQxlMFFYSRfz3RMcjsC9Qhk=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.4.3/go.mod h1:gNsR5CaXKmQSSzrmGxmwmct/r+ZBfbxorAuXYsj/M5Y=
+github.com/aws/aws-sdk-go-v2/config v1.15.15 h1:yBV+J7Au5KZwOIrIYhYkTGJbifZPCkAnCFSvGsF3ui8=
+github.com/aws/aws-sdk-go-v2/config v1.15.15/go.mod h1:A1Lzyy/o21I5/s2FbyX5AevQfSVXpvvIDCoVFD0BC4E=
+github.com/aws/aws-sdk-go-v2/credentials v1.12.10 h1:7gGcMQePejwiKoDWjB9cWnpfVdnz/e5JwJFuT6OrroI=
+github.com/aws/aws-sdk-go-v2/credentials v1.12.10/go.mod h1:g5eIM5XRs/OzIIK81QMBl+dAuDyoLN0VYaLP+tBqEOk=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.9 h1:hz8tc+OW17YqxyFFPSkvfSikbqWcyyHRyPVSTzC0+aI=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.9/go.mod h1:KDCCm4ONIdHtUloDcFvK2+vshZvx4Zmj7UMDfusuz5s=
+github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.11.21 h1:bpiKFJ9aC0xTVpygSRRRL/YHC1JZ+pHQHENATHuoiwo=
+github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.11.21/go.mod h1:iIYPrQ2rYfZiB/iADYlhj9HHZ9TTi6PqKQPAqygohbE=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.15 h1:bx5F2mr6H6FC7zNIQoDoUr8wEKnvmwRncujT3FYRtic=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.15/go.mod h1:pWrr2OoHlT7M/Pd2y4HV3gJyPb3qj5qMmnPkKSNPYK4=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.9 h1:5sbyznZC2TeFpa4fvtpvpcGbzeXEEs1l1Jo51ynUNsQ=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.9/go.mod h1:08tUpeSGN33QKSO7fwxXczNfiwCpbj+GxK6XKwqWVv0=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.16 h1:f0ySVcmQhwmzn7zQozd8wBM3yuGBfzdpsOaKQ0/Epzw=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.16/go.mod h1:CYmI+7x03jjJih8kBEEFKRQc40UjUokT0k7GbvrhhTc=
+github.com/aws/aws-sdk-go-v2/internal/v4a v1.0.6 h1:3L8pcjvgaSOs0zzZcMKzxDSkYKEpwJ2dNVDdxm68jAY=
+github.com/aws/aws-sdk-go-v2/internal/v4a v1.0.6/go.mod h1:O7Oc4peGZDEKlddivslfYFvAbgzvl/GH3J8j3JIGBXc=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.3 h1:4n4KCtv5SUoT5Er5XV41huuzrCqepxlW3SDI9qHQebc=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.3/go.mod h1:gkb2qADY+OHaGLKNTYxMaQNacfeyQpZ4csDTQMeFmcw=
+github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.1.10 h1:7LJcuRalaLw+GYQTMGmVUl4opg2HrDZkvn/L3KvIQfw=
+github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.1.10/go.mod h1:Qks+dxK3O+Z2deAhNo6cJ8ls1bam3tUGUAcgxQP1c70=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.9 h1:sHfDuhbOuuWSIAEDd3pma6p0JgUcR2iePxtCE8gfCxQ=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.9/go.mod h1:yQowTpvdZkFVuHrLBXmczat4W+WJKg/PafBZnGBLga0=
+github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.13.9 h1:sJdKvydGYDML9LTFcp6qq6Z5fIjN0Rdq2Gvw1hUg8tc=
+github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.13.9/go.mod h1:Rc5+wn2k8gFSi3V1Ch4mhxOzjMh+bYSXVFfVaqowQOY=
+github.com/aws/aws-sdk-go-v2/service/s3 v1.27.2 h1:NvzGue25jKnuAsh6yQ+TZ4ResMcnp49AWgWGm2L4b5o=
+github.com/aws/aws-sdk-go-v2/service/s3 v1.27.2/go.mod h1:u+566cosFI+d+motIz3USXEh6sN8Nq4GrNXSg2RXVMo=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.13 h1:DQpf+al+aWozOEmVEdml67qkVZ6vdtGUi71BZZWw40k=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.13/go.mod h1:d7ptRksDDgvXaUvxyHZ9SYh+iMDymm94JbVcgvSYSzU=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.10 h1:7tquJrhjYz2EsCBvA9VTl+sBAAh1bv7h/sGASdZOGGo=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.10/go.mod h1:cftkHYN6tCDNfkSasAmclSfl4l7cySoay8vz7p/ce0E=
+github.com/aws/smithy-go v1.12.0 h1:gXpeZel/jPoWQ7OEmLIgCUnhkFftqNfwWUwAHSlp1v0=
+github.com/aws/smithy-go v1.12.0/go.mod h1:Tg+OJXh4MB2R/uN61Ko2f6hTZwB/ZYGOtib8J3gBHzA=
+github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
+github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
+github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg=
+github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg=
+github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
+github.com/jmespath/go-jmespath/internal/testify v1.5.1 h1:shLQSRRSCCPj3f2gpwzGwWFoC7ycTf1rcQZHOlsJ6N8=
+github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10=
+gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=

s3/s3.go

@@ -0,0 +1,202 @@
+package s3
+
+import (
+	"bytes"
+	"context"
+	"errors"
+	"fmt"
+	"time"
+
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/aws/retry"
+	awsconfig "github.com/aws/aws-sdk-go-v2/config"
+	"github.com/aws/aws-sdk-go-v2/credentials"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/service/s3"
+	"github.com/aws/aws-sdk-go-v2/service/s3/types"
+)
+
+// Storage interface that is implemented by storage providers
+type Storage struct {
+	svc            *s3.Client
+	downloader     *manager.Downloader
+	uploader       *manager.Uploader
+	requestTimeout time.Duration
+	bucket         string
+}
+
+// New creates a new storage
+func New(config ...Config) *Storage {
+	// Set default config
+	cfg := configDefault(config...)
+
+	// Create s3 session
+	// 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: https://aws.github.io/aws-sdk-go-v2/docs/configuring-sdk/#specifying-credentials
+	awscfg, err := returnAWSConfig(cfg)
+	if err != nil {
+		panic(fmt.Sprintf("unable to load SDK config, %v", err))
+	}
+
+	sess := s3.NewFromConfig(awscfg)
+	storage := &Storage{
+		svc:            sess,
+		downloader:     manager.NewDownloader(sess),
+		uploader:       manager.NewUploader(sess),
+		requestTimeout: cfg.RequestTimeout,
+		bucket:         cfg.Bucket,
+	}
+
+	// Reset all entries if set to true
+	if cfg.Reset {
+		if err := storage.Reset(); err != nil {
+			panic(err)
+		}
+	}
+
+	return storage
+}
+
+// Get value by key
+func (s *Storage) Get(key string) ([]byte, error) {
+	var nsk *types.NoSuchKey
+
+	if len(key) <= 0 {
+		return nil, nil
+	}
+
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
+	buf := manager.NewWriteAtBuffer([]byte{})
+
+	_, err := s.downloader.Download(ctx, buf, &s3.GetObjectInput{
+		Bucket: &s.bucket,
+		Key:    aws.String(key),
+	})
+	if errors.As(err, &nsk) {
+		return nil, nil
+	}
+
+	return buf.Bytes(), err
+}
+
+// Set key with value
+func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
+	if len(key) <= 0 {
+		return nil
+	}
+
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
+	_, err := s.uploader.Upload(ctx, &s3.PutObjectInput{
+		Bucket: &s.bucket,
+		Key:    aws.String(key),
+		Body:   bytes.NewReader(val),
+	})
+
+	return err
+}
+
+// Delete entry by key
+func (s *Storage) Delete(key string) error {
+	if len(key) <= 0 {
+		return nil
+	}
+
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
+	_, err := s.svc.DeleteObject(ctx, &s3.DeleteObjectInput{
+		Bucket: &s.bucket,
+		Key:    aws.String(key),
+	})
+
+	return err
+}
+
+// Reset all entries, including unexpired
+func (s *Storage) Reset() error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
+	paginator := s3.NewListObjectsV2Paginator(s.svc, &s3.ListObjectsV2Input{
+		Bucket: &s.bucket,
+	})
+
+	for paginator.HasMorePages() {
+		page, err := paginator.NextPage(ctx)
+		if err != nil {
+			return err
+		}
+
+		var objects []types.ObjectIdentifier
+		for _, object := range page.Contents {
+			objects = append(objects, types.ObjectIdentifier{
+				Key: object.Key,
+			})
+		}
+
+		_, err = s.svc.DeleteObjects(ctx, &s3.DeleteObjectsInput{
+			Bucket: &s.bucket,
+			Delete: &types.Delete{
+				Objects: objects,
+			},
+		})
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+// Close the database
+func (s *Storage) Close() error {
+	return nil
+}
+
+// Context for making requests will timeout if a non-zero timeout is configured
+func (s *Storage) requestContext() (context.Context, context.CancelFunc) {
+	if s.requestTimeout > 0 {
+		return context.WithTimeout(context.Background(), s.requestTimeout)
+	}
+	return context.Background(), func() {}
+}
+
+func returnAWSConfig(cfg Config) (aws.Config, error) {
+	endpoint := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
+		if cfg.Endpoint != "" {
+			return aws.Endpoint{
+				PartitionID:       "aws",
+				URL:               cfg.Endpoint,
+				SigningRegion:     cfg.Region,
+				HostnameImmutable: true,
+			}, nil
+		}
+		return aws.Endpoint{}, &aws.EndpointNotFoundError{}
+	})
+
+	if cfg.Credentials != (Credentials{}) {
+		credentials := credentials.NewStaticCredentialsProvider(cfg.Credentials.AccessKey, cfg.Credentials.SecretAccessKey, "")
+		return awsconfig.LoadDefaultConfig(context.TODO(),
+			awsconfig.WithRegion(cfg.Region),
+			awsconfig.WithEndpointResolverWithOptions(endpoint),
+			awsconfig.WithCredentialsProvider(credentials),
+			awsconfig.WithRetryer(func() aws.Retryer {
+				return retry.AddWithMaxAttempts(retry.NewStandard(), cfg.MaxAttempts)
+			}),
+		)
+	}
+
+	return awsconfig.LoadDefaultConfig(context.TODO(),
+		awsconfig.WithRegion(cfg.Region),
+		awsconfig.WithEndpointResolverWithOptions(endpoint),
+		awsconfig.WithRetryer(func() aws.Retryer {
+			return retry.AddWithMaxAttempts(retry.NewStandard(), cfg.MaxAttempts)
+		}),
+	)
+}

s3/s3_test.go

@@ -0,0 +1,107 @@
+package s3
+
+import (
+	"testing"
+
+	"github.com/gofiber/utils"
+)
+
+var testStore = New(
+	Config{
+		Bucket:   "testbucket",
+		Endpoint: "http://127.0.0.1:9000/",
+		Region:   "us-east-1",
+		Credentials: Credentials{
+			AccessKey:       "minioadmin",
+			SecretAccessKey: "minioadmin",
+		},
+	},
+)
+
+func Test_S3_Set(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_S3_Set_Override(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_S3_Get(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, val, result)
+}
+
+func Test_S3_Get_NotExist(t *testing.T) {
+
+	result, err := testStore.Get("notexist")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_S3_Delete(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Delete(key)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_S3_Reset(t *testing.T) {
+	var (
+		val = []byte("doe")
+	)
+
+	err := testStore.Set("john1", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set("john2", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Reset()
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get("john1")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+
+	result, err = testStore.Get("john2")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_S3_Close(t *testing.T) {
+	utils.AssertEqual(t, nil, testStore.Close())
+}

sqlite3/go.mod

@@ -4,5 +4,5 @@ go 1.14
 
 require (
 	github.com/gofiber/utils v0.1.2
-	github.com/mattn/go-sqlite3 v1.14.10
+	github.com/mattn/go-sqlite3 v1.14.14
 )

sqlite3/go.sum

@@ -1,4 +1,4 @@
 github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
 github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
-github.com/mattn/go-sqlite3 v1.14.10 h1:MLn+5bFRlWMGoSRmJour3CL1w/qL96mvipqpwQW/Sfk=
-github.com/mattn/go-sqlite3 v1.14.10/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
+github.com/mattn/go-sqlite3 v1.14.14 h1:qZgc/Rwetq+MtyE18WhzjokPD93dNqLGNT3QJuLvBGw=
+github.com/mattn/go-sqlite3 v1.14.14/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=