net

package

v1.0.0 Latest Latest Go to latest Published: Nov 12, 2023 License: GPL-3.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/devsolux/clash-meta

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func MaskWebSocket(key uint32, b []byte) uint32
func NeedHandshake(conn any) bool
func NewBindPacketConn(pc net.PacketConn, rAddr net.Addr) net.Conn
func NewRefConn(conn net.Conn, ref any) net.Conn
func ParseCert(certificate, privateKey string, path Path) (tls.Certificate, error)
func Relay(leftConn, rightConn net.Conn)
func SetupContextForConn(ctx context.Context, conn net.Conn) (done func(*error))
func SplitHostPort(s string) (host, port string, hasPort bool, err error)
func SplitNetworkType(s string) (string, string, error)
func TCPKeepAlive(c net.Conn)
func WarpConnWithBioReader(c net.Conn, br *bufio.Reader) net.Conn
type BufferedConn
- func NewBufferedConn(c net.Conn) *BufferedConn
- func (c *BufferedConn) Buffered() int
- func (c *BufferedConn) Discard(n int) (discarded int, err error)
- func (c *BufferedConn) Peek(n int) ([]byte, error)
- func (c *BufferedConn) Peeked() bool
- func (c *BufferedConn) Read(p []byte) (int, error)
- func (c *BufferedConn) ReadBuffer(buffer *buf.Buffer) (err error)
- func (c *BufferedConn) ReadByte() (byte, error)
- func (c *BufferedConn) ReadCached() *buf.Buffer
- func (c *BufferedConn) Reader() *bufio.Reader
- func (c *BufferedConn) ReaderReplaceable() bool
- func (c *BufferedConn) ResetPeeked()
- func (c *BufferedConn) UnreadByte() error
- func (c *BufferedConn) Upstream() any
- func (c *BufferedConn) WriterReplaceable() bool
type CachedConn
- func NewCachedConn(c net.Conn, data []byte) *CachedConn
- func (c *CachedConn) Read(b []byte) (n int, err error)
- func (c *CachedConn) ReadCached() *buf.Buffer
- func (c *CachedConn) ReaderReplaceable() bool
- func (c *CachedConn) Upstream() any
- func (c *CachedConn) WriterReplaceable() bool
type CountFunc
type CustomAddr
- func NewCustomAddr(networkStr string, addrStr string, rawAddr net.Addr) CustomAddr
type EnhancePacketConn
type ExtendedConn
- func NewDeadlineConn(conn net.Conn) ExtendedConn
type ExtendedReader
type ExtendedWriter
type Path
type ReadOnlyReader
type WaitReadFrom
type WriteOnlyWriter

Constants ¶

This section is empty.

Variables ¶

View Source

var KeepAliveInterval = 15 * time.Second

View Source

var NewDeadlineEnhancePacketConn = deadline.NewEnhancePacketConn

View Source

var NewDeadlineEnhanceSingPacketConn = deadline.NewEnhanceSingPacketConn

View Source

var NewDeadlineNetPacketConn = deadline.NewNetPacketConn

View Source

var NewDeadlineSingPacketConn = deadline.NewSingPacketConn

View Source

var NewEnhancePacketConn = packet.NewEnhancePacketConn

View Source

var NewExtendedConn = bufio.NewExtendedConn

View Source

var NewExtendedReader = bufio.NewExtendedReader

View Source

var NewExtendedWriter = bufio.NewExtendedWriter

View Source

var NewRefPacketConn = packet.NewRefPacketConn

View Source

var NewThreadSafePacketConn = packet.NewThreadSafePacketConn

Functions ¶

func MaskWebSocket ¶

func MaskWebSocket(key uint32, b []byte) uint32

MaskWebSocket applies the WebSocket masking algorithm to p with the given key. See https://tools.ietf.org/html/rfc6455#section-5.3

The returned value is the correctly rotated key to to continue to mask/unmask the message.

It is optimized for LittleEndian and expects the key to be in little endian.

See https://github.com/golang/go/issues/31586

func NeedHandshake ¶

func NeedHandshake(conn any) bool

func NewBindPacketConn ¶

func NewBindPacketConn(pc net.PacketConn, rAddr net.Addr) net.Conn

func NewRefConn ¶

func NewRefConn(conn net.Conn, ref any) net.Conn

func ParseCert ¶

func ParseCert(certificate, privateKey string, path Path) (tls.Certificate, error)

func Relay ¶

func Relay(leftConn, rightConn net.Conn)

Relay copies between left and right bidirectionally.

func SetupContextForConn ¶

func SetupContextForConn(ctx context.Context, conn net.Conn) (done func(*error))

SetupContextForConn is a helper function that starts connection I/O interrupter goroutine.

func SplitHostPort ¶

func SplitHostPort(s string) (host, port string, hasPort bool, err error)

func SplitNetworkType ¶

func SplitNetworkType(s string) (string, string, error)

func TCPKeepAlive ¶

func TCPKeepAlive(c net.Conn)

func WarpConnWithBioReader ¶

func WarpConnWithBioReader(c net.Conn, br *bufio.Reader) net.Conn

Types ¶

type BufferedConn ¶

type BufferedConn struct {
	ExtendedConn
	// contains filtered or unexported fields
}

func NewBufferedConn ¶

func NewBufferedConn(c net.Conn) *BufferedConn

func (*BufferedConn) Buffered ¶

func (c *BufferedConn) Buffered() int

func (*BufferedConn) Discard ¶

func (c *BufferedConn) Discard(n int) (discarded int, err error)

func (*BufferedConn) Peek ¶

func (c *BufferedConn) Peek(n int) ([]byte, error)

Peek returns the next n bytes without advancing the reader.

func (*BufferedConn) Peeked ¶

func (c *BufferedConn) Peeked() bool

func (*BufferedConn) Read ¶

func (c *BufferedConn) Read(p []byte) (int, error)

func (*BufferedConn) ReadBuffer ¶

func (c *BufferedConn) ReadBuffer(buffer *buf.Buffer) (err error)

func (*BufferedConn) ReadByte ¶

func (c *BufferedConn) ReadByte() (byte, error)

func (*BufferedConn) ReadCached ¶

func (c *BufferedConn) ReadCached() *buf.Buffer

func (*BufferedConn) Reader ¶

func (c *BufferedConn) Reader() *bufio.Reader

Reader returns the internal bufio.Reader.

func (*BufferedConn) ReaderReplaceable ¶

func (c *BufferedConn) ReaderReplaceable() bool

func (*BufferedConn) ResetPeeked ¶

func (c *BufferedConn) ResetPeeked()

func (*BufferedConn) UnreadByte ¶

func (c *BufferedConn) UnreadByte() error

func (*BufferedConn) Upstream ¶

func (c *BufferedConn) Upstream() any

func (*BufferedConn) WriterReplaceable ¶

func (c *BufferedConn) WriterReplaceable() bool

type CachedConn ¶

type CachedConn struct {
	ExtendedConn
	// contains filtered or unexported fields
}

func NewCachedConn ¶

func NewCachedConn(c net.Conn, data []byte) *CachedConn

func (*CachedConn) Read ¶

func (c *CachedConn) Read(b []byte) (n int, err error)

func (*CachedConn) ReadCached ¶

func (c *CachedConn) ReadCached() *buf.Buffer

func (*CachedConn) ReaderReplaceable ¶

func (c *CachedConn) ReaderReplaceable() bool

func (*CachedConn) Upstream ¶

func (c *CachedConn) Upstream() any

func (*CachedConn) WriterReplaceable ¶

func (c *CachedConn) WriterReplaceable() bool

type CountFunc ¶

type CountFunc = network.CountFunc

type CustomAddr ¶

type CustomAddr interface {
	net.Addr
	RawAddr() net.Addr
}

func NewCustomAddr ¶

func NewCustomAddr(networkStr string, addrStr string, rawAddr net.Addr) CustomAddr

type EnhancePacketConn ¶

type EnhancePacketConn = packet.EnhancePacketConn

type ExtendedConn ¶

type ExtendedConn = network.ExtendedConn

func NewDeadlineConn ¶

func NewDeadlineConn(conn net.Conn) ExtendedConn

type ExtendedReader ¶

type ExtendedReader = network.ExtendedReader

type ExtendedWriter ¶

type ExtendedWriter = network.ExtendedWriter

type Path ¶

type Path interface {
	Resolve(path string) string
}

type ReadOnlyReader ¶

type ReadOnlyReader struct {
	io.Reader
}

type WaitReadFrom ¶

type WaitReadFrom = packet.WaitReadFrom

type WriteOnlyWriter ¶

type WriteOnlyWriter struct {
	io.Writer
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
deadline
packet

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