upstream

Documentation

Index

• Variables
• type H2CTransport
  • func (t *H2CTransport) RoundTrip(r *http.Request) (*http.Response, error)
• type HTTPSTransport
  • func (t *HTTPSTransport) RoundTrip(r *http.Request) (*http.Response, error)
• type HTTPTransport
  • func (t *HTTPTransport) RoundTrip(r *http.Request) (*http.Response, error)
• type RoundRobinLoadBalancer
  • func NewRoundRobinLoadBalancer(targets []*Target) *RoundRobinLoadBalancer
  • func (l *RoundRobinLoadBalancer) RoundTrip(r *http.Request) (*http.Response, error)
• type Target
• type Transport
  • func (t *Transport) RoundTrip(r *http.Request) (*http.Response, error)
• type UnixTransport
  • func (t *UnixTransport) RoundTrip(r *http.Request) (*http.Response, error)
• type Upstream
  • func New(transport http.RoundTripper) *Upstream
  • func SingleHost(host string, transport http.RoundTripper) *Upstream
  • func (m *Upstream) RoundTrip(r *http.Request) (*http.Response, error)
  • func (m Upstream) ServeHandler(h http.Handler) http.Handler

Variables

var (
	ErrUnavailable = errors.New("upstream: unavailable")
)

Errors

Types

type H2CTransport

type H2CTransport struct {
	HTTP2Transport *http2.Transport
	HTTPTransport  *http.Transport
	// contains filtered or unexported fields
}

H2CTransport type

func (*H2CTransport) RoundTrip

func (t *H2CTransport) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip implement http.RoundTripper

type HTTPSTransport

type HTTPSTransport struct {
	DialTimeout           time.Duration
	TCPKeepAlive          time.Duration
	DisableKeepAlives     bool
	MaxConn               int
	MaxIdleConns          int
	IdleConnTimeout       time.Duration
	ExpectContinueTimeout time.Duration
	ResponseHeaderTimeout time.Duration
	TLSClientConfig       *tls.Config
	// contains filtered or unexported fields
}

HTTPSTransport type

func (*HTTPSTransport) RoundTrip

func (t *HTTPSTransport) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip implement http.RoundTripper

type HTTPTransport

type HTTPTransport struct {
	DialTimeout           time.Duration
	TCPKeepAlive          time.Duration
	DisableKeepAlives     bool
	MaxConn               int
	MaxIdleConns          int
	IdleConnTimeout       time.Duration
	ExpectContinueTimeout time.Duration
	ResponseHeaderTimeout time.Duration
	// contains filtered or unexported fields
}

HTTPTransport type

func (*HTTPTransport) RoundTrip

func (t *HTTPTransport) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip implement http.RoundTripper

type RoundRobinLoadBalancer

type RoundRobinLoadBalancer struct {
	Targets []*Target
	// contains filtered or unexported fields
}

RoundRobinLoadBalancer strategy

func NewRoundRobinLoadBalancer

func NewRoundRobinLoadBalancer(targets []*Target) *RoundRobinLoadBalancer

NewRoundRobinLoadBalancer creates new round-robin load balancer

func (*RoundRobinLoadBalancer) RoundTrip

func (l *RoundRobinLoadBalancer) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip sends a request to upstream server

type Target

type Target struct {
	Transport http.RoundTripper
	Host      string
}

Target is the load balancer target

type Transport

type Transport struct {
	DialTimeout           time.Duration
	TCPKeepAlive          time.Duration
	DisableKeepAlives     bool
	MaxConn               int
	MaxIdleConns          int
	IdleConnTimeout       time.Duration
	ExpectContinueTimeout time.Duration
	ResponseHeaderTimeout time.Duration
	DisableCompression    bool
	TLSClientConfig       *tls.Config
	// contains filtered or unexported fields
}

Transport does RoundTrip dynamically from request's scheme

func (*Transport) RoundTrip

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

RoundTrip implement http.RoundTripper

type UnixTransport

type UnixTransport struct {
	DisableKeepAlives     bool
	MaxIdleConns          int
	IdleConnTimeout       time.Duration
	ExpectContinueTimeout time.Duration
	ResponseHeaderTimeout time.Duration
	// contains filtered or unexported fields
}

UnixTransport type

func (*UnixTransport) RoundTrip

func (t *UnixTransport) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip implement http.RoundTripper

type Upstream

type Upstream struct {
	Transport     http.RoundTripper
	ErrorLog      *log.Logger
	Host          string // override host
	Path          string // target prefix path
	Retries       int
	BackoffFactor time.Duration
}

Upstream controls request flow to upstream server via load balancer

func New

func New(transport http.RoundTripper) *Upstream

New creates new upstream

func SingleHost

func SingleHost(host string, transport http.RoundTripper) *Upstream

SingleHost creates new single host upstream

func (*Upstream) RoundTrip

func (m *Upstream) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip wraps transport round-trip

func (Upstream) ServeHandler

func (m Upstream) ServeHandler(h http.Handler) http.Handler

ServeHandler implements middleware interface