base

package

Go to main page

Versions in this module

v1

v1.5.2

Aug 27, 2023

v1.5.1

Aug 24, 2023

v1.5.0

Aug 14, 2023

Changes in this version

+ type WorkState int32

+ const WORK_DONE

+ const WORK_FREE

+ const WORK_NEED_PROCESS

+ const WORK_OUTPUT

+ func (ws WorkState) String() string

v1.4.2

Jul 29, 2023

v1.4.1

Jul 23, 2023

v1.4.0

Jul 23, 2023

v1.3.0

Jul 19, 2023

v1.2.3

Jun 19, 2023

Changes in this version

type TransData

+ func (t *TransData) AddJson(v map[string]string)

+ func (t *TransData) PopJson() map[string]string

v1.2.2

Jun 14, 2023

Changes in this version

+ type OnEventsFunc map[define.EventType]func(any)

v1.2.1

May 13, 2023

v1.2.0

Mar 11, 2023

v1.1.0

Jan 28, 2023

v1.0.0

Jan 25, 2023

Changes in this version

+ const LIMIT_SIZE

+ const MTU

+ func BytesToInt32(b []byte, order binary.ByteOrder) int32

+ func BytesToInt64(b []byte, order binary.ByteOrder) int64

+ func BytesToNumber(b []byte, order binary.ByteOrder) T

+ func BytesToUInt16(b []byte, order binary.ByteOrder) uint16

+ func CheckConns(root *Conn)

+ func CheckWorks(works *Work)

+ func NumberToBytes(v T, order binary.ByteOrder) []byte

+ func SliceString(array []byte) string

+ type Conn struct

+ BufferLength int32

+ DisconnectTime time.Time

+ Index int32

+ Mode ConnMode

+ NetConn net.Conn

+ Next *Conn

+ ReadCh chan *Packet

+ ReadLength int32

+ ReadableLength int32

+ State define.ConnectState

+ WritableLength int32

+ func NewConn(id int32, size int32) *Conn

+ func (c *Conn) Add(conn *Conn)

+ func (c *Conn) CheckReadable(checker func(buffer *[]byte, i int32, o int32, length int32) bool) bool

+ func (c *Conn) GetId() int32

+ func (c *Conn) Handler()

+ func (c *Conn) Read(data *[]byte, length int32)

+ func (c *Conn) Reconnect()

+ func (c *Conn) Release()

+ func (c *Conn) SetDisconnectTime(second time.Duration)

+ func (c *Conn) SetReadBuffer(packet *Packet)

+ func (c *Conn) SetWriteBuffer(data *[]byte, length int32)

+ func (c *Conn) String() string

+ func (c *Conn) Write() error

+ type ConnBuffer struct

+ Index int32

+ type ConnMode byte

+ const CLOSE

+ const KEEPALIVE

+ type LoopState byte

+ const BREAK

+ const CONTINUE

+ const KEEPGOING

+ type Packet struct

+ Data []byte

+ Error error

+ Index int32

+ Length int32

+ func NewPacket() *Packet

+ func (p *Packet) Release(length int32)

+ type Tcp0 struct

+ HeaderSize int32

+ ReadLength int32

+ State int8

+ func NewTcp0() *Tcp0

+ func (t *Tcp0) ReadableChecker(buffer *[]byte, i int32, o int32, length int32) bool

+ func (t *Tcp0) ResetReadLength()

+ type TransData struct

+ func LoadTransData(data []byte) *TransData

+ func NewTransData() *TransData

+ func (t *TransData) AddBoolean(v bool)

+ func (t *TransData) AddByte(v byte)

+ func (t *TransData) AddByteArray(v []byte)

+ func (t *TransData) AddFloat32(v float32)

+ func (t *TransData) AddFloat64(v float64)

+ func (t *TransData) AddInt16(v int16)

+ func (t *TransData) AddInt32(v int32)

+ func (t *TransData) AddInt64(v int64)

+ func (t *TransData) AddInt8(v int8)

+ func (t *TransData) AddRawData(v []byte)

+ func (t *TransData) AddString(v string)

+ func (t *TransData) AddUInt16(v uint16)

+ func (t *TransData) AddUInt32(v uint32)

+ func (t *TransData) AddUInt64(v uint64)

+ func (t *TransData) Clear()

+ func (t *TransData) FormData() []byte

+ func (t *TransData) GetCapacity() int32

+ func (t *TransData) GetData() []byte

+ func (t *TransData) GetLength() int32

+ func (t *TransData) InsertInt32(v int32)

+ func (t *TransData) PopBoolean() bool

+ func (t *TransData) PopByte() byte

+ func (t *TransData) PopByteArray() []byte

+ func (t *TransData) PopFloat32() float32

+ func (t *TransData) PopFloat64() float64

+ func (t *TransData) PopInt16() int16

+ func (t *TransData) PopInt32() int32

+ func (t *TransData) PopInt64() int64

+ func (t *TransData) PopInt8() int8

+ func (t *TransData) PopString() string

+ func (t *TransData) PopUInt16() uint16

+ func (t *TransData) PopUInt32() uint32

+ func (t *TransData) PopUInt64() uint64

+ func (t *TransData) ResetIndex()

+ func (t *TransData) SetCapacity(capacity int32)

+ func (t *TransData) SetOrder(order binary.ByteOrder)

+ type Work struct

+ Body *TransData

+ Data []byte

+ Index int32

+ Length int32

+ Next *Work

+ RequestTime time.Time

+ State int32

+ func NewWork(id int32) *Work

+ func (w *Work) Add(work *Work)

+ func (w *Work) Equals(other *Work) bool

+ func (w *Work) Finish()

+ func (w *Work) GetId() int32

+ func (w *Work) Read() []byte

+ func (w *Work) Release()

+ func (w *Work) Send()

+ func (w *Work) SendTransData()

+ func (w *Work) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL