nets

package module

Go to main page

Versions in this module

v1

v1.2.3

May 20, 2026

v1.2.2

May 14, 2026

Changes in this version

+ func GenerateConnID() string

+ func PutMessage(m IMessage)

type ConnectionBase

+ func (c *ConnectionBase) Close()

+ func (c *ConnectionBase) ConnCtxDone() <-chan struct{}

+ func (c *ConnectionBase) Open()

+ func (c *ConnectionBase) RemoteAddrStr() string

+ func (c *ConnectionBase) RemoveProperty(key string)

+ func (c *ConnectionBase) SetProperty(key string, value any)

type ConnectionManager

+ func (c *ConnectionManager) GetConnClosed(conn IConnection)

+ func (c *ConnectionManager) GetConnOpened(conn IConnection)

+ func (c *ConnectionManager) SetConnClosed(connCloseCallBack func(conn IConnection))

+ func (c *ConnectionManager) SetConnOpened(connOpenCallBack func(conn IConnection))

type IConnection

+ Close func()

+ ConnCtxDone func() <-chan struct{}

+ GetNetConn func() net.Conn

+ Open func()

+ RemoveProperty func(key string)

+ SetProperty func(key string, value any)

type Message

+ func GetMessage() *Message

v1.2.1

Dec 30, 2025

Changes in this version

+ var ConnPropertyHttpAuthorization = "HttpAuthorization"

+ var ConnPropertyHttpReader = "HttpReader"

+ var ConnPropertyHttpWriter = "HttpWriter"

+ var SHARD_COUNT = 32

+ func ConnPropertyGet[T any](c IConnection, key string) T

+ func ConnPropertyRemove(c IConnection, key string)

+ func ConnPropertySet(c IConnection, key string, value any)

+ func SetCustomServer(custom *CustomServer)

+ type AppConf struct

+ AppName string

+ ConnRWTimeOut int

+ MaxConn int

+ MaxFlowSecond int

+ MaxMsgChanLen int

+ MaxPackSize int

+ ProtocolIsJson bool

+ ServerHTTP ServerConf

+ ServerKCP ServerConf

+ ServerTCP ServerConf

+ ServerWS ServerConf

+ WorkerPoolSize int

+ WorkerTaskMaxLen int

+ func GetServerConf() *AppConf

+ type BaseRouter struct

+ func (b *BaseRouter) GetNewMsg() proto.Message

+ func (b *BaseRouter) RunHandler(conn IConnection, message proto.Message)

+ func (b *BaseRouter) SetHandler(msgHandler IReceiveMsgHandler)

+ func (b *BaseRouter) SetMsg(msgTemplate INewMsgStructTemplate)

+ type ConcurrentMap struct

+ func NewConcurrentMap[V any]() ConcurrentMap[string, V]

+ func NewConcurrentStringer[K Stringer, V any]() ConcurrentMap[K, V]

+ func NewWithCustomShardingFunction[K comparable, V any](sharding func(key K) uint32) ConcurrentMap[K, V]

+ func (m ConcurrentMap[K, V]) Clear()

+ func (m ConcurrentMap[K, V]) Count() int

+ func (m ConcurrentMap[K, V]) Get(key K) (V, bool)

+ func (m ConcurrentMap[K, V]) GetShard(key K) *ConcurrentMapShared[K, V]

+ func (m ConcurrentMap[K, V]) Has(key K) bool

+ func (m ConcurrentMap[K, V]) IsEmpty() bool

+ func (m ConcurrentMap[K, V]) Items() map[K]V

+ func (m ConcurrentMap[K, V]) IterBuffered() <-chan Tuple[K, V]

+ func (m ConcurrentMap[K, V]) IterCb(fn IterCb[K, V])

+ func (m ConcurrentMap[K, V]) Keys() []K

+ func (m ConcurrentMap[K, V]) MSet(data map[K]V)

+ func (m ConcurrentMap[K, V]) MarshalJSON() ([]byte, error)

+ func (m ConcurrentMap[K, V]) Pop(key K) (v V, exists bool)

+ func (m ConcurrentMap[K, V]) Remove(key K)

+ func (m ConcurrentMap[K, V]) RemoveCb(key K, cb RemoveCb[K, V]) bool

+ func (m ConcurrentMap[K, V]) Set(key K, value V)

+ func (m ConcurrentMap[K, V]) SetIfAbsent(key K, value V) bool

+ func (m ConcurrentMap[K, V]) UnmarshalJSON(b []byte) (err error)

+ func (m ConcurrentMap[K, V]) Upsert(key K, value V, cb UpsertCb[V]) (res V)

+ type ConcurrentMapShared struct

+ type ConnectionBase struct

+ func (c *ConnectionBase) ByteToProtocol(byte []byte, target proto.Message) error

+ func (c *ConnectionBase) DoTask(task func())

+ func (c *ConnectionBase) FlowControl() (b bool)

+ func (c *ConnectionBase) GetConnId() int

+ func (c *ConnectionBase) GetProperty() any

+ func (c *ConnectionBase) IsClose() bool

+ func (c *ConnectionBase) ProtocolToByte(str proto.Message) []byte

+ func (c *ConnectionBase) SendMsg(msgId int32, msgData proto.Message)

+ func (c *ConnectionBase) Start(readerHandler func() bool, writerHandler func(data []byte) bool)

+ func (c *ConnectionBase) Stop() bool

+ type ConnectionManager struct

+ func GetInstanceConnManager() *ConnectionManager

+ func (c *ConnectionManager) Add(conn IConnection)

+ func (c *ConnectionManager) ClearConn()

+ func (c *ConnectionManager) ConnOnClosed(conn IConnection)

+ func (c *ConnectionManager) ConnOnOpened(conn IConnection)

+ func (c *ConnectionManager) ConnRateLimiting(conn IConnection)

+ func (c *ConnectionManager) Get(connId int) (IConnection, bool)

+ func (c *ConnectionManager) Len() int

+ func (c *ConnectionManager) NewConnId() int

+ func (c *ConnectionManager) RangeConnections(handler func(conn IConnection))

+ func (c *ConnectionManager) Remove(conn IConnection)

+ func (c *ConnectionManager) SetConnOnClosed(connCloseCallBack func(conn IConnection))

+ func (c *ConnectionManager) SetConnOnOpened(connOpenCallBack func(conn IConnection))

+ func (c *ConnectionManager) SetConnOnRateLimiting(limitCallBack func(conn IConnection))

+ type CustomServer struct

+ AppConf *AppConf

+ DataPack IDataPack

+ Message func(id int32, data []byte) IMessage

+ type IConnection interface

+ ByteToProtocol func(byte []byte, target proto.Message) error

+ DoTask func(task func())

+ FlowControl func() bool

+ GetConnId func() int

+ GetProperty func() any

+ IsClose func() bool

+ ProtocolToByte func(str proto.Message) []byte

+ RemoteAddrStr func() string

+ SendMsg func(msgId int32, msgData proto.Message)

+ Start func(readerHandler func() bool, writerHandler func(data []byte) bool)

+ StartReader func() bool

+ StartWriter func(data []byte) bool

+ Stop func() bool

+ func NewConnectionHTTP(server IServer, writer http.ResponseWriter, reader *http.Request) IConnection

+ func NewConnectionKCP(server *serverKCP, conn net.Conn) IConnection

+ func NewConnectionTCP(server IServer, conn *net.TCPConn) IConnection

+ func NewConnectionWS(server IServer, conn *websocket.Conn) IConnection

+ type IDataPack interface

+ GetHeadLen func() int

+ Pack func(msg IMessage) []byte

+ UnPack func([]byte) IMessage

+ func NewDataPack() IDataPack

+ type IErrCapture func(conn IConnection, msg IMessage, panicInfo string)

+ type IFilter func(conn IConnection, msg IMessage) bool

+ type IMessage interface

+ GetData func() []byte

+ GetDataLen func() uint16

+ GetMsgId func() uint16

+ SetData func([]byte)

+ func NewMsgPackage(id int32, data []byte) IMessage

+ type INewMsgStructTemplate func() proto.Message

+ type IReceiveMsgHandler func(conn IConnection, message proto.Message)

+ type IServer interface

+ GetServerName func() string

+ Start func()

+ func GetServerHTTP() IServer

+ func GetServerKCP() IServer

+ func GetServerTCP() IServer

+ func GetServerWS() IServer

+ type Integer int

+ func (i Integer) String() string

+ type IterCb func(key K, v V)

+ type Message struct

+ Data string

+ DataLen uint16

+ Id uint16

+ func (m *Message) GetData() []byte

+ func (m *Message) GetDataLen() uint16

+ func (m *Message) GetMsgId() uint16

+ func (m *Message) SetData(bytes []byte)

+ type MsgHandler struct

+ func GetInstanceMsgHandler() *MsgHandler

+ func (m *MsgHandler) AddRouter(msgId int32, msgTemplate INewMsgStructTemplate, msgHandler IReceiveMsgHandler)

+ func (m *MsgHandler) GetApis() map[int32]*BaseRouter

+ func (m *MsgHandler) GetErrCapture(conn IConnection, message IMessage)

+ func (m *MsgHandler) GetFilter() IFilter

+ func (m *MsgHandler) SetErrCapture(fun IErrCapture)

+ func (m *MsgHandler) SetFilter(fun IFilter)

+ type RemoveCb func(key K, v V, exists bool) bool

+ type ServerConf struct

+ Address string

+ Port string

+ TLSCertPath string

+ TLSKeyPath string

+ type ServerManager struct

+ func GetInstanceServerManager() *ServerManager

+ func (c *ServerManager) IsClose() bool

+ func (c *ServerManager) RegisterServer(server ...IServer)

+ func (c *ServerManager) Servers() []IServer

+ func (c *ServerManager) StopAll()

+ func (c *ServerManager) WaitGroupAdd(delta int)

+ func (c *ServerManager) WaitGroupDone()

+ type Stringer interface

+ type Tuple struct

+ Key K

+ Val V

+ type UpsertCb func(exist bool, valueInMap V, newValue V) V

v1.2.0

Dec 30, 2025

v1.1.2

Dec 9, 2025

v1.1.1

Dec 9, 2025

v1.1.0

Dec 8, 2025

v1.0.2-bate1

Nov 19, 2023

v1.0.1

Nov 14, 2023

v1.0.1-beta1

Nov 14, 2023

v1.0.0

Nov 12, 2023

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