44 lines
1.3 KiB
Go
44 lines
1.3 KiB
Go
package proxy
|
|
|
|
import (
|
|
"errors"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"github.com/fsouza/go-dockerclient"
|
|
. "github.com/weaveworks/weave/common"
|
|
)
|
|
|
|
type startContainerInterceptor struct{ proxy *Proxy }
|
|
|
|
func (i *startContainerInterceptor) InterceptRequest(r *http.Request) error {
|
|
return nil
|
|
}
|
|
|
|
func (i *startContainerInterceptor) InterceptResponse(r *http.Response) error {
|
|
if r.StatusCode < 200 || r.StatusCode >= 300 { // Docker didn't do the start
|
|
return nil
|
|
}
|
|
|
|
container, err := inspectContainerInPath(i.proxy.client, r.Request.URL.Path)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
cidrs, err := i.proxy.weaveCIDRsFromConfig(container.Config, container.HostConfig)
|
|
if err != nil {
|
|
Info.Printf("Ignoring container %s due to %s", container.ID, err)
|
|
return nil
|
|
}
|
|
Info.Printf("Attaching container %s with WEAVE_CIDR \"%s\" to weave network", container.ID, strings.Join(cidrs, " "))
|
|
args := []string{"attach"}
|
|
args = append(args, cidrs...)
|
|
args = append(args, "--or-die", container.ID)
|
|
if output, err := callWeave(args...); err != nil {
|
|
Warning.Printf("Attaching container %s to weave network failed: %s", container.ID, string(output))
|
|
return errors.New(string(output))
|
|
}
|
|
|
|
return i.proxy.client.KillContainer(docker.KillContainerOptions{ID: container.ID, Signal: docker.SIGUSR2})
|
|
}
|