gxtcp

package

v0.1.0 Latest Latest Go to latest Published: Aug 22, 2023 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/oldjon/gx

Links

Open Source Insights

Documentation ¶

Index ¶

type TCPClient
- func (tc *TCPClient) Connect(address string) (*net.TCPConn, error)
type TCPFrame
type TCPTask
- func NewTCPTask(conn net.Conn, logger *zap.Logger, pmHandler func(data []byte), ...) *TCPTask

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type TCPClient ¶

type TCPClient struct {
}

func (*TCPClient) Connect ¶

func (tc *TCPClient) Connect(address string) (*net.TCPConn, error)

type TCPFrame ¶

type TCPFrame interface {
	HeaderSize() int
	Size([]byte) (int, error)
	EncodeMsg(uint8, uint32, interface{}) ([]byte, error)
	DecodeMsg([]byte, interface{}) error
}

type TCPTask ¶

type TCPTask struct {
	Conn net.Conn
	// contains filtered or unexported fields
}

func NewTCPTask ¶

func NewTCPTask(conn net.Conn, logger *zap.Logger, pmHandler func(data []byte), ocHandler func(), f TCPFrame) *TCPTask

func (*TCPTask) Close ¶

func (tt *TCPTask) Close()

func (*TCPTask) IsClosed ¶

func (tt *TCPTask) IsClosed() bool

func (*TCPTask) IsVerified ¶

func (tt *TCPTask) IsVerified() bool

func (*TCPTask) LocalAddr ¶

func (tt *TCPTask) LocalAddr() string

func (*TCPTask) RemoteAddr ¶

func (tt *TCPTask) RemoteAddr() string

func (*TCPTask) Reset ¶

func (tt *TCPTask) Reset() bool

func (*TCPTask) RevLoop ¶

func (tt *TCPTask) RevLoop()

func (*TCPTask) SendBytes ¶

func (tt *TCPTask) SendBytes(buffer []byte) bool

func (*TCPTask) SendLoop ¶

func (tt *TCPTask) SendLoop()

func (*TCPTask) SendMsg ¶

func (tt *TCPTask) SendMsg(cmd uint8, subCmd uint32, msg interface{}) bool

func (*TCPTask) SendSignal ¶

func (tt *TCPTask) SendSignal()

func (*TCPTask) Start ¶

func (tt *TCPTask) Start()

func (*TCPTask) Stop ¶

func (tt *TCPTask) Stop() bool

func (*TCPTask) Terminate ¶

func (tt *TCPTask) Terminate()

func (*TCPTask) Verify ¶

func (tt *TCPTask) Verify()

Source Files ¶

View all Source files

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