eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-06-18 04:40:03 +02:00
Code Releases Activity

Upgrade from redis v8 to v9

Browse source
This commit is contained in:
Henrik Hautakoski 2023-06-05 13:25:01 +02:00
parent c2d60a1240
commit a91df0c39e
14 changed files with 102 additions and 127 deletions
Download patch file Download diff file Expand all files Collapse all files

4
api/redis/publisher.go
View file

@ -5,7 +5,7 @@ import (
"github.com/eosswedenorg/thalos/api"
"github.com/go-redis/redis/v8"
"github.com/redis/go-redis/v9"
)
type Publisher struct {
@ -32,5 +32,5 @@ func (r *Publisher) Flush() error {
}
func (r *Publisher) Close() error {
return r.pipeline.Close()
return r.Flush()
}

3
api/redis/publisher_test.go
View file

@ -1,11 +1,12 @@
package redis
import (
"context"
"testing"
"github.com/eosswedenorg/thalos/api"
"github.com/go-redis/redismock/v8"
"github.com/go-redis/redismock/v9"
"github.com/stretchr/testify/assert"
)

2
api/redis/subscriber.go
View file

@ -7,7 +7,7 @@ import (
"github.com/eosswedenorg/thalos/api"
"github.com/go-redis/redis/v8"
"github.com/redis/go-redis/v9"
)
type Subscriber struct {

4
api/redis/subscriber_test.go
View file

@ -8,8 +8,8 @@ import (
"github.com/eosswedenorg/thalos/api"
"github.com/alicebob/miniredis/v2"
"github.com/go-redis/redis/v8"
"github.com/go-redis/redismock/v8"
"github.com/go-redis/redismock/v9"
"github.com/redis/go-redis/v9"
"github.com/stretchr/testify/assert"
)