transport

type ErrMissingWorker 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 TransportDB interface {
	GetWorker(string) (db.SavedWorker, bool, error)
}

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