forwarder

Dec 6, 2024

Changes in this version

+ func WithDialConnTrack(ctx context.Context, track DialConnTrack) context.Context

type DNSConfig

+ RoundRobin bool

+ func (c *DNSConfig) Apply() error

type DialConfig

+ KeepAliveConfig net.KeepAliveConfig

+ RedirectFunc DialRedirectFunc

+ Retry DialRetryConfig

+ type DialConnTrack uint8

+ const DialConnTrackDefault

+ const DialConnTrackDisabled

+ const DialConnTrackTraffic

+ type DialRedirectFunc func(network, address string) (targetNetwork, targetAddress string)

+ func DialRedirectFromHostPortPairs(subs []HostPortPair) DialRedirectFunc

+ type DialRetryConfig struct

+ Attempts int

+ Backoff time.Duration

type HTTPProxyConfig

+ ExtraListeners []NamedListenerConfig

+ type HostPort struct

+ Host string

+ Port string

+ func (hp HostPort) Validate() error

+ type HostPortPair struct

+ Dst HostPort

+ Src HostPort

+ func ParseHostPortPair(val string) (HostPortPair, error)

+ func (p HostPortPair) String() string

+ func (p HostPortPair) Validate() error

+ type ListenerConfig struct

+ Address string

+ KeepAliveConfig net.KeepAliveConfig

+ ProxyProtocolConfig *ProxyProtocolConfig

+ ReadLimit SizeSuffix

+ TrackTraffic bool

+ WriteLimit SizeSuffix

+ func DefaultListenerConfig(addr string) *ListenerConfig

type MITMConfig

+ CacheSize uint32

+ CacheTTL time.Duration

+ type MultiListener struct

+ ListenerConfigs []NamedListenerConfig

+ TLSConfig func(NamedListenerConfig) *tls.Config

+ func (ml MultiListener) Listen() (_ []net.Listener, ferr error)

+ type NamedListenerConfig struct

+ Name string

+ type ProxyProtocolConfig struct

+ ReadHeaderTimeout time.Duration

+ func DefaultProxyProtocolConfig() *ProxyProtocolConfig

type TLSClientConfig

+ Insecure bool

Aug 5, 2024

Changes in this version

+ const APIUnixSocket

type TLSClientConfig

+ KeyLogFile string

Jun 11, 2024

Changes in this version

type HTTPProxyConfig

+ PromHTTPOpts []middleware.PrometheusOpt

Mar 27, 2024

Changes in this version

+ type MatchFunc func(string) bool

+ func (m MatchFunc) Match(s string) bool

+ type Matcher interface

+ Match func(string) bool

Mar 4, 2024

Changes in this version

+ var ErrProxyAuthentication = errors.New("proxy authentication required")

type HTTPProxyConfig

+ ConnectTimeout time.Duration

type HTTPServerConfig

+ IdleTimeout time.Duration

+ type Listener struct

+ Address string

+ Log log.Logger

+ ReadLimit int64

+ TLSConfig *tls.Config

+ TLSHandshakeTimeout time.Duration

+ WriteLimit int64

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

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

+ func (l *Listener) Close() error

+ func (l *Listener) Listen() error

+ type PromConfig struct

+ PromNamespace string

+ PromRegistry prometheus.Registerer

type TLSClientConfig

+ func DefaultTLSClientConfig() *TLSClientConfig

type TLSServerConfig

+ HandshakeTimeout time.Duration

+ type TrackedConn struct

+ OnClose func()

+ TrackTraffic bool

+ func (c *TrackedConn) Close() error

+ func (c *TrackedConn) Read(p []byte) (int, error)

+ func (c *TrackedConn) Rx() uint64

+ func (c *TrackedConn) Tx() uint64

+ func (c *TrackedConn) Write(p []byte) (int, error)

Jan 2, 2024

Changes in this version

+ func Listen(network, address string) (net.Listener, error)

Nov 27, 2023

Changes in this version

+ const SizeSuffixMax

+ const SizeSuffixMaxValue

+ const SizeSuffixMinValue

+ var ErrConnectFallback = martian.ErrConnectFallback

+ func NewHTTPProxyHandler(cfg *HTTPProxyConfig, pr PACResolver, cm *CredentialsMatcher, ...) (http.Handler, error)

+ func ParsePrometheusNamespace(val string) (string, error)

+ func ParseUserinfo(val string) (*url.Userinfo, error)

+ func UnmarshalJSONFlag(in []byte, x interface{ ... }, setInt func(int64) error) error

+ type APIEndpoint struct

+ Handler http.Handler

+ Path string

+ type ConnectFunc = martian.ConnectFunc

type HTTPProxy

+ func (hp *HTTPProxy) Close() error

+ func (hp *HTTPProxy) MITMCACert() *x509.Certificate

type HTTPProxyConfig

+ ConnectFunc ConnectFunc

+ ConnectRequestModifier func(*http.Request) error

+ DirectDomains *ruleset.RegexpMatcher

+ MITMDomains *ruleset.RegexpMatcher

+ ReadLimit SizeSuffix

+ RequestIDHeader string

+ WriteLimit SizeSuffix

type HTTPServer

+ func (hs *HTTPServer) Close() error

type HostPortUser

+ func (hpu *HostPortUser) String() string

+ type RequestModifier = martian.RequestModifier

+ type RequestModifierFunc = martian.RequestModifierFunc

+ type RequestResponseModifier = martian.RequestResponseModifier

+ type ResponseModifier = martian.ResponseModifier

+ type ResponseModifierFunc = martian.ResponseModifierFunc

+ type SizeSuffix int64

+ const Exbi

+ const Gibi

+ const Kibi

+ const Mebi

+ const Pebi

+ const SizeSuffixBase

+ const Tebi

+ func (x *SizeSuffix) Scan(s fmt.ScanState, ch rune) error

+ func (x *SizeSuffix) Set(s string) error

+ func (x *SizeSuffix) Type() string

+ func (x *SizeSuffix) UnmarshalJSON(in []byte) error

+ func (x SizeSuffix) BitRateUnit() string

+ func (x SizeSuffix) BitUnit() string

+ func (x SizeSuffix) ByteRateUnit() string

+ func (x SizeSuffix) ByteUnit() string

+ func (x SizeSuffix) String() string

+ type SizeSuffixList []SizeSuffix

+ func (l SizeSuffixList) Len() int

+ func (l SizeSuffixList) Less(i, j int) bool

+ func (l SizeSuffixList) Sort()

+ func (l SizeSuffixList) Swap(i, j int)

Aug 29, 2023

Changes in this version

+ var ErrProxyDenied = denyError

+ func ReadFileOrBase64(name string) ([]byte, error)

+ func ReadURLString(u *url.URL, rt http.RoundTripper) (string, error)

+ type DialConfig struct

+ DialTimeout time.Duration

+ KeepAlive time.Duration

+ func DefaultDialConfig() *DialConfig

+ type Dialer struct

+ func NewDialer(cfg *DialConfig) (*Dialer, error)

+ func (d *Dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

type HTTPProxyConfig

+ DenyDomains []*regexp.Regexp

+ DenyDomainsExclude []*regexp.Regexp

+ MITM *MITMConfig

+ Name string

+ type MITMConfig struct

+ CACertFile string

+ CAKeyFile string

+ Organization string

+ Validity time.Duration

+ func DefaultMITMConfig() *MITMConfig

+ type TLSClientConfig struct

+ CACertFiles []string

+ HandshakeTimeout time.Duration

+ InsecureSkipVerify bool

+ func (c *TLSClientConfig) ConfigureTLSConfig(tlsCfg *tls.Config) error

+ type TLSServerConfig struct

+ CertFile string

+ KeyFile string

+ func (c *TLSServerConfig) ConfigureTLSConfig(tlsCfg *tls.Config) error

Jul 17, 2023

Changes in this version

type HTTPProxy

+ func (hp *HTTPProxy) ProxyFunc() ProxyFunc

May 11, 2023

Changes in this version

+ func LoadCertificateFromTLSConfig(dst *tls.Config, src *TLSConfig) error

type TLSConfig

+ CertFile string

+ KeyFile string

Mar 27, 2023

Changes in this version

+ const ErrorHeader

+ var ErrProxyLocalhost = denyError

+ func NewHTTPTransport(cfg *HTTPTransportConfig, r *net.Resolver) *http.Transport

+ func NewResolver(cfg *DNSConfig, log log.Logger) (*net.Resolver, error)

+ func OpenFileParser(flag int, perm, dirPerm os.FileMode) func(val string) (*os.File, error)

+ func ParseDNSAddress(val string) (netip.AddrPort, error)

+ func ParseProxyURL(val string) (*url.URL, error)

+ func ParseUserInfo(val string) (*url.Userinfo, error)

+ func ReadURL(u *url.URL, rt http.RoundTripper) (string, error)

+ func RedactHostPortUser(hpu *HostPortUser) string

+ type APIHandler struct

+ func NewAPIHandler(r prometheus.Gatherer, ready func() bool, config, pac string) *APIHandler

+ func (h *APIHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type CredentialsMatcher struct

+ func NewCredentialsMatcher(credentials []*HostPortUser, log log.Logger) (*CredentialsMatcher, error)

+ func (m *CredentialsMatcher) Match(hostport string) *url.Userinfo

+ func (m *CredentialsMatcher) MatchURL(u *url.URL) *url.Userinfo

+ type DNSConfig struct

+ Servers []netip.AddrPort

+ Timeout time.Duration

+ func DefaultDNSConfig() *DNSConfig

+ func (c *DNSConfig) Validate() error

+ type HTTPProxy struct

+ Listener net.Listener

+ TLSConfig *tls.Config

+ func NewHTTPProxy(cfg *HTTPProxyConfig, pr PACResolver, cm *CredentialsMatcher, ...) (*HTTPProxy, error)

+ func (hp *HTTPProxy) Addr() string

+ func (hp *HTTPProxy) Handler() http.Handler

+ func (hp *HTTPProxy) Ready() bool

+ func (hp *HTTPProxy) Run(ctx context.Context) error

+ type HTTPProxyConfig struct

+ CloseAfterReply bool

+ ConnectPassthrough bool

+ ProxyLocalhost ProxyLocalhostMode

+ RequestModifiers []martian.RequestModifier

+ ResponseModifiers []martian.ResponseModifier

+ TestingHTTPHandler bool

+ UpstreamProxy *url.URL

+ UpstreamProxyFunc ProxyFunc

+ func DefaultHTTPProxyConfig() *HTTPProxyConfig

+ func (c *HTTPProxyConfig) Validate() error

+ type HTTPServer struct

+ Listener net.Listener

+ func NewHTTPServer(cfg *HTTPServerConfig, h http.Handler, log log.Logger) (*HTTPServer, error)

+ func (hs *HTTPServer) Addr() string

+ func (hs *HTTPServer) Ready() bool

+ func (hs *HTTPServer) Run(ctx context.Context) error

+ type HTTPServerConfig struct

+ Addr string

+ BasicAuth *url.Userinfo

+ LogHTTPMode httplog.Mode

+ PromNamespace string

+ PromRegistry prometheus.Registerer

+ Protocol Scheme

+ ReadHeaderTimeout time.Duration

+ ReadTimeout time.Duration

+ TLSCertFile string

+ TLSKeyFile string

+ WriteTimeout time.Duration

+ func DefaultHTTPServerConfig() *HTTPServerConfig

+ func (c *HTTPServerConfig) Validate() error

+ type HTTPTransportConfig struct

+ DialTimeout time.Duration

+ ExpectContinueTimeout time.Duration

+ IdleConnTimeout time.Duration

+ KeepAlive time.Duration

+ MaxConnsPerHost int

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ ResponseHeaderTimeout time.Duration

+ TLSHandshakeTimeout time.Duration

+ func DefaultHTTPTransportConfig() *HTTPTransportConfig

+ type HostPortUser struct

+ Host string

+ Port string

+ func ParseHostPortUser(val string) (*HostPortUser, error)

+ func (hpu *HostPortUser) Validate() error

+ type LoggingPACResolver struct

+ Logger log.Logger

+ Resolver PACResolver

+ func (r *LoggingPACResolver) FindProxyForURL(u *url.URL, hostname string) (string, error)

+ type PACResolver interface

+ FindProxyForURL func(url *url.URL, hostname string) (string, error)

+ type ProxyFunc func(*http.Request) (*url.URL, error)

+ type ProxyLocalhostMode string

+ const AllowProxyLocalhost

+ const DenyProxyLocalhost

+ const DirectProxyLocalhost

+ func (m *ProxyLocalhostMode) UnmarshalText(text []byte) error

+ func (m ProxyLocalhostMode) String() string

+ type Scheme string

+ const HTTP2Scheme

+ const HTTPSScheme

+ const HTTPScheme

+ const TunnelScheme

+ func (s Scheme) String() string

+ type TLSConfig struct

+ InsecureSkipVerify bool