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 DirectorSetScheme
  • func NewSetSchemeDirector(scheme string) DirectorSetScheme
  • func (d DirectorSetScheme) Director(req *http.Request) error
• type HTTPProxy
  • func NewHTTPProxy(ctx context.Context, listener net.Listener) *HTTPProxy
  • func (p *HTTPProxy) Close() error
  • func (p *HTTPProxy) Start() error
• 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
	KeepAliveTimeoutSeconds int
	HTTPSBackend            bool
	HTTPSBackendIgnoreCert  bool
	EnableAccessLog         bool
}

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 DirectorSetScheme

type DirectorSetScheme string

func NewSetSchemeDirector

func NewSetSchemeDirector(scheme string) DirectorSetScheme

func (DirectorSetScheme) Director

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

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 Transport

type Transport struct {
	IgnoreHTTPSCertificate bool
}

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)