web_socket

Documentation

Overview

Websocket server package. This package starts separate websocket server and transfers all messages from redis channel "ws" to client browser.

Running server

web_socket.StartServer()

Example code to send data to redis:

	c, _ := redis.Dial("tcp", ":6379")
 msg := web_socket.RedisMessage{"apiKey", map[string]interface{}{
	  "log_per_second": 24,
   "kbs_per_second": 128,
 }}
 msg.Send(c)

Index

• func StartServer()
• type RedisMessage
  • func (m *RedisMessage) Send(r redis.Conn) (interface{}, error)

Functions

func StartServer

func StartServer()

Types

type RedisMessage

type RedisMessage struct {
	ApiKey string
	Data   interface{}
}

Represents data to be sent to user by its apiKey

func (*RedisMessage) Send

func (m *RedisMessage) Send(r redis.Conn) (interface{}, error)