Go Redis Pub/Sub

redis.go

package config

import (
	"context"
	// "fmt"
	"go/chat/utils"

	"github.com/go-redis/redis/v9"
)

var Ctx = context.Background()
var Conn redis.Client

func PubSub() {
	SERVERID := utils.EnvVariable("SERVERID")
	subscriber := Conn.Subscribe(Ctx, SERVERID)
	for {
		msg, err := subscriber.ReceiveMessage(Ctx)
		if err != nil {
			panic(err)
		}

		// fmt.Printf("message from pub/sub : %v", msg.Payload)
		broadcast <- msg

		// ...
	}
}