connection

Nov 13, 2023

Changes in this version

type IConnection

+ SQueue func() <-chan bool

type Tcp

+ func (t *Tcp) SQueue() <-chan bool

type WebSocket

+ func (t *WebSocket) SQueue() <-chan bool

Nov 8, 2023

Changes in this version

+ func Get(conn IConnection, key int64) T

type IConnection

+ Get func(key int64) (any, bool)

+ Set func(key int64, value any)

type Tcp

+ func (t *Tcp) Get(userId int64) (any, bool)

+ func (t *Tcp) Set(userId int64, val any)

type WebSocket

+ func (t *WebSocket) Get(key int64) (any, bool)

+ func (t *WebSocket) Set(key int64, val any)

Jun 9, 2023

Changes in this version

type IConnection

+ Expired func() bool

type Tcp

+ func (t *Tcp) Expired() bool

type WebSocket

+ func (t *WebSocket) Expired() bool

Sep 22, 2022

Changes in this version

type IConnection

+ RemoteIp func() string

type Tcp

+ func (t *Tcp) RemoteIp() string

type WebSocket

+ func (t *WebSocket) RemoteIp() string

Sep 1, 2022

Changes in this version

+ const Packet_Max_Len

Jul 20, 2022

Changes in this version

type IConnection

+ SendBytes func([]byte) error

type Tcp

+ func (t *Tcp) SendBytes(buf []byte) error

type WebSocket

+ func (t *WebSocket) SendBytes(buf []byte) error

Jul 20, 2022

Changes in this version

+ func Init(endian string)

type PacketConfig

+ Endian string

Jul 19, 2022

Changes in this version

type IConnection

+ Send func(IPacket) error

type Tcp

+ func (t *Tcp) Send(pack IPacket) error

type WebSocket

+ func (t *WebSocket) Send(pack IPacket) error

Jul 18, 2022

Changes in this version

+ const CHANNEL_PACKET_MAX

+ func BytesToInt32(buf []byte) int32

+ func BytesToInt64(buf []byte) int64

+ func Int32ToBytes(num int32) []byte

+ func Int64ToBytes(num int64) []byte

+ type Default struct

+ func NewDefault() *Default

+ func (d *Default) BodyOffset() int

+ func (d *Default) LenOffset() int

+ func (d *Default) Serialize() []byte

+ func (d *Default) Unserialize(buf []byte) error

+ type IConnection interface

+ Close func() error

+ Closed func() bool

+ FD func() int

+ RQueue func() chan IPacket

+ Read func(int, int, int) ([]byte, error)

+ WQueue func() chan IPacket

+ Write func(IPacket) (int, error)

+ type IPacket interface

+ Serialize func() []byte

+ Unserialize func([]byte) error

+ type PacketConfig struct

+ BodyLenLen int

+ BodyLenOffset int

+ HeaderLength int

+ type Tcp struct

+ func NewTcp(fd int, conn net.Conn) *Tcp

+ func (t *Tcp) Close() error

+ func (t *Tcp) Closed() bool

+ func (t *Tcp) FD() int

+ func (t *Tcp) RQueue() chan IPacket

+ func (t *Tcp) Read(hLen, bLen, bLenOffset int) ([]byte, error)

+ func (t *Tcp) WQueue() chan IPacket

+ func (t *Tcp) Write(pack IPacket) (int, error)

+ type WebSocket struct

+ func NewWebSocket(fd int, conn net.Conn) *WebSocket

+ func (t *WebSocket) Close() error

+ func (t *WebSocket) Closed() bool

+ func (t *WebSocket) FD() int

+ func (t *WebSocket) RQueue() chan IPacket

+ func (t *WebSocket) Read(hLen, bLen, bLenOffset int) ([]byte, error)

+ func (t *WebSocket) WQueue() chan IPacket

+ func (t *WebSocket) Write(pack IPacket) (int, error)