util

Documentation

Index

• Variables
• func NewHTTPTransport(v1 http.RoundTripper, v2 http.RoundTripper) http.RoundTripper
• func NewRetryRoundTripper(rt http.RoundTripper, l *zap.SugaredLogger, b wait.Backoff, ...) http.RoundTripper
• func NewRewinder(rc io.ReadCloser) io.ReadCloser
• func SetupHeaderPruning(p *httputil.ReverseProxy)
• type RetryCond
  • func RetryStatus(status int) RetryCond
• type RoundTripperFunc
  • func (rt RoundTripperFunc) RoundTrip(r *http.Request) (*http.Response, error)

Variables

var AutoTransport = NewHTTPTransport(http.DefaultTransport, h2cutil.DefaultTransport)

AutoTransport uses h2c for HTTP2 requests and falls back to `http.DefaultTransport` for all others

Functions

func NewHTTPTransport

func NewHTTPTransport(v1 http.RoundTripper, v2 http.RoundTripper) http.RoundTripper

NewHttpTransport will use the appropriate transport for the request's HTTP protocol version

func NewRetryRoundTripper

func NewRetryRoundTripper(rt http.RoundTripper, l *zap.SugaredLogger, b wait.Backoff, conditions ...RetryCond) http.RoundTripper

RetryRoundTripper retries a request on error or retry condition, using the given `retry` strategy

func NewRewinder

func NewRewinder(rc io.ReadCloser) io.ReadCloser

rewinder wraps a single-use `ReadCloser` into a `ReadCloser` that can be read multiple times

func SetupHeaderPruning

func SetupHeaderPruning(p *httputil.ReverseProxy)

SetupHeaderPruning will cause the http.ReverseProxy to not forward activator headers

Types

type RetryCond

type RetryCond func(*http.Response) bool

func RetryStatus

func RetryStatus(status int) RetryCond

RetryStatus will filter responses matching `status`

type RoundTripperFunc

type RoundTripperFunc func(*http.Request) (*http.Response, error)

func (RoundTripperFunc) RoundTrip

func (rt RoundTripperFunc) RoundTrip(r *http.Request) (*http.Response, error)