websocket

Documentation

Index

• type Handler
• type WsServer
  • func InitWsServer() *WsServer
  • func (this *WsServer) BroadcastResult(resp map[string]interface{})
  • func (this *WsServer) IsValidMsg(reqMsg map[string]interface{}) bool
  • func (this *WsServer) OnDataHandle(curSession *session.Session, bysMsg []byte, r *http.Request) bool
  • func (this *WsServer) PushTxResult(txHashStr string, resp map[string]interface{})
  • func (this *WsServer) Restart()
  • func (this *WsServer) SetTxHashMap(txhash string, sessionid string)
  • func (this *WsServer) Start() error
  • func (this *WsServer) Stop()

Types

type Handler

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

type WsServer

type WsServer struct {
	sync.RWMutex
	Upgrader websocket.Upgrader

	SessionList  *session.SessionList
	ActionMap    map[string]Handler
	TxHashMap    map[string]string //key: txHash   value:sessionid
	BroadcastMap map[string]string
	// contains filtered or unexported fields
}

func InitWsServer

func InitWsServer() *WsServer

func (*WsServer) BroadcastResult

func (this *WsServer) BroadcastResult(resp map[string]interface{})

func (*WsServer) IsValidMsg

func (this *WsServer) IsValidMsg(reqMsg map[string]interface{}) bool

func (*WsServer) OnDataHandle

func (this *WsServer) OnDataHandle(curSession *session.Session, bysMsg []byte, r *http.Request) bool

func (*WsServer) PushTxResult

func (this *WsServer) PushTxResult(txHashStr string, resp map[string]interface{})

func (*WsServer) Restart

func (this *WsServer) Restart()

func (*WsServer) SetTxHashMap

func (this *WsServer) SetTxHashMap(txhash string, sessionid string)

func (*WsServer) Start

func (this *WsServer) Start() error

func (*WsServer) Stop

func (this *WsServer) Stop()