fix: fail to open pub/sub in cluster mode #239
This commit is contained in:
parent
d41421389c
commit
8139481ea7
|
@ -2,7 +2,6 @@ package services
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/redis/go-redis/v9"
|
"github.com/redis/go-redis/v9"
|
||||||
"github.com/wailsapp/wails/v2/pkg/runtime"
|
"github.com/wailsapp/wails/v2/pkg/runtime"
|
||||||
|
@ -13,7 +12,7 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
type pubsubItem struct {
|
type pubsubItem struct {
|
||||||
client *redis.Client
|
client redis.UniversalClient
|
||||||
pubsub *redis.PubSub
|
pubsub *redis.PubSub
|
||||||
mutex sync.Mutex
|
mutex sync.Mutex
|
||||||
closeCh chan struct{}
|
closeCh chan struct{}
|
||||||
|
@ -62,12 +61,8 @@ func (p *pubsubService) getItem(server string) (*pubsubItem, error) {
|
||||||
if uniClient, err = Connection().createRedisClient(conf.ConnectionConfig); err != nil {
|
if uniClient, err = Connection().createRedisClient(conf.ConnectionConfig); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
var client *redis.Client
|
|
||||||
if client, ok = uniClient.(*redis.Client); !ok {
|
|
||||||
return nil, errors.New("create redis client fail")
|
|
||||||
}
|
|
||||||
item = &pubsubItem{
|
item = &pubsubItem{
|
||||||
client: client,
|
client: uniClient,
|
||||||
}
|
}
|
||||||
p.items[server] = item
|
p.items[server] = item
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue