session

Documentation

Overview

Package session privides websocket server manager sessionlist

Index

• Constants
• type Session
  • func (self *Session) AppendTxHash(txhash string)
  • func (self *Session) Close()
  • func (self *Session) GetSessionId() string
  • func (self *Session) RemoveTimeoverTxHashes() (remove []TxHashInfo)
  • func (self *Session) Send(data []byte) error
  • func (self *Session) SessionTimeoverCheck() bool
  • func (self *Session) UpdateActiveTime()
• type SessionList
  • func NewSessionList() *SessionList
  • func (self *SessionList) CloseSession(session *Session)
  • func (self *SessionList) ForEachSession(visit func(*Session))
  • func (self *SessionList) GetSessionById(sessionId string) *Session
  • func (self *SessionList) GetSessionCount() int
  • func (self *SessionList) NewSession(wsConn *websocket.Conn) (session *Session, err error)
• type TxHashInfo

Constants

const MAX_SESSION_COUNT = 3000

const SESSION_TIMEOUT int64 = 300

Types

type Session

type Session struct {
	sync.Mutex

	TxHashArr []TxHashInfo //transaction hashes in this session
	// contains filtered or unexported fields
}

websocket session

func (*Session) AppendTxHash

func (self *Session) AppendTxHash(txhash string)

append transaction hash

func (*Session) Close

func (self *Session) Close()

close session

func (*Session) GetSessionId

func (self *Session) GetSessionId() string

func (*Session) RemoveTimeoverTxHashes

func (self *Session) RemoveTimeoverTxHashes() (remove []TxHashInfo)

remove timew over transaction hashes

func (*Session) Send

func (self *Session) Send(data []byte) error

send to client

func (*Session) SessionTimeoverCheck

func (self *Session) SessionTimeoverCheck() bool

sesseion time over check

func (*Session) UpdateActiveTime

func (self *Session) UpdateActiveTime()

update active time

type SessionList

type SessionList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSessionList

func NewSessionList() *SessionList

new websocket session list

func (*SessionList) CloseSession

func (self *SessionList) CloseSession(session *Session)

func (*SessionList) ForEachSession

func (self *SessionList) ForEachSession(visit func(*Session))

func (*SessionList) GetSessionById

func (self *SessionList) GetSessionById(sessionId string) *Session

func (*SessionList) GetSessionCount

func (self *SessionList) GetSessionCount() int

func (*SessionList) NewSession

func (self *SessionList) NewSession(wsConn *websocket.Conn) (session *Session, err error)

type TxHashInfo

type TxHashInfo struct {
	TxHash    string //transaction hash
	StartTime int64  //recv tranasction time
}