retryhttp

README

retryhttp

Provides RetryRoundTripper used by Baggageclaim client and ATC garden client.

Retries on network errors, does not retry if request body was already read from (e.g. streaming request)

Documentation

Index

• type BackOff
• type BackOffFactory
  • func NewExponentialBackOffFactory(timeout time.Duration) BackOffFactory
• type BasicHijackableClient
  • func (c *BasicHijackableClient) Do(req *http.Request) (*http.Response, HijackCloser, error)
• type Conn
• type DefaultRetryer
  • func (r *DefaultRetryer) IsRetryable(err error) bool
• type DoHijackCloser
• type DoHijackCloserFactory
• type HijackCloser
• type HijackableClient
• type RetryHijackableClient
  • func (d *RetryHijackableClient) Do(request *http.Request) (*http.Response, HijackCloser, error)
• type RetryReadCloser
  • func (rrc *RetryReadCloser) Read(p []byte) (n int, err error)
• type RetryRoundTripper
  • func (d *RetryRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)
• type Retryer
• type RoundTripper
• type Sleeper

Types

type BackOff

type BackOff interface {
	NextBackOff() time.Duration
	GetElapsedTime() time.Duration
	Reset()
}

type BackOffFactory

type BackOffFactory interface {
	NewBackOff() BackOff
}

func NewExponentialBackOffFactory

func NewExponentialBackOffFactory(timeout time.Duration) BackOffFactory

type BasicHijackableClient

type BasicHijackableClient struct {
	Dial                  func(network, addr string) (net.Conn, error)
	DoHijackCloserFactory DoHijackCloserFactory
}

func (*BasicHijackableClient) Do

func (c *BasicHijackableClient) Do(req *http.Request) (*http.Response, HijackCloser, error)

type Conn

type Conn interface {
	Read(b []byte) (n int, err error)
	Write(b []byte) (n int, err error)
	Close() error
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	SetDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}

type DefaultRetryer

type DefaultRetryer struct{}

func (*DefaultRetryer) IsRetryable

func (r *DefaultRetryer) IsRetryable(err error) bool

type DoHijackCloser

type DoHijackCloser interface {
	Do(req *http.Request) (resp *http.Response, err error)
	Hijack() (c net.Conn, r *bufio.Reader)
	Close() error
}

type DoHijackCloserFactory

type DoHijackCloserFactory interface {
	NewDoHijackCloser(c net.Conn, r *bufio.Reader) DoHijackCloser
}

var DefaultDoHijackCloserFactory DoHijackCloserFactory = defaultDoHijackCloserFactory{}

type HijackCloser

type HijackCloser interface {
	Hijack() (c net.Conn, r *bufio.Reader)
	Close() error
}

type HijackableClient

type HijackableClient interface {
	Do(req *http.Request) (*http.Response, HijackCloser, error)
}

var DefaultHijackableClient HijackableClient = &BasicHijackableClient{
	Dial: (&net.Dialer{
		Timeout:   30 * time.Second,
		KeepAlive: 30 * time.Second,
	}).Dial,
	DoHijackCloserFactory: DefaultDoHijackCloserFactory,
}

type RetryHijackableClient

type RetryHijackableClient struct {
	Logger           lager.Logger
	BackOffFactory   BackOffFactory
	HijackableClient HijackableClient
	Retryer          Retryer
}

func (*RetryHijackableClient) Do

func (d *RetryHijackableClient) Do(request *http.Request) (*http.Response, HijackCloser, error)

type RetryReadCloser

type RetryReadCloser struct {
	io.ReadCloser
	IsRead bool
}

func (*RetryReadCloser) Read

func (rrc *RetryReadCloser) Read(p []byte) (n int, err error)

type RetryRoundTripper

type RetryRoundTripper struct {
	Logger         lager.Logger
	BackOffFactory BackOffFactory
	RoundTripper   RoundTripper
	Retryer        Retryer
}

func (*RetryRoundTripper) RoundTrip

func (d *RetryRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)

type Retryer

type Retryer interface {
	IsRetryable(err error) bool
}

type RoundTripper

type RoundTripper interface {
	RoundTrip(request *http.Request) (*http.Response, error)
}

type Sleeper

type Sleeper interface {
	Sleep(time.Duration)
}