proxy

Documentation

Index

• Constants
• type Config
  • func (c *Config) Apply(ctx context.Context, p *HTTPProxy) error
• type Director
• type DirectorChain
  • func NewDirectorChain(directors ...Director) DirectorChain
  • func (c DirectorChain) Director(request *http.Request) error
• type DirectorDestMap
  • func NewDirectorDestMap(m map[string]string) DirectorDestMap
  • func (d DirectorDestMap) Director(request *http.Request) error
• type DirectorHost
  • func NewDirectorHost(host string) DirectorHost
  • func (d DirectorHost) Director(request *http.Request) error
• type DirectorSameIP
  • func NewDirectorSameIP(port int) DirectorSameIP
  • func (s DirectorSameIP) Director(request *http.Request) error
• type DirectorSetHeaders
  • func NewDirectorSetHeaders(m map[string]string) DirectorSetHeaders
  • func (h DirectorSetHeaders) Director(request *http.Request) error
• type DirectorSetHeadersByIP
  • func NewDirectorSetHeadersByIP(m map[string]HTTPHeaders) (DirectorSetHeadersByIP, error)
  • func (h DirectorSetHeadersByIP) Director(request *http.Request) error
• type DirectorSetScheme
  • func NewSetSchemeDirector(scheme string) DirectorSetScheme
  • func (d DirectorSetScheme) Director(req *http.Request) error
• type HTTPHeader
• type HTTPHeaders
• type HTTPProxy
  • func NewHTTPProxy(ctx context.Context, listener net.Listener) *HTTPProxy
  • func (p *HTTPProxy) Close() error
  • func (p *HTTPProxy) Start() error
• type IPHeaders
• type Net
  • func (n Net) Network() net.IPNet
• type RateLimitParams
• type RateLimiter
  • func NewRateLimiter(params RateLimitParams) (*RateLimiter, error)
  • func (rl *RateLimiter) Allow(r *http.Request) bool
• type Transport
  • func (t Transport) RoundTrip(req *http.Request) (*http.Response, error)
• type TransportLogger
  • func NewTransportLogger(transport http.RoundTripper) TransportLogger
  • func (t TransportLogger) RoundTrip(request *http.Request) (resp *http.Response, err error)

Constants

const (
	ConnectionID = "{{CONNECTION_ID}}"
	HTTPProto    = "{{HTTP_PROTO}}"
	SourceIP     = "{{SOURCE_IP}}"
	SourcePort   = "{{SOURCE_PORT}}"
	SourceIPPort = "{{SOURCE_IP}}:{{SOURCE_PORT}}"
)

const (
	ProtocolHTTP  = "http"
	ProtocolHTTPS = "https"
)

Types

type Config

type Config struct {
	DefaultTarget           string
	TargetMap               []string
	Headers                 []string
	HeadersByIP             map[string][]string
	KeepAliveTimeoutSeconds int
	HTTPSBackend            bool
	HTTPSBackendIgnoreCert  bool
	EnableAccessLog         bool
	RateLimit               int
	RateLimitTimeWindowMs   int
	RateLimitBurst          int
	RateLimitCacheSize      int
}

func (*Config) Apply

func (c *Config) Apply(ctx context.Context, p *HTTPProxy) error

type Director

type Director interface {
	Director(request *http.Request) error
}

type DirectorChain

type DirectorChain []Director

func NewDirectorChain

func NewDirectorChain(directors ...Director) DirectorChain

skip nil directors

func (DirectorChain) Director

func (c DirectorChain) Director(request *http.Request) error

type DirectorDestMap

type DirectorDestMap map[string]string

func NewDirectorDestMap

func NewDirectorDestMap(m map[string]string) DirectorDestMap

func (DirectorDestMap) Director

func (d DirectorDestMap) Director(request *http.Request) error

type DirectorHost

type DirectorHost string

func NewDirectorHost

func NewDirectorHost(host string) DirectorHost

func (DirectorHost) Director

func (d DirectorHost) Director(request *http.Request) error

type DirectorSameIP

type DirectorSameIP struct {
	Port string
}

func NewDirectorSameIP

func NewDirectorSameIP(port int) DirectorSameIP

func (DirectorSameIP) Director

func (s DirectorSameIP) Director(request *http.Request) error

type DirectorSetHeaders

type DirectorSetHeaders map[string]string

func NewDirectorSetHeaders

func NewDirectorSetHeaders(m map[string]string) DirectorSetHeaders

func (DirectorSetHeaders) Director

func (h DirectorSetHeaders) Director(request *http.Request) error

type DirectorSetHeadersByIP

type DirectorSetHeadersByIP struct {
	cidranger.Ranger[HTTPHeaders]
	// contains filtered or unexported fields
}

func NewDirectorSetHeadersByIP

func NewDirectorSetHeadersByIP(m map[string]HTTPHeaders) (DirectorSetHeadersByIP, error)

func (DirectorSetHeadersByIP) Director

func (h DirectorSetHeadersByIP) Director(request *http.Request) error

type DirectorSetScheme

type DirectorSetScheme string

func NewSetSchemeDirector

func NewSetSchemeDirector(scheme string) DirectorSetScheme

func (DirectorSetScheme) Director

func (d DirectorSetScheme) Director(req *http.Request) error

type HTTPHeader

type HTTPHeader struct {
	Name  string
	Value string
}

type HTTPHeaders

type HTTPHeaders []HTTPHeader

type HTTPProxy

type HTTPProxy struct {
	GetContext           func(req *http.Request) (context.Context, error)
	HandleHTTPValidation func(w http.ResponseWriter, r *http.Request) bool
	Director             Director // modify requests to backend.
	HTTPTransport        http.RoundTripper
	EnableAccessLog      bool

	IdleTimeout time.Duration
	// contains filtered or unexported fields
}

func NewHTTPProxy

func NewHTTPProxy(ctx context.Context, listener net.Listener) *HTTPProxy

func (*HTTPProxy) Close

func (p *HTTPProxy) Close() error

func (*HTTPProxy) Start

func (p *HTTPProxy) Start() error

Start - finish initialization of proxy and start handling request. It is sync method, always return with non nil error: if handle stopped by context or if error on start handling. Any public fields must not change after Start called

type IPHeaders

type IPHeaders struct {
	Headers map[string]string
	IP      string
}

type Net

type Net struct {
	net.IPNet
}

func (Net) Network

func (n Net) Network() net.IPNet

type RateLimitParams

type RateLimitParams struct {
	RateLimit  int
	TimeWindow time.Duration
	Burst      int
	CacheSize  int
	Clock      clockwork.Clock
}

type RateLimiter

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

func NewRateLimiter

func NewRateLimiter(params RateLimitParams) (*RateLimiter, error)

func (*RateLimiter) Allow

func (rl *RateLimiter) Allow(r *http.Request) bool

type Transport

type Transport struct {
	IgnoreHTTPSCertificate bool
	RateLimiter            *RateLimiter
}

func (Transport) RoundTrip

func (t Transport) RoundTrip(req *http.Request) (*http.Response, error)

type TransportLogger

type TransportLogger struct {
	Transport http.RoundTripper
}

func NewTransportLogger

func NewTransportLogger(transport http.RoundTripper) TransportLogger

func (TransportLogger) RoundTrip

func (t TransportLogger) RoundTrip(request *http.Request) (resp *http.Response, err error)