tcpx

Jan 3, 2023

Changes in this version

+ const TCPSocketType

+ const WebSocketType

+ var DefaultBufferSize = 1024

+ var DefaultMessageChannelSize = 32

+ var DefaultReadDeadline = 15 * time.Second

+ func ByteToBool(i byte) bool

+ func BytesToInt(data []byte) int

+ func BytesToInt16(data []byte) int16

+ func BytesToInt32(data []byte) int32

+ func BytesToInt64(data []byte) int64

+ func BytesToUint16(data []byte) uint16

+ func BytesToUint32(data []byte) uint32

+ func BytesToUint64(data []byte) uint64

+ func Float32bytes(float float32) []byte

+ func Float64frombytes(bytes []byte) float64

+ func IntToBytes(data interface{}) []byte

+ func SetGlobalLogger(logger TCPLibraryLogger)

+ type Conn struct

+ func (c *Conn) GetClientID() string

+ func (c *Conn) GetConnType() TCPType

+ func (c *Conn) SendMessage(data []byte) (int, error)

+ type Logger struct

+ func (l *Logger) Errorf(format string, a ...interface{})

+ func (l *Logger) Fatalf(format string, a ...interface{})

+ func (l *Logger) Infof(format string, a ...interface{})

+ func (l *Logger) SetDefaultDebug(debug bool)

+ func (l *Logger) Warnf(format string, a ...interface{})

+ type ServerSocket interface

+ GetClientID func() string

+ type Socket interface

+ OnClose func(*Conn, error)

+ OnConnect func(*Conn) error

+ OnError func(error)

+ OnRecMessage func(context.Context, *Conn, []byte)

+ type TCPClient struct

+ func NewTCPClient(debug bool, socket Socket) (*TCPClient, error)

+ func (c *TCPClient) Dial(conn net.Conn) error

+ func (c *TCPClient) DialAndStart(address string) error

+ func (c *TCPClient) DialAndStartTLS(address string) error

+ func (c *TCPClient) GetConn() *Conn

+ func (c *TCPClient) Ping(v []byte)

+ type TCPLibrary struct

+ func NewTCPLibrary(debug bool, socket ServerSocket) (*TCPLibrary, error)

+ func (t *TCPLibrary) CloseForClientID(clientID string) error

+ func (t *TCPLibrary) GetClients() *sync.Map

+ func (t *TCPLibrary) NewTCPServer() *TCPServer

+ func (t *TCPLibrary) SendMessageToAll(v []byte) (int, error)

+ func (t *TCPLibrary) SendMessageToClients(v []byte, clientIDs ...string) (sendCount int, err error)

+ func (t *TCPLibrary) SetReadBufferSize(readBufferSize int)

+ func (t *TCPLibrary) SetReadDeadline(duration time.Duration)

+ func (t *TCPLibrary) StopService() (err error)

+ type TCPLibraryLogger interface

+ Errorf func(format string, a ...interface{})

+ Fatalf func(format string, a ...interface{})

+ Infof func(format string, a ...interface{})

+ Warnf func(format string, a ...interface{})

+ type TCPServer struct

+ func (tcp *TCPServer) ListenAndServe(address string) error

+ func (tcp *TCPServer) ListenAndServeTLS(address, certFile, keyFile string) error

+ func (tcp *TCPServer) Serve(listen net.Listener) error

+ type TCPType = int