eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-08-25 20:08:13 +02:00
Code Releases Activity

api/redis/subscriber.go: remove client field from Subscriber struct

Browse source
This commit is contained in:
Henrik Hautakoski 2023-04-21 11:58:16 +02:00
parent 8881b2a529
commit 220f1976f0
2 changed files with 0 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
api/redis/subscriber.go
View file

@ -11,7 +11,6 @@ import (
) )
type Subscriber struct { type Subscriber struct {
client *redis.Client
sub *redis.PubSub sub *redis.PubSub
ctx context.Context ctx context.Context
mu sync.RWMutex mu sync.RWMutex
@ -30,7 +29,6 @@ func WithTimeout(value time.Duration) SubscriberOption {
func NewSubscriber(client *redis.Client, ns Namespace, options ...SubscriberOption) *Subscriber { func NewSubscriber(client *redis.Client, ns Namespace, options ...SubscriberOption) *Subscriber {
sub := &Subscriber{ sub := &Subscriber{
client: client,
ctx: client.Context(), ctx: client.Context(),
sub: client.PSubscribe(client.Context()), sub: client.PSubscribe(client.Context()),
channels: make(map[string]chan []byte), channels: make(map[string]chan []byte),

1
api/redis/subscriber_test.go
View file

@ -18,7 +18,6 @@ func TestSubscriber_Construct(t *testing.T) {
s := NewSubscriber(client, ns) s := NewSubscriber(client, ns)
assert.Equal(t, s.client, client)
assert.Equal(t, s.ctx, client.Context()) assert.Equal(t, s.ctx, client.Context())
assert.NotNil(t, s.sub) assert.NotNil(t, s.sub)
assert.Equal(t, s.ns, ns) assert.Equal(t, s.ns, ns)