backend_http_pipe.go

package proxy

import (
	"net/http"

	"github.com/Sirupsen/logrus"
)

func NewHTTPPipe(rw http.ResponseWriter, backend backendProxy, hostKey string) (*BackendHTTPReader, *BackendHTTPWriter, error) {
	msgKey, respChannel, err := backend.initializeClient(hostKey)
	if err != nil {
		return nil, nil, err
	}

	logrus.Debugf("BACKEND PIPE %s %s", hostKey, msgKey)

	if err = backend.connect(hostKey, msgKey, "/v1/container-proxy/"); err != nil {
		backend.closeConnection(hostKey, msgKey)
		return nil, nil, err
	}

	return NewBackendHTTPReader(rw, hostKey, msgKey, backend, respChannel), &BackendHTTPWriter{
		hostKey: hostKey,
		msgKey:  msgKey,
		backend: backend,
	}, nil
}