ws

Documentation

Index

• Variables
• func OrderSocketCloseHandler(orderId bson.ObjectId) func(code int, text string) error
• func PairSocketCloseHandler(pair string, conn *websocket.Conn) func(code int, text string) error
• func PairSocketRegister(pair string, conn *websocket.Conn) error
• func PairSocketWriteMessage(pair string, message []byte) error
• type PairWs
• type Ws

Variables

var Connections map[string]*Ws

var PairSockets map[string]PairWs

Functions

func OrderSocketCloseHandler

func OrderSocketCloseHandler(orderId bson.ObjectId) func(code int, text string) error

func PairSocketCloseHandler

func PairSocketCloseHandler(pair string, conn *websocket.Conn) func(code int, text string) error

func PairSocketRegister

func PairSocketRegister(pair string, conn *websocket.Conn) error

func PairSocketWriteMessage

func PairSocketWriteMessage(pair string, message []byte) error

Types

type PairWs

type PairWs map[*websocket.Conn]bool

type Ws

type Ws struct {
	Conn        *websocket.Conn
	ReadChannel chan *types.WsMsg
}