websocket

Documentation

Index

• func NewMarketChannelCreator(fetcher SnapshotFetcher) func(channelID string) IChannel
• func RegisterChannelCreator(prefix string, fn func(channelID string) IChannel)
• type Channel
  • func (c *Channel) AddMessage(msg *common.WebSocketMessage)
  • func (c *Channel) AddSubscriber(client *Client)
  • func (c *Channel) GetID() string
  • func (c *Channel) MessagesChan() chan *common.WebSocketMessage
  • func (c *Channel) RemoveSubscriber(ID string)
  • func (c *Channel) SubScribeChan() chan *Client
  • func (c *Channel) UnsubscribeChan() chan string
• type Client
  • func NewClient() *Client
  • func (c *Client) Send(data interface{}) error
• type ClientRequest
• type DefaultHttpSnapshotFetcher
  • func (f *DefaultHttpSnapshotFetcher) GetV2(marketID string) *common.SnapshotV2
• type IChannel
• type OnMessageResult
• type Orderbook
• type SnapshotFetcher
• type WSServer
  • func NewWSServer(addr string, sourceQueue common.IQueue) *WSServer
  • func (s *WSServer) Start(ctx context.Context)

Functions

func NewMarketChannelCreator

func NewMarketChannelCreator(fetcher SnapshotFetcher) func(channelID string) IChannel

func RegisterChannelCreator

func RegisterChannelCreator(prefix string, fn func(channelID string) IChannel)

Types

type Channel

type Channel struct {
	ID      string
	Clients map[string]*Client

	Subscribe   chan *Client
	Unsubscribe chan string
	Messages    chan *common.WebSocketMessage
}

Channel is a basic type implemented IChannel

func (*Channel) AddMessage

func (c *Channel) AddMessage(msg *common.WebSocketMessage)

func (*Channel) AddSubscriber

func (c *Channel) AddSubscriber(client *Client)

func (*Channel) GetID

func (c *Channel) GetID() string

func (*Channel) MessagesChan

func (c *Channel) MessagesChan() chan *common.WebSocketMessage

func (*Channel) RemoveSubscriber

func (c *Channel) RemoveSubscriber(ID string)

func (*Channel) SubScribeChan

func (c *Channel) SubScribeChan() chan *Client

func (*Channel) UnsubscribeChan

func (c *Channel) UnsubscribeChan() chan string

type Client

type Client struct {
	ID       string
	Conn     clientConn
	Channels map[string]*Channel
	// contains filtered or unexported fields
}

func NewClient

func NewClient() *Client

func (*Client) Send

func (c *Client) Send(data interface{}) error

type ClientRequest

type ClientRequest struct {
	Type     string
	Channels []string
}

type DefaultHttpSnapshotFetcher

type DefaultHttpSnapshotFetcher struct {
	ApiUrl string
}

func (*DefaultHttpSnapshotFetcher) GetV2

func (f *DefaultHttpSnapshotFetcher) GetV2(marketID string) *common.SnapshotV2

type IChannel

type IChannel interface {
	GetID() string

	// Thread safe calls
	AddSubscriber(*Client)
	RemoveSubscriber(string)
	AddMessage(message *common.WebSocketMessage)

	UnsubscribeChan() chan string
	SubScribeChan() chan *Client
	MessagesChan() chan *common.WebSocketMessage
	// contains filtered or unexported methods
}

type OnMessageResult

type OnMessageResult struct {
	Price  decimal.Decimal
	Side   string
	Amount decimal.Decimal
}

type Orderbook

type Orderbook struct {
	Sequence uint64
	*common.Orderbook
	// contains filtered or unexported fields
}

type SnapshotFetcher

type SnapshotFetcher interface {
	GetV2(marketID string) *common.SnapshotV2
}

type WSServer

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

func NewWSServer

func NewWSServer(addr string, sourceQueue common.IQueue) *WSServer

func (*WSServer) Start

func (s *WSServer) Start(ctx context.Context)