Versions in this module Expand all Collapse all v0 v0.1.0 Sep 25, 2023 Changes in this version + const ChannelCandles120m + const ChannelCandles1440m + const ChannelCandles15m + const ChannelCandles1m + const ChannelCandles240m + const ChannelCandles30m + const ChannelCandles360m + const ChannelCandles3m + const ChannelCandles5m + const ChannelCandles60m + const ChannelCandles720m + const ChannelFunds + const ChannelLevel2 + const ChannelMatch + const ChannelOrder + const ChannelTicker + const ChannelTrade + const Level2TypeSnapshot + const Level2TypeUpdate + func CandlesFormatWithGranularityProductId(granularity int64, productId string) string + func StartServer() + type CandlesMessage struct + Close string + High string + Low string + Open string + ProductId string + Time string + Type string + Volume string + type Channel string + func (t Channel) Format(productId string, userId int64) string + func (t Channel) FormatWithProductId(productId string) string + func (t Channel) FormatWithUserId(userId int64) string + type Client struct + func NewClient(conn *websocket.Conn, sub *subscription) *Client + type FundsMessage struct + Available string + Currency string + Hold string + Sequence int64 + Type string + UserId string + type Level2Change struct + Price string + ProductId string + Seq int64 + Side string + Size string + type Level2SnapshotMessage struct + Asks [][3]interface{} + Bids [][3]interface{} + ProductId string + Type Level2Type + type Level2Type string + type Level2UpdateMessage struct + Changes [][3]interface{} + ProductId string + Type Level2Type + type MatchMessage struct + MakerOrderId string + Price string + ProductId string + Sequence int64 + Side string + Size string + TakerOrderId string + Time string + TradeSeq int64 + Type string + type MatchStream struct + func (s *MatchStream) OnDoneLog(log *matching.DoneLog, offset int64) + func (s *MatchStream) OnMatchLog(log *matching.MatchLog, offset int64) + func (s *MatchStream) OnOpenLog(log *matching.OpenLog, offset int64) + func (s *MatchStream) Start() + type OrderBookFullSnapshot struct + LogOffset int64 + LogSeq int64 + Orders []matching.BookOrder + ProductId string + Seq int64 + type OrderBookLevel2Snapshot struct + Asks [][3]interface{} + Bids [][3]interface{} + ProductId string + Seq int64 + type OrderBookStream struct + func (s *OrderBookStream) OnDoneLog(log *matching.DoneLog, offset int64) + func (s *OrderBookStream) OnMatchLog(log *matching.MatchLog, offset int64) + func (s *OrderBookStream) OnOpenLog(log *matching.OpenLog, offset int64) + func (s *OrderBookStream) Start() + type OrderMessage struct + CreatedAt string + ExecutedValue string + FillFees string + FilledSize string + Funds string + Id string + OrderType string + Price string + ProductId string + Sequence int64 + Settled bool + Side string + Size string + Status string + Type string + UserId int64 + type PriceLevel struct + OrderCount int64 + Price decimal.Decimal + Size decimal.Decimal + type Request struct + Channels []string + CurrencyIds []string + ProductIds []string + Token string + Type string + type Response struct + Channels []string + ProductIds []string + Token string + Type string + type Server struct + func NewServer(addr, path string, sub *subscription) *Server + func (s *Server) Run() + type TickerMessage struct + BestAsk string + BestBid string + LastSize string + Low24h string + Open24h string + Price string + ProductId string + Sequence int64 + Side string + Time string + TradeSeq int64 + Type string + Volume24h string + Volume30d string + type TickerStream struct + func (s *TickerStream) OnDoneLog(log *matching.DoneLog, offset int64) + func (s *TickerStream) OnMatchLog(log *matching.MatchLog, offset int64) + func (s *TickerStream) OnOpenLog(log *matching.OpenLog, offset int64) + func (s *TickerStream) Start() + type TradeMessage struct + MakerOrderId string + Price string + ProductId string + Side string + Size string + TakerOrderId string + Time string + Type string