session

Documentation

Index

• Constants
• func RemoveSession(sess *Session)
• type IDStack
  • func (s *IDStack) Pop() (ret int32)
  • func (s *IDStack) Push(v int32)
  • func (s *IDStack) Reset()
• type Session
  • func CreateSession(srcID int32, host string, port string) *Session
  • func GetSession(sessionID string) *Session
  • func (s *Session) NotifyDone()
  • func (s *Session) PopSrcID() int32
  • func (s *Session) PushSrcID(srcID int32)
  • func (s *Session) Reset()
• type SessionPool
  • func GS() *SessionPool
  • func NewSessionPool() *SessionPool
  • func (p *SessionPool) Alloc(srcID int32, host string, port string) *Session
  • func (p *SessionPool) Free(sess *Session)

Constants

const MaxIDSequence = 10

MaxIDSequence max srcid sequence

Functions

func RemoveSession

func RemoveSession(sess *Session)

RemoveSession remove from pool

Types

type IDStack

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

IDStack store srcIDs,max

func (*IDStack) Pop

func (s *IDStack) Pop() (ret int32)

Pop id from stack

func (*IDStack) Push

func (s *IDStack) Push(v int32)

Push id to stack

func (*IDStack) Reset

func (s *IDStack) Reset()

Reset data

type Session

type Session struct {
	IP        net.IP
	Port      string
	SrcID     int32 //module id
	MQ        queue.Queue
	SessionID string
	Done      chan *Session

	Request  proto.Message
	Response proto.Message
	Die      chan struct{} // session die signal, will be triggered by others
	// contains filtered or unexported fields
}

Session connection identify

func CreateSession

func CreateSession(srcID int32, host string, port string) *Session

CreateSession from session pool

func GetSession

func GetSession(sessionID string) *Session

GetSession get Session By sessionID

func (*Session) NotifyDone

func (s *Session) NotifyDone()

NotifyDone tigger done notify

func (*Session) PopSrcID

func (s *Session) PopSrcID() int32

PopSrcID get last srcID

func (*Session) PushSrcID

func (s *Session) PushSrcID(srcID int32)

PushSrcID add SrcID to message src seq

func (*Session) Reset

func (s *Session) Reset()

Reset session set to default value

type SessionPool

type SessionPool struct {
	Pool *sync.Pool
	Objs sync.Map
}

SessionPool mamager session objests

func GS

func GS() *SessionPool

GS session instance

func NewSessionPool

func NewSessionPool() *SessionPool

NewSessionPool new session pool

func (*SessionPool) Alloc

func (p *SessionPool) Alloc(srcID int32, host string, port string) *Session

Alloc borrow session from pool

func (*SessionPool) Free

func (p *SessionPool) Free(sess *Session)

Free retrun session to pool