server

Documentation

Index

• Constants
• type Handler
• type WsServer
  • func InitWsServer(node protocol.Noder, wallet vault.Wallet) *WsServer
  • func (ws *WsServer) Broadcast(data []byte) error
  • func (ws *WsServer) GetClientsById(cliendID []byte) []*Session
  • func (ws *WsServer) GetNetNode() (protocol.Noder, error)
  • func (ws *WsServer) GetWallet() (vault.Wallet, error)
  • func (ws *WsServer) IsValidMsg(reqMsg map[string]interface{}) bool
  • func (ws *WsServer) NotifyWrongClients()
  • func (ws *WsServer) OnDataHandle(curSession *Session, messageType int, bysMsg []byte, r *http.Request) bool
  • func (ws *WsServer) PushResult(resp map[string]interface{})
  • func (ws *WsServer) PushTxResult(txHashStr string, resp map[string]interface{})
  • func (ws *WsServer) Restart()
  • func (ws *WsServer) SendRelayPacket(clientId string, msg *client.OutboundMessage)
  • func (ws *WsServer) SetTxHashMap(txhash string, sessionid string)
  • func (ws *WsServer) Start() error
  • func (ws *WsServer) Stop()

Constants

const (
	TlsPort uint16 = 443
)

Types

type Handler

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

type WsServer

type WsServer struct {
	sync.RWMutex
	Upgrader websocket.Upgrader

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

func InitWsServer

func InitWsServer(node protocol.Noder, wallet vault.Wallet) *WsServer

func (*WsServer) Broadcast

func (ws *WsServer) Broadcast(data []byte) error

func (*WsServer) GetClientsById

func (ws *WsServer) GetClientsById(cliendID []byte) []*Session

func (*WsServer) GetNetNode

func (ws *WsServer) GetNetNode() (protocol.Noder, error)

func (*WsServer) GetWallet

func (ws *WsServer) GetWallet() (vault.Wallet, error)

func (*WsServer) IsValidMsg

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

func (*WsServer) NotifyWrongClients

func (ws *WsServer) NotifyWrongClients()

func (*WsServer) OnDataHandle

func (ws *WsServer) OnDataHandle(curSession *Session, messageType int, bysMsg []byte, r *http.Request) bool

func (*WsServer) PushResult

func (ws *WsServer) PushResult(resp map[string]interface{})

func (*WsServer) PushTxResult

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

func (*WsServer) Restart

func (ws *WsServer) Restart()

func (*WsServer) SendRelayPacket

func (ws *WsServer) SendRelayPacket(clientId string, msg *client.OutboundMessage)

func (*WsServer) SetTxHashMap

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

func (*WsServer) Start

func (ws *WsServer) Start() error

func (*WsServer) Stop

func (ws *WsServer) Stop()