proxy

Documentation

Index

• type ConfigWatcher
• type LeafCertSpec
• type Manager
  • func NewProxyManager(peerHost *schedulerv1.PeerHost, peerTaskManager peer.TaskManager, ...) (Manager, error)
• type Option
  • func WithBasicAuth(auth *config.BasicAuth) Option
  • func WithCert(cert *tls.Certificate) Option
  • func WithDefaultApplication(t string) Option
  • func WithDefaultFilter(f string) Option
  • func WithDefaultPriority(priority commonv1.Priority) Option
  • func WithDefaultTag(t string) Option
  • func WithDumpHTTPContent(dump bool) Option
  • func WithHTTPSHosts(hosts ...*config.HijackHost) Option
  • func WithMaxConcurrency(con int64) Option
  • func WithPeerHost(peerHost *schedulerv1.PeerHost) Option
  • func WithPeerIDGenerator(peerIDGenerator peer.IDGenerator) Option
  • func WithPeerSearcher(peerSearcher pex.PeerSearchBroadcaster) Option
  • func WithPeerTaskManager(peerTaskManager peer.TaskManager) Option
  • func WithRegistryMirror(r *config.RegistryMirror) Option
  • func WithRules(rules []*config.ProxyRule) Option
  • func WithWhiteList(whiteList []*config.WhiteList) Option
• type Proxy
  • func NewProxy(options ...Option) (*Proxy, error)
  • func (proxy *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (proxy *Proxy) ServeSNI(l net.Listener) error

Types

type ConfigWatcher

type ConfigWatcher interface {
	Watch(*config.ProxyOption)
}

type LeafCertSpec

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

type Manager

type Manager interface {
	ConfigWatcher
	Serve(net.Listener) error
	ServeSNI(net.Listener) error
	Stop() error
	IsEnabled() bool
}

func NewProxyManager

func NewProxyManager(peerHost *schedulerv1.PeerHost, peerTaskManager peer.TaskManager, peerExchange pex.PeerExchangeServer, proxyOption *config.ProxyOption) (Manager, error)

type Option

type Option func(p *Proxy) *Proxy

Option is a functional option for configuring the proxy

func WithBasicAuth

func WithBasicAuth(auth *config.BasicAuth) Option

WithBasicAuth sets basic auth info for proxy

func WithCert

func WithCert(cert *tls.Certificate) Option

WithCert sets the certificate

func WithDefaultApplication

func WithDefaultApplication(t string) Option

WithDefaultApplication sets default tag for http requests without X-Dragonfly-Application Header

func WithDefaultFilter

func WithDefaultFilter(f string) Option

WithDefaultFilter sets default filter for http requests without X-Dragonfly-Filter Header

func WithDefaultPriority

func WithDefaultPriority(priority commonv1.Priority) Option

WithDefaultPriority sets default priority for http requests without X-Dragonfly-Priority Header

func WithDefaultTag

func WithDefaultTag(t string) Option

WithDefaultTag sets default tag for http requests without X-Dragonfly-Tag Header

func WithDumpHTTPContent

func WithDumpHTTPContent(dump bool) Option

func WithHTTPSHosts

func WithHTTPSHosts(hosts ...*config.HijackHost) Option

WithHTTPSHosts sets the rules for hijacking https requests

func WithMaxConcurrency

func WithMaxConcurrency(con int64) Option

WithMaxConcurrency sets max concurrent for process http request

func WithPeerHost

func WithPeerHost(peerHost *schedulerv1.PeerHost) Option

WithPeerHost sets the *schedulerv1.PeerHost

func WithPeerIDGenerator

func WithPeerIDGenerator(peerIDGenerator peer.IDGenerator) Option

WithPeerIDGenerator sets the *transport.PeerIDGenerator

func WithPeerSearcher

func WithPeerSearcher(peerSearcher pex.PeerSearchBroadcaster) Option

func WithPeerTaskManager

func WithPeerTaskManager(peerTaskManager peer.TaskManager) Option

WithPeerTaskManager sets the peer.PeerTaskManager

func WithRegistryMirror

func WithRegistryMirror(r *config.RegistryMirror) Option

WithRegistryMirror sets the registry mirror for the proxy

func WithRules

func WithRules(rules []*config.ProxyRule) Option

WithRules sets the proxy rules

func WithWhiteList

func WithWhiteList(whiteList []*config.WhiteList) Option

WithWhiteList sets the proxy whitelist

type Proxy

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

Proxy is a http proxy handler. It proxies requests with dragonfly if any defined proxy rules is matched

func NewProxy

func NewProxy(options ...Option) (*Proxy, error)

NewProxy returns a new transparent proxy from the given options

func (*Proxy) ServeHTTP

func (proxy *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP implements http.Handler.ServeHTTP

func (*Proxy) ServeSNI

func (proxy *Proxy) ServeSNI(l net.Listener) error