server

Documentation

Index

• Constants
• type DelayedChan
  • func NewDelayedChan(size int, delay time.Duration) *DelayedChan
  • func (dc *DelayedChan) Pop() (interface{}, bool)
  • func (dc *DelayedChan) Push(v interface{}) bool
• type Handler
• type MsgServer
  • func InitMsgServer(localNode node.ILocalNode, wallet *vault.Wallet) *MsgServer
  • func (ms *MsgServer) Broadcast(data []byte) error
  • func (ms *MsgServer) GetClientsById(cliendID []byte) []*session.Session
  • func (ms *MsgServer) GetNetNode() node.ILocalNode
  • func (ms *MsgServer) IsValidMsg(reqMsg map[string]interface{}) bool
  • func (ms *MsgServer) NotifyWrongClients()
  • func (ms *MsgServer) OnDataHandle(curSession *session.Session, messageType int, bysMsg []byte, ...) error
  • func (ms *MsgServer) PushResult(resp map[string]interface{})
  • func (ms *MsgServer) PushTxResult(txHashStr string, resp map[string]interface{})
  • func (ms *MsgServer) SetTxHashMap(txhash string, sessionid string)
  • func (ms *MsgServer) Start(wssCertReady chan struct{}) error

Constants

const (
	TlsPort = 443
)

Types

type DelayedChan

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

func NewDelayedChan

func NewDelayedChan(size int, delay time.Duration) *DelayedChan

func (*DelayedChan) Pop

func (dc *DelayedChan) Pop() (interface{}, bool)

func (*DelayedChan) Push

func (dc *DelayedChan) Push(v interface{}) bool

type Handler

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

type MsgServer

type MsgServer struct {
	sync.RWMutex
	SessionList *session.SessionList
	ActionMap   map[string]Handler
	TxHashMap   map[string]string //key: txHash   value:sessionid
	// contains filtered or unexported fields
}

func InitMsgServer

func InitMsgServer(localNode node.ILocalNode, wallet *vault.Wallet) *MsgServer

func (*MsgServer) Broadcast

func (ms *MsgServer) Broadcast(data []byte) error

func (*MsgServer) GetClientsById

func (ms *MsgServer) GetClientsById(cliendID []byte) []*session.Session

func (*MsgServer) GetNetNode

func (ms *MsgServer) GetNetNode() node.ILocalNode

func (*MsgServer) IsValidMsg

func (ms *MsgServer) IsValidMsg(reqMsg map[string]interface{}) bool

func (*MsgServer) NotifyWrongClients

func (ms *MsgServer) NotifyWrongClients()

func (*MsgServer) OnDataHandle

func (ms *MsgServer) OnDataHandle(curSession *session.Session, messageType int, bysMsg []byte, httpr *http.Request) error

func (*MsgServer) PushResult

func (ms *MsgServer) PushResult(resp map[string]interface{})

func (*MsgServer) PushTxResult

func (ms *MsgServer) PushTxResult(txHashStr string, resp map[string]interface{})

func (*MsgServer) SetTxHashMap

func (ms *MsgServer) SetTxHashMap(txhash string, sessionid string)

func (*MsgServer) Start

func (ms *MsgServer) Start(wssCertReady chan struct{}) error