net

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: May 2, 2018 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HttpBasicAuth added in v0.13.0 

func HttpBasicAuth(h http.HandlerFunc, user, passwd string) http.HandlerFunc

func HttprouterBasicAuth added in v0.13.0 

func HttprouterBasicAuth(h httprouter.Handle, user, passwd string) httprouter.Handle

func MakeHttpGzipHandler added in v0.13.0 

func MakeHttpGzipHandler(h http.Handler) http.Handler

func NewHttpBasicAuthWraper added in v0.13.0 

func NewHttpBasicAuthWraper(h http.Handler, user, passwd string) http.Handler

func NewKcpConnFromUdp added in v0.14.0 

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

Types

type Conn 

type Conn interface {
	net.Conn
	log.Logger
}

Conn is the interface of connections used in frp.

func ConnectServer added in v0.12.0 

func ConnectServer(protocol string, addr string) (c Conn, err error)

func ConnectServerByHttpProxy added in v0.12.0 

func ConnectServerByHttpProxy(httpProxy string, protocol string, addr string) (c Conn, err error)

func ConnectTcpServer 

func ConnectTcpServer(addr string) (c Conn, err error)

func ConnectTcpServerByHttpProxy 

func ConnectTcpServerByHttpProxy(httpProxy string, serverAddr string) (c Conn, err error)

ConnectTcpServerByHttpProxy try to connect remote server by http proxy. If httpProxy is empty, it will connect server directly.

func WrapConn 

func WrapConn(c net.Conn) Conn

func WrapReadWriteCloserToConn added in v0.11.0 

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

type CustomListener added in v0.13.0 

type CustomListener struct {
	log.Logger
	// contains filtered or unexported fields
}

Custom listener

func NewCustomListener added in v0.13.0 

func NewCustomListener() *CustomListener

func (*CustomListener) Accept added in v0.13.0 

func (l *CustomListener) Accept() (Conn, error)

func (*CustomListener) Addr added in v0.13.0 

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

func (*CustomListener) Close added in v0.13.0 

func (l *CustomListener) Close() error

func (*CustomListener) PutConn added in v0.13.0 

func (l *CustomListener) PutConn(conn Conn) error

type FakeUdpConn 

type FakeUdpConn struct {
	log.Logger
	// 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(t time.Time) error

func (*FakeUdpConn) SetReadDeadline 

func (c *FakeUdpConn) SetReadDeadline(t time.Time) error

func (*FakeUdpConn) SetWriteDeadline 

func (c *FakeUdpConn) SetWriteDeadline(t time.Time) error

func (*FakeUdpConn) Write 

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

type HttpAuthWraper added in v0.13.0 

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

func (*HttpAuthWraper) ServeHTTP added in v0.13.0 

func (aw *HttpAuthWraper) ServeHTTP(w http.ResponseWriter, r *http.Request)

type HttpGzipWraper added in v0.13.0 

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

func (*HttpGzipWraper) ServeHTTP added in v0.13.0 

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

type KcpListener added in v0.12.0 

type KcpListener struct {
	net.Addr

	log.Logger
	// contains filtered or unexported fields
}

func ListenKcp added in v0.12.0 

func ListenKcp(bindAddr string, bindPort int) (l *KcpListener, err error)

func (*KcpListener) Accept added in v0.12.0 

func (l *KcpListener) Accept() (Conn, error)

func (*KcpListener) Close added in v0.12.0 

func (l *KcpListener) Close() error

type Listener 

type Listener interface {
	Accept() (Conn, error)
	Close() error
	log.Logger
}

func WrapLogListener added in v0.12.0 

func WrapLogListener(l net.Listener) Listener

type LogListener added in v0.12.0 

type LogListener struct {
	net.Listener
	log.Logger
	// contains filtered or unexported fields
}

func (*LogListener) Accept added in v0.12.0 

func (logL *LogListener) Accept() (Conn, error)

type SharedConn added in v0.12.0 

type SharedConn struct {
	Conn
	sync.Mutex
	// contains filtered or unexported fields
}

func NewShareConn added in v0.12.0 

func NewShareConn(conn Conn) (*SharedConn, io.Reader)

the bytes you read in io.Reader, will be reserved in SharedConn

func (*SharedConn) Read added in v0.12.0 

func (sc *SharedConn) Read(p []byte) (n int, err error)

func (*SharedConn) WriteBuff added in v0.12.0 

func (sc *SharedConn) WriteBuff(buffer []byte) (err error)

type StatsConn added in v0.15.0 

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

func WrapStatsConn added in v0.15.0 

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

func (*StatsConn) Close added in v0.15.0 

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

func (*StatsConn) Read added in v0.15.0 

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

func (*StatsConn) Write added in v0.15.0 

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

type TcpConn 

type TcpConn struct {
	net.Conn
	log.Logger
}

Wrap for TCPConn.

func NewTcpConn 

func NewTcpConn(conn *net.TCPConn) (c *TcpConn)

type TcpListener 

type TcpListener struct {
	net.Addr

	log.Logger
	// contains filtered or unexported fields
}

func ListenTcp 

func ListenTcp(bindAddr string, bindPort int) (l *TcpListener, err error)

func (*TcpListener) Accept 

func (l *TcpListener) Accept() (Conn, error)

Wait util get one new connection or listener is closed if listener is closed, err returned.

func (*TcpListener) Close 

func (l *TcpListener) Close() error

type UdpListener 

type UdpListener struct {
	net.Addr

	log.Logger
	// contains filtered or unexported fields
}

func ListenUDP 

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

func (*UdpListener) Accept 

func (l *UdpListener) Accept() (Conn, error)

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 WrapLogConn 

type WrapLogConn struct {
	net.Conn
	log.Logger
}

type WrapReadWriteCloserConn added in v0.11.0 

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

func (*WrapReadWriteCloserConn) LocalAddr added in v0.11.0 

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

func (*WrapReadWriteCloserConn) RemoteAddr added in v0.11.0 

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

func (*WrapReadWriteCloserConn) SetDeadline added in v0.11.0 

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

func (*WrapReadWriteCloserConn) SetReadDeadline added in v0.11.0 

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

func (*WrapReadWriteCloserConn) SetWriteDeadline added in v0.11.0 

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.