Documentation
¶
Index ¶
Constants ¶
View Source
const ( CLOB_PAIR_IDS_QUERY_PARAM = "clobPairIds" MARKET_IDS_QUERY_PARAM = "marketIds" CLOSE_DEADLINE = 5 * time.Second )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WebsocketMessageSender ¶
type WebsocketMessageSender struct {
// contains filtered or unexported fields
}
func (*WebsocketMessageSender) Send ¶
func (wms *WebsocketMessageSender) Send( response *clobtypes.StreamOrderbookUpdatesResponse, ) (err error)
type WebsocketServer ¶
type WebsocketServer struct {
// contains filtered or unexported fields
}
func NewWebsocketServer ¶
func NewWebsocketServer( streamingManager types.FullNodeStreamingManager, cdc codec.JSONCodec, logger log.Logger, port uint16, ) *WebsocketServer
func (*WebsocketServer) Handler ¶
func (ws *WebsocketServer) Handler(w http.ResponseWriter, r *http.Request)
func (*WebsocketServer) Shutdown ¶
func (ws *WebsocketServer) Shutdown()
func (*WebsocketServer) Start ¶
func (ws *WebsocketServer) Start()
Start the websocket server in a separate goroutine.
Source Files
Click to show internal directories.
Click to hide internal directories.