Versions in this module Expand all Collapse all v1 v1.0.2 Aug 16, 2022 v1.0.1 Aug 8, 2022 Changes in this version + const TlsPort + type DelayedChan struct + func NewDelayedChan(size int, delay time.Duration) *DelayedChan + func (dc *DelayedChan) Pop() (interface{}, bool) + func (dc *DelayedChan) Push(v interface{}) bool + type Handler struct + type WsServer struct + ActionMap map[string]Handler + SessionList *session.SessionList + TxHashMap map[string]string + Upgrader websocket.Upgrader + func InitWsServer(localNode *node.LocalNode, wallet *vault.Wallet) *WsServer + func (ws *WsServer) Broadcast(data []byte) error + func (ws *WsServer) GetClientsById(cliendID []byte) []*session.Session + func (ws *WsServer) GetNetNode() *node.LocalNode + func (ws *WsServer) IsValidMsg(reqMsg map[string]interface{}) bool + func (ws *WsServer) NotifyWrongClients() + func (ws *WsServer) OnDataHandle(curSession *session.Session, messageType int, bysMsg []byte, r *http.Request) error + func (ws *WsServer) PushResult(resp map[string]interface{}) + func (ws *WsServer) PushTxResult(txHashStr string, resp map[string]interface{}) + func (ws *WsServer) SetTxHashMap(txhash string, sessionid string) + func (ws *WsServer) Start(wssCertReady chan struct{}) error + func (ws *WsServer) Stop()