transport

type ErrMissingWorker struct {
	WorkerName string
}

type ErrWorkerAddrIsMissing struct {
	WorkerName string
}

type ErrWorkerBaggageclaimURLIsMissing struct {
	WorkerName string
}

type ErrWorkerStalled struct {
	WorkerName string
}

type ReadCloser interface {
	Read(p []byte) (n int, err error)
	Close() error
}

type RequestGenerator interface {
	CreateRequest(name string, params rata.Params, body io.Reader) (*http.Request, error)
}

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

type StalledWorkerRetryer struct {
	DelegateRetryer retryhttp.Retryer
}

type TransportDB interface {
	GetWorker(name string) (*dbng.Worker, bool, error)
}

type WorkerHijackStreamer struct {
	HttpClient       *http.Client
	HijackableClient retryhttp.HijackableClient
	Req              RequestGenerator
}