docker
/
docs
mirror of https://github.com/docker/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Support unix:// URLs in forward 

Signed-off-by: Aanand Prasad <aanand.prasad@gmail.com>
This commit is contained in:
Aanand Prasad 2014-06-07 19:03:03 -07:00
parent dd33da7c47
commit 20c489e752
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
backends/forward.go
View File

@ -229,27 +229,36 @@ func newClient(peer, version string) (*client, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
protoAddrParts := strings.SplitN(peer, "://", 2)
c := &client{ c := &client{
URL: u, URL: u,
proto: protoAddrParts[0],
addr: protoAddrParts[1],
version: version, version: version,
} }
c.URL.Scheme = "http" c.URL.Scheme = "http"
return c, nil return c, nil
} }
func (c *client) dial() (net.Conn, error) {
return net.Dial(c.proto, c.addr)
}
func (c *client) call(method, path, body string) (*http.Response, error) { func (c *client) call(method, path, body string) (*http.Response, error) {
path = fmt.Sprintf("/%s%s", c.version, path) path = fmt.Sprintf("/%s%s", c.version, path)
u, err := url.Parse(path) u, err := url.Parse(path)
if err != nil { if err != nil {
return nil, err return nil, err
} }
u.Host = c.URL.Host u.Host = "dummy.host"
u.Scheme = c.URL.Scheme u.Scheme = c.URL.Scheme
req, err := http.NewRequest(method, u.String(), strings.NewReader(body)) req, err := http.NewRequest(method, u.String(), strings.NewReader(body))
if err != nil { if err != nil {
return nil, err return nil, err
} }
resp, err := http.DefaultClient.Do(req) tr := &http.Transport{Dial: func(_, _ string) (net.Conn, error) { return c.dial() }}
client := &http.Client{Transport: tr}
resp, err := client.Do(req)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -258,7 +267,7 @@ func (c *client) call(method, path, body string) (*http.Response, error) {
func (c *client) hijack(method, path string, in io.ReadCloser, stdout, stderr io.Writer) error { func (c *client) hijack(method, path string, in io.ReadCloser, stdout, stderr io.Writer) error {
path = fmt.Sprintf("/%s%s", c.version, path) path = fmt.Sprintf("/%s%s", c.version, path)
dial, err := net.Dial("tcp", c.URL.Host) dial, err := c.dial()
if err != nil { if err != nil {
return err return err
} }