camSocket

Apr 24, 2020

Changes in this version

+ type SocketContext struct

+ func (ctx *SocketContext) GetConn() net.Conn

+ func (ctx *SocketContext) GetRecv() []byte

+ func (ctx *SocketContext) SetConn(conn net.Conn)

+ func (ctx *SocketContext) SetRecv(recv []byte)

+ type SocketContextInterface interface

+ GetConn func() net.Conn

+ GetRecv func() []byte

+ SetConn func(conn net.Conn)

+ SetRecv func(recv []byte)

type SocketSession

+ func (sess *SocketSession) GetConn() net.Conn

+ func (sess *SocketSession) SetConn(conn net.Conn)

Apr 17, 2020

Changes in this version

+ type SocketComponent struct

+ func (comp *SocketComponent) GetConfig() *SocketComponentConfig

+ func (comp *SocketComponent) Init(configI camBase.ComponentConfigInterface)

+ func (comp *SocketComponent) Start()

+ func (comp *SocketComponent) Stop()

+ type SocketComponentConfig struct

+ ConnHandler camBase.SocketConnHandler

+ Etb byte

+ MessageParseHandler camBase.MessageParseHandler

+ Port uint16

+ RecvMaxLen uint64

+ RecvTimeout time.Duration

+ SendMaxLen uint64

+ SendTimeout time.Duration

+ Trace bool

+ func NewSocketComponentConfig(port uint16) *SocketComponentConfig

+ type SocketSession struct

+ func NewSocketSession(conn net.Conn) *SocketSession

+ func (sess *SocketSession) Del(key interface{})

+ func (sess *SocketSession) Destroy()

+ func (sess *SocketSession) Get(key interface{}) interface{}

+ func (sess *SocketSession) GetSessionId() string

+ func (sess *SocketSession) Set(key interface{}, value interface{})