server

package
v0.0.0-...-4178c87 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 10, 2018 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const PROTO_VERSION = 3

Variables

This section is empty.

Functions

func KuCoinRunner

func KuCoinRunner(ws *TickerWebSocketHandler)

func ServerMain

func ServerMain(options Options)

Types

type BinanceRunner

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

func NewBinanceRunner

func NewBinanceRunner() *BinanceRunner

func (*BinanceRunner) Run

func (b *BinanceRunner) Run()

func (*BinanceRunner) Subscribe

func (b *BinanceRunner) Subscribe(symbol string) chan interface{}

func (*BinanceRunner) Unsubscribe

func (b *BinanceRunner) Unsubscribe(symbol string, channel chan interface{})

type Options

type Options struct {
	Port uint16
}

type TickerStream

type TickerStream struct {
	Tickers []interface{} `json:"tickers"`
}

type TickerWebSocketHandler

type TickerWebSocketHandler struct {
	Feed *BinanceRunner
	// contains filtered or unexported fields
}

func NewBroadcastWebSocketHandler

func NewBroadcastWebSocketHandler() *TickerWebSocketHandler

func (*TickerWebSocketHandler) AddClient

func (h *TickerWebSocketHandler) AddClient(client *WebSocketClient)

func (*TickerWebSocketHandler) Broadcast

func (h *TickerWebSocketHandler) Broadcast(v TickerStream) error

func (*TickerWebSocketHandler) CloseClient

func (h *TickerWebSocketHandler) CloseClient(client *WebSocketClient)

func (*TickerWebSocketHandler) Handle

func (*TickerWebSocketHandler) Upgrade

type WebSocketClient

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

func NewWebSocketClient

func NewWebSocketClient(c *websocket.Conn, r *http.Request) *WebSocketClient

func (*WebSocketClient) GetRemoteAddr

func (c *WebSocketClient) GetRemoteAddr() string

func (*WebSocketClient) GetRemoteHost

func (c *WebSocketClient) GetRemoteHost() string

func (*WebSocketClient) WriteTextMessage

func (c *WebSocketClient) WriteTextMessage(msg []byte) error

type WsConnectionTracker

type WsConnectionTracker struct {
	Paths   map[string]map[*WebSocketClient]bool
	Clients map[*WebSocketClient]map[string]bool
	Lock    sync.RWMutex
}

func NewWsConnectionTracker

func NewWsConnectionTracker() *WsConnectionTracker

func (*WsConnectionTracker) Add

func (w *WsConnectionTracker) Add(path string, conn *WebSocketClient)

func (*WsConnectionTracker) Del

func (w *WsConnectionTracker) Del(path string, conn *WebSocketClient)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL