Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proxy

package

Go to main page

Versions in this module

v1

v1.4.3

Sep 12, 2021

Changes in this version

type Middleware

+ func NewBackendPluginMiddleware(remote *config.Backend) Middleware

+ func NewFlatmapMiddleware(cfg *config.EndpointConfig) Middleware

+ func NewLoadBalancedMiddleware(remote *config.Backend) Middleware

+ func NewLoadBalancedMiddlewareWithSubscriber(subscriber sd.Subscriber) Middleware

+ func NewPluginMiddleware(endpoint *config.EndpointConfig) Middleware

+ type RequestWrapper interface

+ Body func() io.ReadCloser

+ Headers func() map[string][]string

+ Method func() string

+ Params func() map[string]string

+ Path func() string

+ Query func() url.Values

+ URL func() *url.URL

+ type ResponseMetadataWrapper interface

+ Headers func() map[string][]string

+ StatusCode func() int

+ type ResponseWrapper interface

+ Data func() map[string]interface{}

+ Io func() io.Reader

+ IsComplete func() bool

+ Metadata func() ResponseMetadataWrapper

v0

v0.9.0

Apr 4, 2019

Changes in this version

+ const Namespace

+ var DefaultHTTPResponseParserConfig = HTTPResponseParserConfig

+ var ErrNoBackends = errors.New("all endpoints must have at least one backend")

+ var ErrNotEnoughProxies = errors.New("not enough proxies for this endpoint")

+ var ErrTooManyBackends = errors.New("too many backends for this proxy")

+ var ErrTooManyProxies = errors.New("too many proxies for this proxy middleware")

+ func CloneRequestHeaders(headers map[string][]string) map[string][]string

+ func CloneRequestParams(params map[string]string) map[string]string

+ func NewReadCloserWrapper(ctx context.Context, in io.ReadCloser) io.Reader

+ func RegisterResponseCombiner(name string, f ResponseCombiner)

+ type BackendFactory func(remote *config.Backend) Proxy

+ func CustomHTTPProxyFactory(cf client.HTTPClientFactory) BackendFactory

+ func HTTPProxyFactory(client *http.Client) BackendFactory

+ type EntityFormatter interface

+ Format func(Response) Response

+ func NewEntityFormatter(remote *config.Backend) EntityFormatter

+ type EntityFormatterFunc func(Response) Response

+ func (e EntityFormatterFunc) Format(entity Response) Response

+ type Factory interface

+ New func(cfg *config.EndpointConfig) (Proxy, error)

+ func DefaultFactory(logger logging.Logger) Factory

+ func DefaultFactoryWithSubscriber(logger logging.Logger, sF sd.SubscriberFactory) Factory

+ func NewDefaultFactory(backendFactory BackendFactory, logger logging.Logger) Factory

+ func NewDefaultFactoryWithSubscriber(backendFactory BackendFactory, logger logging.Logger, sF sd.SubscriberFactory) Factory

+ func NewShadowFactory(f Factory) Factory

+ type FactoryFunc func(*config.EndpointConfig) (Proxy, error)

+ func (f FactoryFunc) New(cfg *config.EndpointConfig) (Proxy, error)

+ type HTTPResponseParser func(context.Context, *http.Response) (*Response, error)

+ func DefaultHTTPResponseParserFactory(cfg HTTPResponseParserConfig) HTTPResponseParser

+ type HTTPResponseParserConfig struct

+ Decoder encoding.Decoder

+ EntityFormatter EntityFormatter

+ type HTTPResponseParserFactory func(HTTPResponseParserConfig) HTTPResponseParser

+ type Metadata struct

+ Headers map[string][]string

+ StatusCode int

+ type Middleware func(next ...Proxy) Proxy

+ func NewConcurrentMiddleware(remote *config.Backend) Middleware

+ func NewLoggingMiddleware(logger logging.Logger, name string) Middleware

+ func NewMergeDataMiddleware(endpointConfig *config.EndpointConfig) Middleware

+ func NewRandomLoadBalancedMiddleware(remote *config.Backend) Middleware

+ func NewRandomLoadBalancedMiddlewareWithSubscriber(subscriber sd.Subscriber) Middleware

+ func NewRequestBuilderMiddleware(remote *config.Backend) Middleware

+ func NewRoundRobinLoadBalancedMiddleware(remote *config.Backend) Middleware

+ func NewRoundRobinLoadBalancedMiddlewareWithSubscriber(subscriber sd.Subscriber) Middleware

+ func NewStaticMiddleware(endpointConfig *config.EndpointConfig) Middleware

+ type Proxy func(ctx context.Context, request *Request) (*Response, error)

+ func EmptyMiddleware(next ...Proxy) Proxy

+ func NewHTTPProxy(remote *config.Backend, cf client.HTTPClientFactory, decode encoding.Decoder) Proxy

+ func NewHTTPProxyDetailed(remote *config.Backend, re client.HTTPRequestExecutor, ...) Proxy

+ func NewHTTPProxyWithHTTPExecutor(remote *config.Backend, re client.HTTPRequestExecutor, dec encoding.Decoder) Proxy

+ func NewShadowProxy(p1, p2 Proxy) Proxy

+ func ShadowMiddleware(next ...Proxy) Proxy

+ type Register struct

+ func NewRegister() *Register

+ func (r Register) GetResponseCombiner(name string) (ResponseCombiner, bool)

+ func (r Register) SetResponseCombiner(name string, rc ResponseCombiner)

+ type Request struct

+ Body io.ReadCloser

+ Headers map[string][]string

+ Method string

+ Params map[string]string

+ Path string

+ Query url.Values

+ URL *url.URL

+ func CloneRequest(r *Request) *Request

+ func (r *Request) Clone() Request

+ func (r *Request) GeneratePath(URLPattern string)

+ type Response struct

+ Data map[string]interface{}

+ Io io.Reader

+ IsComplete bool

+ Metadata Metadata

+ func NoOpHTTPResponseParser(ctx context.Context, resp *http.Response) (*Response, error)

+ func NoopProxy(_ context.Context, _ *Request) (*Response, error)

+ type ResponseCombiner func(int, []*Response) *Response