plugin

package
v0.19.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const PluginHttpProxy = "http_proxy"
View Source
const PluginSocks5 = "socks5"
View Source
const PluginStaticFile = "static_file"
View Source
const PluginUnixDomainSocket = "unix_domain_socket"

Variables

This section is empty.

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 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 frpNet.Conn)

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
	Handle(conn io.ReadWriteCloser, realConn frpNet.Conn)
	Close() error
}

func Create

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

func NewHttpProxyPlugin

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

func NewSocks5Plugin added in v0.13.0

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

func NewStaticFilePlugin added in v0.16.0

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

func NewUnixDomainSocketPlugin

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

type Socks5Plugin added in v0.13.0

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

func (*Socks5Plugin) Close added in v0.13.0

func (sp *Socks5Plugin) Close() error

func (*Socks5Plugin) Handle added in v0.13.0

func (sp *Socks5Plugin) Handle(conn io.ReadWriteCloser, realConn frpNet.Conn)

func (*Socks5Plugin) Name added in v0.13.0

func (sp *Socks5Plugin) Name() string

type StaticFilePlugin added in v0.16.0

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

func (*StaticFilePlugin) Close added in v0.16.0

func (sp *StaticFilePlugin) Close() error

func (*StaticFilePlugin) Handle added in v0.16.0

func (sp *StaticFilePlugin) Handle(conn io.ReadWriteCloser, realConn frpNet.Conn)

func (*StaticFilePlugin) Name added in v0.16.0

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 frpNet.Conn)

func (*UnixDomainSocketPlugin) Name

func (uds *UnixDomainSocketPlugin) Name() string

Jump to

Keyboard shortcuts

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