plugin

Documentation

Index

• Constants
• func Register(name string, fn CreatorFn)
• type CreatorFn
• type HTTP2HTTPSPlugin
  • func (p *HTTP2HTTPSPlugin) Close() error
  • func (p *HTTP2HTTPSPlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)
  • func (p *HTTP2HTTPSPlugin) Name() string
• type HTTPS2HTTPPlugin
  • func (p *HTTPS2HTTPPlugin) Close() error
  • func (p *HTTPS2HTTPPlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)
  • func (p *HTTPS2HTTPPlugin) Name() string
• type HttpProxy
  • func (hp *HttpProxy) Auth(req *http.Request) bool
  • func (hp *HttpProxy) Close() error
  • func (hp *HttpProxy) ConnectHandler(rw http.ResponseWriter, req *http.Request)
  • func (hp *HttpProxy) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)
  • func (hp *HttpProxy) HttpHandler(rw http.ResponseWriter, req *http.Request)
  • func (hp *HttpProxy) Name() string
  • func (hp *HttpProxy) ServeHTTP(rw http.ResponseWriter, req *http.Request)
• type Listener
  • func NewProxyListener() *Listener
  • func (l *Listener) Accept() (net.Conn, error)
  • func (l *Listener) Addr() net.Addr
  • func (l *Listener) Close() error
  • func (l *Listener) PutConn(conn net.Conn) error
• type Plugin
  • func Create(name string, params map[string]string) (p Plugin, err error)
  • func NewHTTP2HTTPSPlugin(params map[string]string) (Plugin, error)
  • func NewHTTPS2HTTPPlugin(params map[string]string) (Plugin, error)
  • func NewHttpProxyPlugin(params map[string]string) (Plugin, error)
  • func NewSocks5Plugin(params map[string]string) (p Plugin, err error)
  • func NewStaticFilePlugin(params map[string]string) (Plugin, error)
  • func NewUnixDomainSocketPlugin(params map[string]string) (p Plugin, err error)
• type Socks5Plugin
  • func (sp *Socks5Plugin) Close() error
  • func (sp *Socks5Plugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)
  • func (sp *Socks5Plugin) Name() string
• type StaticFilePlugin
  • func (sp *StaticFilePlugin) Close() error
  • func (sp *StaticFilePlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)
  • func (sp *StaticFilePlugin) Name() string
• type UnixDomainSocketPlugin
  • func (uds *UnixDomainSocketPlugin) Close() error
  • func (uds *UnixDomainSocketPlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)
  • func (uds *UnixDomainSocketPlugin) Name() string

Constants

const PluginHTTP2HTTPS = "http2https"

const PluginHTTPS2HTTP = "https2http"

const PluginHttpProxy = "http_proxy"

const PluginSocks5 = "socks5"

const PluginStaticFile = "static_file"

const PluginUnixDomainSocket = "unix_domain_socket"

Functions

func Register

func Register(name string, fn CreatorFn)

Types

type CreatorFn

type CreatorFn func(params map[string]string) (Plugin, error)

params has prefix "plugin_"

type HTTP2HTTPSPlugin

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

func (*HTTP2HTTPSPlugin) Close

func (p *HTTP2HTTPSPlugin) Close() error

func (*HTTP2HTTPSPlugin) Handle

func (p *HTTP2HTTPSPlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)

func (*HTTP2HTTPSPlugin) Name

func (p *HTTP2HTTPSPlugin) Name() string

type HTTPS2HTTPPlugin

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

func (*HTTPS2HTTPPlugin) Close

func (p *HTTPS2HTTPPlugin) Close() error

func (*HTTPS2HTTPPlugin) Handle

func (p *HTTPS2HTTPPlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)

func (*HTTPS2HTTPPlugin) Name

func (p *HTTPS2HTTPPlugin) Name() string

type HttpProxy

type HttpProxy struct {
	AuthUser   string
	AuthPasswd string
	// contains filtered or unexported fields
}

func (*HttpProxy) Auth

func (hp *HttpProxy) Auth(req *http.Request) bool

func (*HttpProxy) Close

func (hp *HttpProxy) Close() error

func (*HttpProxy) ConnectHandler

func (hp *HttpProxy) ConnectHandler(rw http.ResponseWriter, req *http.Request)

deprecated Hijack needs to SetReadDeadline on the Conn of the request, but if we use stream compression here, we may always get i/o timeout error.

func (*HttpProxy) Handle

func (hp *HttpProxy) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)

func (*HttpProxy) HttpHandler

func (hp *HttpProxy) HttpHandler(rw http.ResponseWriter, req *http.Request)

func (*HttpProxy) Name

func (hp *HttpProxy) Name() string

func (*HttpProxy) ServeHTTP

func (hp *HttpProxy) ServeHTTP(rw http.ResponseWriter, req *http.Request)

type Listener

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

func NewProxyListener

func NewProxyListener() *Listener

func (*Listener) Accept

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

func (*Listener) Addr

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

func (*Listener) Close

func (l *Listener) Close() error

func (*Listener) PutConn

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

type Plugin

type Plugin interface {
	Name() string

	// extraBufToLocal will send to local connection first, then join conn with local connection
	Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)
	Close() error
}

func Create

func Create(name string, params map[string]string) (p Plugin, err error)

func NewHTTP2HTTPSPlugin

func NewHTTP2HTTPSPlugin(params map[string]string) (Plugin, error)

func NewHTTPS2HTTPPlugin

func NewHTTPS2HTTPPlugin(params map[string]string) (Plugin, error)

func NewHttpProxyPlugin

func NewHttpProxyPlugin(params map[string]string) (Plugin, error)

func NewSocks5Plugin

func NewSocks5Plugin(params map[string]string) (p Plugin, err error)

func NewStaticFilePlugin

func NewStaticFilePlugin(params map[string]string) (Plugin, error)

func NewUnixDomainSocketPlugin

func NewUnixDomainSocketPlugin(params map[string]string) (p Plugin, err error)

type Socks5Plugin

type Socks5Plugin struct {
	Server *gosocks5.Server
	// contains filtered or unexported fields
}

func (*Socks5Plugin) Close

func (sp *Socks5Plugin) Close() error

func (*Socks5Plugin) Handle

func (sp *Socks5Plugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)

func (*Socks5Plugin) Name

func (sp *Socks5Plugin) Name() string

type StaticFilePlugin

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

func (*StaticFilePlugin) Close

func (sp *StaticFilePlugin) Close() error

func (*StaticFilePlugin) Handle

func (sp *StaticFilePlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)

func (*StaticFilePlugin) Name

func (sp *StaticFilePlugin) Name() string

type UnixDomainSocketPlugin

type UnixDomainSocketPlugin struct {
	UnixAddr *net.UnixAddr
}

func (*UnixDomainSocketPlugin) Close

func (uds *UnixDomainSocketPlugin) Close() error

func (*UnixDomainSocketPlugin) Handle

func (uds *UnixDomainSocketPlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, extraBufToLocal []byte)

func (*UnixDomainSocketPlugin) Name

func (uds *UnixDomainSocketPlugin) Name() string