net

package
v0.0.0-...-0209510 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FrpWebsocketPath = "/~!frp"
)

Variables

View Source 
var ErrWebsocketListenerClosed = errors.New("websocket listener closed")
View Source 
var FRPTLSHeadByte = 0x17

Functions

func CheckAndEnableTLSServerConnWithTimeout 

func CheckAndEnableTLSServerConnWithTimeout(
	c net.Conn, tlsConfig *tls.Config, tlsOnly bool, timeout time.Duration,
) (out net.Conn, isTLS bool, custom bool, err error)

func DialHookCustomTLSHeadByte 

func DialHookCustomTLSHeadByte(enableTLS bool, disableCustomTLSHeadByte bool) libnet.AfterHookFunc

func DialHookWebsocket 

func DialHookWebsocket(protocol string, host string) libnet.AfterHookFunc

func MakeHTTPGzipHandler 

func MakeHTTPGzipHandler(h http.Handler) http.Handler

func NewContextFromConn 

func NewContextFromConn(conn net.Conn) context.Context

func NewCryptoReadWriter 

func NewCryptoReadWriter(rw io.ReadWriter, key []byte) (io.ReadWriter, error)

func NewKCPConnFromUDP 

func NewKCPConnFromUDP(conn *net.UDPConn, connected bool, raddr string) (net.Conn, error)

func NewLogFromConn 

func NewLogFromConn(conn net.Conn) *xlog.Logger

func QuicStreamToNetConn 

func QuicStreamToNetConn(s quic.Stream, c quic.Connection) net.Conn

func SetDefaultDNSAddress 

func SetDefaultDNSAddress(dnsAddress string)

func WrapCloseNotifyConn 

func WrapCloseNotifyConn(c net.Conn, closeFn func()) net.Conn

closeFn will be only called once

Types

type CloseNotifyConn 

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

func (*CloseNotifyConn) Close 

func (cc *CloseNotifyConn) Close() (err error)

type ConnectedUDPConn 

type ConnectedUDPConn struct{ *net.UDPConn }

ConnectedUDPConn is a wrapper for net.UDPConn which converts WriteTo syscalls to Write syscalls that are 4 times faster on some OS'es. This should only be used for connections that were produced by a net.Dial* call.

func (*ConnectedUDPConn) WriteTo 

func (c *ConnectedUDPConn) WriteTo(b []byte, _ net.Addr) (int, error)

WriteTo redirects all writes to the Write syscall, which is 4 times faster.

type ContextConn 

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

ContextConn is the connection with context

func NewContextConn 

func NewContextConn(ctx context.Context, c net.Conn) *ContextConn

func (*ContextConn) Context 

func (c *ContextConn) Context() context.Context

func (*ContextConn) WithContext 

func (c *ContextConn) WithContext(ctx context.Context)

type ContextGetter 

type ContextGetter interface {
	Context() context.Context
}

type ContextSetter 

type ContextSetter interface {
	WithContext(ctx context.Context)
}

type FakeUDPConn 

type FakeUDPConn struct {
	// contains filtered or unexported fields
}

func NewFakeUDPConn 

func NewFakeUDPConn(l *UDPListener, laddr, raddr net.Addr) *FakeUDPConn

func (*FakeUDPConn) Close 

func (c *FakeUDPConn) Close() error

func (*FakeUDPConn) IsClosed 

func (c *FakeUDPConn) IsClosed() bool

func (*FakeUDPConn) LocalAddr 

func (c *FakeUDPConn) LocalAddr() net.Addr

func (*FakeUDPConn) Read 

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

func (*FakeUDPConn) RemoteAddr 

func (c *FakeUDPConn) RemoteAddr() net.Addr

func (*FakeUDPConn) SetDeadline 

func (c *FakeUDPConn) SetDeadline(_ time.Time) error

func (*FakeUDPConn) SetReadDeadline 

func (c *FakeUDPConn) SetReadDeadline(_ time.Time) error

func (*FakeUDPConn) SetWriteDeadline 

func (c *FakeUDPConn) SetWriteDeadline(_ time.Time) error

func (*FakeUDPConn) Write 

func (c *FakeUDPConn) Write(b []byte) (n int, err error)

type HTTPAuthMiddleware 

type HTTPAuthMiddleware struct {
	// contains filtered or unexported fields
}

func NewHTTPAuthMiddleware 

func NewHTTPAuthMiddleware(user, passwd string) *HTTPAuthMiddleware

func (*HTTPAuthMiddleware) Middleware 

func (authMid *HTTPAuthMiddleware) Middleware(next http.Handler) http.Handler

func (*HTTPAuthMiddleware) SetAuthFailDelay 

func (authMid *HTTPAuthMiddleware) SetAuthFailDelay(delay time.Duration) *HTTPAuthMiddleware

type HTTPGzipWrapper 

type HTTPGzipWrapper struct {
	// contains filtered or unexported fields
}

func (*HTTPGzipWrapper) ServeHTTP 

func (gw *HTTPGzipWrapper) ServeHTTP(w http.ResponseWriter, r *http.Request)

type InternalAddr 

type InternalAddr struct{}

func (*InternalAddr) Network 

func (ia *InternalAddr) Network() string

func (*InternalAddr) String 

func (ia *InternalAddr) String() string

type InternalListener 

type InternalListener struct {
	// contains filtered or unexported fields
}

InternalListener is a listener that can be used to accept connections from other goroutines.

func NewInternalListener 

func NewInternalListener() *InternalListener

func (*InternalListener) Accept 

func (l *InternalListener) Accept() (net.Conn, error)

func (*InternalListener) Addr 

func (l *InternalListener) Addr() net.Addr

func (*InternalListener) Close 

func (l *InternalListener) Close() error

func (*InternalListener) PutConn 

func (l *InternalListener) PutConn(conn net.Conn) error

type KCPListener 

type KCPListener struct {
	// contains filtered or unexported fields
}

func ListenKcp 

func ListenKcp(address string) (l *KCPListener, err error)

func (*KCPListener) Accept 

func (l *KCPListener) Accept() (net.Conn, error)

func (*KCPListener) Addr 

func (l *KCPListener) Addr() net.Addr

func (*KCPListener) Close 

func (l *KCPListener) Close() error

type StatsConn 

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

func WrapStatsConn 

func WrapStatsConn(conn net.Conn, statsFunc func(total, totalWrite int64)) *StatsConn

func (*StatsConn) Close 

func (statsConn *StatsConn) Close() (err error)

func (*StatsConn) Read 

func (statsConn *StatsConn) Read(p []byte) (n int, err error)

func (*StatsConn) Write 

func (statsConn *StatsConn) Write(p []byte) (n int, err error)

type UDPListener 

type UDPListener struct {
	// contains filtered or unexported fields
}

func ListenUDP 

func ListenUDP(bindAddr string, bindPort int) (l *UDPListener, err error)

func (*UDPListener) Accept 

func (l *UDPListener) Accept() (net.Conn, error)

func (*UDPListener) Addr 

func (l *UDPListener) Addr() net.Addr

func (*UDPListener) Close 

func (l *UDPListener) Close() error

func (*UDPListener) WriteMsg 

func (l *UDPListener) WriteMsg(buf []byte, remoteAddr *net.UDPAddr) (err error)

type UDPPacket 

type UDPPacket struct {
	Buf        []byte
	LocalAddr  net.Addr
	RemoteAddr net.Addr
}

type WebsocketListener 

type WebsocketListener struct {
	// contains filtered or unexported fields
}

func NewWebsocketListener 

func NewWebsocketListener(ln net.Listener) (wl *WebsocketListener)

NewWebsocketListener to handle websocket connections ln: tcp listener for websocket connections

func (*WebsocketListener) Accept 

func (p *WebsocketListener) Accept() (net.Conn, error)

func (*WebsocketListener) Addr 

func (p *WebsocketListener) Addr() net.Addr

func (*WebsocketListener) Close 

func (p *WebsocketListener) Close() error

type WrapReadWriteCloserConn 

type WrapReadWriteCloserConn struct {
	io.ReadWriteCloser
	// contains filtered or unexported fields
}

func WrapReadWriteCloserToConn 

func WrapReadWriteCloserToConn(rwc io.ReadWriteCloser, underConn net.Conn) *WrapReadWriteCloserConn

func (*WrapReadWriteCloserConn) LocalAddr 

func (conn *WrapReadWriteCloserConn) LocalAddr() net.Addr

func (*WrapReadWriteCloserConn) RemoteAddr 

func (conn *WrapReadWriteCloserConn) RemoteAddr() net.Addr

func (*WrapReadWriteCloserConn) SetDeadline 

func (conn *WrapReadWriteCloserConn) SetDeadline(t time.Time) error

func (*WrapReadWriteCloserConn) SetReadDeadline 

func (conn *WrapReadWriteCloserConn) SetReadDeadline(t time.Time) error

func (*WrapReadWriteCloserConn) SetRemoteAddr 

func (conn *WrapReadWriteCloserConn) SetRemoteAddr(addr net.Addr)

func (*WrapReadWriteCloserConn) SetWriteDeadline 

func (conn *WrapReadWriteCloserConn) SetWriteDeadline(t time.Time) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.