pubsub

Documentation

Index

• func Publish(hub *Hub, args [][]byte) redis.Reply
• func Subscribe(hub *Hub, c redis.Connection, args [][]byte) redis.Reply
• func UnSubscribe(db *Hub, c redis.Connection, args [][]byte) redis.Reply
• func UnsubscribeAll(hub *Hub, c redis.Connection)
• type Hub
  • func MakeHub() *Hub

Functions

func Publish

func Publish(hub *Hub, args [][]byte) redis.Reply

Publish send msg to all subscribing client

func Subscribe

func Subscribe(hub *Hub, c redis.Connection, args [][]byte) redis.Reply

Subscribe puts the given connection into the given channel

func UnSubscribe

func UnSubscribe(db *Hub, c redis.Connection, args [][]byte) redis.Reply

UnSubscribe removes the given connection from the given channel

func UnsubscribeAll

func UnsubscribeAll(hub *Hub, c redis.Connection)

UnsubscribeAll removes the given connection from all subscribing channel

Types

type Hub

type Hub struct {
	// contains filtered or unexported fields
}

Hub stores all subscribe relations

func MakeHub

func MakeHub() *Hub

MakeHub creates new hub