retryhttp

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

type BackOffFactory interface {
	NewBackOff() BackOff
	WithMaxElapsedTime() backoff.RetryOption
}

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

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 struct{}

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

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

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

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

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

type RetryReadCloser struct {
	io.ReadCloser
	IsRead bool
}

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

type Retryer interface {
	IsRetryable(err error) bool
}

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

type Sleeper interface {
	Sleep(time.Duration)
}