be83c11fb0
Signed-off-by: Daniel Nephin <dnephin@docker.com> Upstream-commit: 4f0d95fa6ee7f865597c03b9e63702cdcb0f7067 Component: engine
37 lines
937 B
Go
37 lines
937 B
Go
package transport // import "github.com/docker/docker/pkg/plugins/transport"
|
|
|
|
import (
|
|
"io"
|
|
"net/http"
|
|
"strings"
|
|
)
|
|
|
|
// VersionMimetype is the Content-Type the engine sends to plugins.
|
|
const VersionMimetype = "application/vnd.docker.plugins.v1.2+json"
|
|
|
|
// RequestFactory defines an interface that
|
|
// transports can implement to create new requests.
|
|
type RequestFactory interface {
|
|
NewRequest(path string, data io.Reader) (*http.Request, error)
|
|
}
|
|
|
|
// Transport defines an interface that plugin transports
|
|
// must implement.
|
|
type Transport interface {
|
|
http.RoundTripper
|
|
RequestFactory
|
|
}
|
|
|
|
// newHTTPRequest creates a new request with a path and a body.
|
|
func newHTTPRequest(path string, data io.Reader) (*http.Request, error) {
|
|
if !strings.HasPrefix(path, "/") {
|
|
path = "/" + path
|
|
}
|
|
req, err := http.NewRequest("POST", path, data)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
req.Header.Add("Accept", VersionMimetype)
|
|
return req, nil
|
|
}
|