vhost

package

v0.45.0 Latest Latest Go to latest Published: Oct 26, 2022 License: Apache-2.0 Imports: 26 Imported by: 20

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/fatedier/frp

Links

Documentation ¶

Index ¶

Constants
Variables
func GetHTTPSHostname(c net.Conn) (_ net.Conn, _ map[string]string, err error)
type ByLocation
- func (a ByLocation) Len() int
- func (a ByLocation) Less(i, j int) bool
- func (a ByLocation) Swap(i, j int)
type ChooseEndpointFunc
type CreateConnByEndpointFunc
type CreateConnFunc
type HTTPReverseProxy
- func NewHTTPReverseProxy(option HTTPReverseProxyOptions, vhostRouter *Routers) *HTTPReverseProxy
- func (rp *HTTPReverseProxy) CheckAuth(domain, location, routeByHTTPUser, user, passwd string) bool
- func (rp *HTTPReverseProxy) CreateConnection(reqRouteInfo *RequestRouteInfo, byEndpoint bool) (net.Conn, error)
- func (rp *HTTPReverseProxy) GetHeaders(domain, location, routeByHTTPUser string) (headers map[string]string)
- func (rp *HTTPReverseProxy) GetRouteConfig(domain, location, routeByHTTPUser string) *RouteConfig
- func (rp *HTTPReverseProxy) Register(routeCfg RouteConfig) error
- func (rp *HTTPReverseProxy) ServeHTTP(rw http.ResponseWriter, req *http.Request)
- func (rp *HTTPReverseProxy) UnRegister(routeCfg RouteConfig)
type HTTPReverseProxyOptions
type HTTPSMuxer
- func NewHTTPSMuxer(listener net.Listener, timeout time.Duration) (*HTTPSMuxer, error)
type Listener
- func (l *Listener) Accept() (net.Conn, error)
- func (l *Listener) Addr() net.Addr
- func (l *Listener) Close() error
- func (l *Listener) Name() string
type Muxer
- func NewMuxer(listener net.Listener, vhostFunc muxFunc, authFunc httpAuthFunc, ...) (mux *Muxer, err error)
- func (v *Muxer) Listen(ctx context.Context, cfg *RouteConfig) (l *Listener, err error)
type RequestRouteInfo
type RouteConfig
type RouteInfo
type Router
type Routers
- func NewRouters() *Routers
- func (r *Routers) Add(domain, location, httpUser string, payload interface{}) error
- func (r *Routers) Del(domain, location, httpUser string)
- func (r *Routers) Get(host, path, httpUser string) (vr *Router, exist bool)

Constants ¶

View Source

const (
	NotFound = `` /* 489-byte string literal not displayed */

)

Variables ¶

View Source

var ErrNoRouteFound = errors.New("no route found")

View Source

var ErrRouterConfigConflict = errors.New("router config conflict")

View Source

var NotFoundPagePath = ""

Functions ¶

func GetHTTPSHostname ¶

func GetHTTPSHostname(c net.Conn) (_ net.Conn, _ map[string]string, err error)

Types ¶

type ByLocation ¶

type ByLocation []*Router

sort by location

func (ByLocation) Len ¶

func (a ByLocation) Len() int

func (ByLocation) Less ¶

func (a ByLocation) Less(i, j int) bool

func (ByLocation) Swap ¶

func (a ByLocation) Swap(i, j int)

type ChooseEndpointFunc ¶ added in v0.45.0

type ChooseEndpointFunc func() (string, error)

type CreateConnByEndpointFunc ¶ added in v0.45.0

type CreateConnByEndpointFunc func(endpoint, remoteAddr string) (net.Conn, error)

type CreateConnFunc ¶

type CreateConnFunc func(remoteAddr string) (net.Conn, error)

type HTTPReverseProxy ¶

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

func NewHTTPReverseProxy ¶

func NewHTTPReverseProxy(option HTTPReverseProxyOptions, vhostRouter *Routers) *HTTPReverseProxy

func (*HTTPReverseProxy) CheckAuth ¶

func (rp *HTTPReverseProxy) CheckAuth(domain, location, routeByHTTPUser, user, passwd string) bool

func (*HTTPReverseProxy) CreateConnection ¶

func (rp *HTTPReverseProxy) CreateConnection(reqRouteInfo *RequestRouteInfo, byEndpoint bool) (net.Conn, error)

CreateConnection create a new connection by route config

func (*HTTPReverseProxy) GetHeaders ¶

func (rp *HTTPReverseProxy) GetHeaders(domain, location, routeByHTTPUser string) (headers map[string]string)

func (*HTTPReverseProxy) GetRouteConfig ¶ added in v0.35.0

func (rp *HTTPReverseProxy) GetRouteConfig(domain, location, routeByHTTPUser string) *RouteConfig

func (*HTTPReverseProxy) Register ¶

func (rp *HTTPReverseProxy) Register(routeCfg RouteConfig) error

Register register the route config to reverse proxy reverse proxy will use CreateConnFn from routeCfg to create a connection to the remote service

func (*HTTPReverseProxy) ServeHTTP ¶

func (rp *HTTPReverseProxy) ServeHTTP(rw http.ResponseWriter, req *http.Request)

func (*HTTPReverseProxy) UnRegister ¶

func (rp *HTTPReverseProxy) UnRegister(routeCfg RouteConfig)

UnRegister unregister route config by domain and location

type HTTPReverseProxyOptions ¶

type HTTPReverseProxyOptions struct {
	ResponseHeaderTimeoutS int64
}

type HTTPSMuxer ¶

type HTTPSMuxer struct {
	*Muxer
}

func NewHTTPSMuxer ¶

func NewHTTPSMuxer(listener net.Listener, timeout time.Duration) (*HTTPSMuxer, error)

type Listener ¶

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

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) Name ¶

func (l *Listener) Name() string

type Muxer ¶

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

Muxer is only used for https and tcpmux proxy.

func NewMuxer ¶

func NewMuxer(
	listener net.Listener,
	vhostFunc muxFunc,
	authFunc httpAuthFunc,
	successFunc successFunc,
	rewriteFunc hostRewriteFunc,
	timeout time.Duration,
) (mux *Muxer, err error)

func (*Muxer) Listen ¶

func (v *Muxer) Listen(ctx context.Context, cfg *RouteConfig) (l *Listener, err error)

listen for a new domain name, if rewriteHost is not empty and rewriteFunc is not nil then rewrite the host header to rewriteHost

type RequestRouteInfo ¶ added in v0.45.0

type RequestRouteInfo struct {
	URL        string
	Host       string
	HTTPUser   string
	RemoteAddr string
	URLHost    string
	Endpoint   string
}

type RouteConfig ¶

type RouteConfig struct {
	Domain          string
	Location        string
	RewriteHost     string
	Username        string
	Password        string
	Headers         map[string]string
	RouteByHTTPUser string

	CreateConnFn           CreateConnFunc
	ChooseEndpointFn       ChooseEndpointFunc
	CreateConnByEndpointFn CreateConnByEndpointFunc
}

RouteConfig is the params used to match HTTP requests

type RouteInfo ¶

type RouteInfo string

const (
	RouteInfoKey RouteInfo = "routeInfo"
)

type Router ¶

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

type Routers ¶

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

func NewRouters ¶

func NewRouters() *Routers

func (*Routers) Add ¶

func (r *Routers) Add(domain, location, httpUser string, payload interface{}) error

func (*Routers) Del ¶

func (r *Routers) Del(domain, location, httpUser string)

func (*Routers) Get ¶

func (r *Routers) Get(host, path, httpUser string) (vr *Router, exist bool)

Source Files ¶

View all Source files

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