gosockredis

Documentation

Index

• type BCData
• type RCData
• type Redis
  • func NewRedis(ch string, p *redis.Pool) *Redis
  • func (r *Redis) BroadcastFromBackend(b chan<- *gosock.BroadcastMsg)
  • func (r *Redis) BroadcastToBackend(b *gosock.BroadcastMsg)
  • func (r *Redis) Init()
  • func (r *Redis) RoomcastFromBackend(rr chan<- *gosock.RoomMsg)
  • func (r *Redis) RoomcastToBackend(rr *gosock.RoomMsg)
  • func (r *Redis) Shutdown()

Types

type BCData

type BCData struct {
	Event string      `json:"e"`
	Data  interface{} `json:"d"`
}

type RCData

type RCData struct {
	Room  string      `json:"r"`
	Event string      `json:"e"`
	Data  interface{} `json:"d"`
}

type Redis

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

func NewRedis

func NewRedis(ch string, p *redis.Pool) *Redis

func (*Redis) BroadcastFromBackend

func (r *Redis) BroadcastFromBackend(b chan<- *gosock.BroadcastMsg)

BroadcastFromBackend is called once and only once as a go routine as soon as the MultihomeBackend is registered using SocketServer.SetMultihomeBackend

b consumes a BroadcastMsg and dispatches it to all sockets on this server

func (*Redis) BroadcastToBackend

func (r *Redis) BroadcastToBackend(b *gosock.BroadcastMsg)

BroadcastToBackend is called everytime a BroadcastMsg is sent by a Socket

BroadcastToBackend must be safe for concurrent use by multiple go routines

func (*Redis) Init

func (r *Redis) Init()

func (*Redis) RoomcastFromBackend

func (r *Redis) RoomcastFromBackend(rr chan<- *gosock.RoomMsg)

RoomcastFromBackend is called once and only once as a go routine as soon as the MultihomeBackend is registered using SocketServer.SetMultihomeBackend

r consumes a RoomMsg and dispatches it to all sockets that are members the specified room

func (*Redis) RoomcastToBackend

func (r *Redis) RoomcastToBackend(rr *gosock.RoomMsg)

RoomcastToBackend is called everytime a RoomMsg is sent by a socket, even if none of this server's sockets are members of that room

RoomcastToBackend must be safe for concurrent use by multiple go routines

func (*Redis) Shutdown

func (r *Redis) Shutdown()