trackerconn

package

v1.2.2 Latest Latest Go to latest Published: Mar 31, 2023 License: GPL-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Conn struct {
	N.ExtendedConn
	// contains filtered or unexported fields
}

func New(conn net.Conn, readCounter []*atomic.Int64, writeCounter []*atomic.Int64) *Conn

func (c *Conn) Read(p []byte) (n int, err error)

func (c *Conn) ReadBuffer(buffer *buf.Buffer) error

func (c *Conn) Upstream() any

func (c *Conn) Write(p []byte) (n int, err error)

func (c *Conn) WriteBuffer(buffer *buf.Buffer) error

type HookConn struct {
	N.ExtendedConn
	// contains filtered or unexported fields
}

func NewHook(conn net.Conn, readCounter func(n int64), writeCounter func(n int64)) *HookConn

func (c *HookConn) Read(p []byte) (n int, err error)

func (c *HookConn) ReadBuffer(buffer *buf.Buffer) error

func (c *HookConn) Upstream() any

func (c *HookConn) Write(p []byte) (n int, err error)

func (c *HookConn) WriteBuffer(buffer *buf.Buffer) error

type HookPacketConn struct {
	N.PacketConn
	// contains filtered or unexported fields
}

func NewHookPacket(conn N.PacketConn, readCounter func(n int64), writeCounter func(n int64)) *HookPacketConn

func (c *HookPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

func (c *HookPacketConn) Upstream() any

func (c *HookPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

type PacketConn struct {
	N.PacketConn
	// contains filtered or unexported fields
}

func NewPacket(conn N.PacketConn, readCounter []*atomic.Int64, writeCounter []*atomic.Int64) *PacketConn

func (c *PacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

func (c *PacketConn) Upstream() any

func (c *PacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error