upstream

Documentation

Index

• Variables
• 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 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