redis

Documentation

Index

• Constants
• Variables
• func ListenChannels()
• func PublishMsg(msg message.ServerMsg, channel channel) error
• func ReadMessages(ch channel)
• func SetUp()
• func Subscribe(userId string, connectionId string, ch chan message.Msg)
• func UnSubscribe(userId string, connectionId string)

Constants

const SEND_ACK_CHANNEL channel = "ACK_MESSAGE"

const SEND_SYSTEM_CHANNEL channel = "SYSTEM_MESSAGE"

const USER_MSG channel = "USER_MESSAGE"

Channel names

Variables

var Redis *redis.Client

Redis client

Functions

func ListenChannels

func ListenChannels()

Listening to redis channels

func PublishMsg

func PublishMsg(msg message.ServerMsg, channel channel) error

Publishing user message to channel

func ReadMessages

func ReadMessages(ch channel)

Read messages from channel and send to clients

func SetUp

func SetUp()

Connecting and start redis pub-sub

func Subscribe

func Subscribe(userId string, connectionId string, ch chan message.Msg)

Subscribing connection for messages

func UnSubscribe

func UnSubscribe(userId string, connectionId string)

Removing connection from connections map