type github.com/go-redis/redis/v8.PubSub

50 uses

	github.com/go-redis/redis/v8 (current package)
		cluster.go#L1492: func (c *ClusterClient) pubSub() *PubSub {
		cluster.go#L1494: 	pubsub := &PubSub{
		cluster.go#L1535: func (c *ClusterClient) Subscribe(ctx context.Context, channels ...string) *PubSub {
		cluster.go#L1545: func (c *ClusterClient) PSubscribe(ctx context.Context, channels ...string) *PubSub {
		pubsub.go#L29: type PubSub struct {
		pubsub.go#L51: func (c *PubSub) String() string {
		pubsub.go#L57: func (c *PubSub) init() {
		pubsub.go#L61: func (c *PubSub) connWithLock(ctx context.Context) (*pool.Conn, error) {
		pubsub.go#L68: func (c *PubSub) conn(ctx context.Context, newChannels []string) (*pool.Conn, error) {
		pubsub.go#L93: func (c *PubSub) writeCmd(ctx context.Context, cn *pool.Conn, cmd Cmder) error {
		pubsub.go#L99: func (c *PubSub) resubscribe(ctx context.Context, cn *pool.Conn) error {
		pubsub.go#L126: func (c *PubSub) _subscribe(
		pubsub.go#L138: func (c *PubSub) releaseConnWithLock(
		pubsub.go#L149: func (c *PubSub) releaseConn(ctx context.Context, cn *pool.Conn, err error, allowTimeout bool) {
		pubsub.go#L158: func (c *PubSub) reconnect(ctx context.Context, reason error) {
		pubsub.go#L163: func (c *PubSub) closeTheCn(reason error) error {
		pubsub.go#L175: func (c *PubSub) Close() error {
		pubsub.go#L190: func (c *PubSub) Subscribe(ctx context.Context, channels ...string) error {
		pubsub.go#L206: func (c *PubSub) PSubscribe(ctx context.Context, patterns ...string) error {
		pubsub.go#L222: func (c *PubSub) Unsubscribe(ctx context.Context, channels ...string) error {
		pubsub.go#L235: func (c *PubSub) PUnsubscribe(ctx context.Context, patterns ...string) error {
		pubsub.go#L246: func (c *PubSub) subscribe(ctx context.Context, redisCmd string, channels ...string) error {
		pubsub.go#L257: func (c *PubSub) Ping(ctx context.Context, payload ...string) error {
		pubsub.go#L312: func (c *PubSub) newMessage(reply interface{}) (interface{}, error) {
		pubsub.go#L368: func (c *PubSub) ReceiveTimeout(ctx context.Context, timeout time.Duration) (interface{}, error) {
		pubsub.go#L393: func (c *PubSub) Receive(ctx context.Context) (interface{}, error) {
		pubsub.go#L400: func (c *PubSub) ReceiveMessage(ctx context.Context) (*Message, error) {
		pubsub.go#L428: func (c *PubSub) Channel() <-chan *Message {
		pubsub.go#L434: func (c *PubSub) ChannelSize(size int) <-chan *Message {
		pubsub.go#L455: func (c *PubSub) ChannelWithSubscriptions(ctx context.Context, size int) <-chan interface{} {
		pubsub.go#L471: func (c *PubSub) getContext() context.Context {
		pubsub.go#L478: func (c *PubSub) initPing() {
		pubsub.go#L515: func (c *PubSub) initMsgChan(size int) {
		pubsub.go#L573: func (c *PubSub) initAllChan(size int) {
		pubsub.go#L617: func (c *PubSub) sendMessage(msg interface{}, timer *time.Timer) {
		pubsub.go#L631: func (c *PubSub) retryBackoff(attempt int) time.Duration {
		redis.go#L629: func (c *Client) pubSub() *PubSub {
		redis.go#L630: 	pubsub := &PubSub{
		redis.go#L668: func (c *Client) Subscribe(ctx context.Context, channels ...string) *PubSub {
		redis.go#L678: func (c *Client) PSubscribe(ctx context.Context, channels ...string) *PubSub {
		ring.go#L487: func (c *Ring) Subscribe(ctx context.Context, channels ...string) *PubSub {
		ring.go#L501: func (c *Ring) PSubscribe(ctx context.Context, channels ...string) *PubSub {
		sentinel.go#L259: func (c *SentinelClient) pubSub() *PubSub {
		sentinel.go#L260: 	pubsub := &PubSub{
		sentinel.go#L282: func (c *SentinelClient) Subscribe(ctx context.Context, channels ...string) *PubSub {
		sentinel.go#L292: func (c *SentinelClient) PSubscribe(ctx context.Context, channels ...string) *PubSub {
		sentinel.go#L406: 	pubsub      *PubSub
		sentinel.go#L646: func (c *sentinelFailover) listen(pubsub *PubSub) {
		universal.go#L181: 	Subscribe(ctx context.Context, channels ...string) *PubSub
		universal.go#L182: 	PSubscribe(ctx context.Context, channels ...string) *PubSub