Skip to content
This repository was archived by the owner on Jun 25, 2025. It is now read-only.

Commit 93b9c5c

Browse files
committed
fix(redis): Pass style checks
1 parent 2da72a5 commit 93b9c5c

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

storage/redis_adapter.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ type redisAdapter struct {
7171
}
7272

7373
// NewRedisStorageAdapter returns a pointer to a new instance of a redis-based storage.Adapter.
74-
func NewRedisStorageAdapter(bufferSize int) (*redisAdapter, error) {
74+
func NewRedisStorageAdapter(bufferSize int) (Adapter, error) {
7575
if bufferSize <= 0 {
7676
return nil, fmt.Errorf("Invalid buffer size: %d", bufferSize)
7777
}

storage/redis_adapter_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ func TestRedisDestroy(t *testing.T) {
120120
// there are 50 queued up OR a 1 second timeout has been reached.
121121
time.Sleep(time.Second * 2)
122122
// A redis list should exist for the app
123-
exists, err := a.redisClient.Exists(app).Result()
123+
exists, err := a.(*redisAdapter).redisClient.Exists(app).Result()
124124
if err != nil {
125125
t.Error(err)
126126
}
@@ -132,7 +132,7 @@ func TestRedisDestroy(t *testing.T) {
132132
t.Error(err)
133133
}
134134
// Now check that the redis list no longer exists
135-
exists, err = a.redisClient.Exists(app).Result()
135+
exists, err = a.(*redisAdapter).redisClient.Exists(app).Result()
136136
if err != nil {
137137
t.Error(err)
138138
}

0 commit comments

Comments
 (0)