BUG/MINOR: ci: embedding proxy-protocol image

Signed-off-by: Dario Tranchitella <[email protected]>

Author: prometherion

.gitlab-ci.yml

@@ -175,6 +175,8 @@ docker-build:
     #- docker image tag $CI_REGISTRY_GO/golang:$GO_VERSION-alpine golang:$GO_VERSION-alpine
     - docker pull -q $CI_REGISTRY_GO/haproxytech/http-echo:latest
     - docker image tag $CI_REGISTRY_GO/haproxytech/http-echo:latest haproxytech/http-echo:latest
+    - docker pull -q $CI_REGISTRY_GO/haproxytech/proxy-protocol:latest
+    - docker image tag $CI_REGISTRY_GO/haproxytech/proxy-protocol:latest haproxytech/proxy-protocol:latest
     - wget -nv -O /usr/local/bin/kind https://github.com/kubernetes-sigs/kind/releases/download/${KIND}/kind-linux-amd64
     - chmod +x /usr/local/bin/kind
     - wget -nv -O /usr/local/bin/kubectl https://storage.googleapis.com/kubernetes-release/release/${KUBECTL}/bin/linux/amd64/kubectl

deploy/tests/create.sh

@@ -40,11 +40,15 @@ fi
 printf %80s |tr " " "="; echo ""
 if [ -n "${GITLAB_CI}" ]; then
   echo "haproxytech/http-echo:latest pulled from CI registry"
+  echo "haproxytech/proxy-protocol:latest pulled from CI registry"
 else
   docker build --build-arg TARGETPLATFORM="linux/amd64" -t haproxytech/http-echo -f deploy/tests/images/http-echo/Dockerfile deploy/tests/images/http-echo
+  docker build --build-arg TARGETPLATFORM="linux/amd64" -t haproxytech/proxy-protocol -f deploy/tests/images/proxy-protocol/Dockerfile deploy/tests/images/proxy-protocol
 fi
 echo "loading image http-echo in kind"
-kind load docker-image haproxytech/http-echo:latest  --name=$clustername
+kind load docker-image haproxytech/http-echo:latest --name=$clustername
+echo "loading image proxy-protocol in kind"
+kind load docker-image haproxytech/proxy-protocol:latest --name=$clustername
 
 printf %80s |tr " " "="; echo ""
 echo "Create HAProxy namespace ..."

deploy/tests/e2e/send-proxy-protocol/config/deploy.yaml.tmpl

@@ -14,7 +14,8 @@ spec:
     spec:
       containers:
         - name: http-echo
-          image: 'quay.io/prometherion/proxy-protocol-app:latest'
+          image: 'haproxytech/proxy-protocol:latest'
+          imagePullPolicy: IfNotPresent
           ports:
             - name: http
               containerPort: 8080

deploy/tests/images/proxy-protocol/Dockerfile

@@ -0,0 +1,14 @@
+FROM golang:1.22-alpine AS builder
+
+COPY *.go /src/
+COPY go.mod /src/go.mod
+COPY go.sum /src/go.sum
+
+RUN cd /src && go build -o proxy-protocol
+
+FROM alpine:3
+WORKDIR /app
+COPY --from=builder /src/proxy-protocol .
+
+ENTRYPOINT ["./proxy-protocol"]
+CMD []

deploy/tests/images/proxy-protocol/README.md

@@ -0,0 +1,21 @@
+# proxy-protocol
+
+A simple Go web server backed by PROXY Protocol.
+
+## How to use
+
+```bash
+    docker build -t haproxytech/proxy-protocol -f deploy/tests/images/proxy-protocol/Dockerfile deploy/tests/images/proxy-protocol
+    docker run -p 8080:8080 --rm -t haproxytech/proxy-protocol
+```
+
+## Output example
+
+```
+$: curl --haproxy-protocol --http1.1 http://localhost:8080/
+hello!
+````
+
+## Credits
+
+[github.com/pires/go-proxyproto](https://github.com/pires/go-proxyproto)

deploy/tests/images/proxy-protocol/go.mod

@@ -0,0 +1,5 @@
+module proxy-protocol
+
+go 1.22.0
+
+require github.com/pires/go-proxyproto v0.8.0

deploy/tests/images/proxy-protocol/go.sum

@@ -0,0 +1,2 @@
+github.com/pires/go-proxyproto v0.8.0 h1:5unRmEAPbHXHuLjDg01CxJWf91cw3lKHc/0xzKpXEe0=
+github.com/pires/go-proxyproto v0.8.0/go.mod h1:iknsfgnH8EkjrMeMyvfKByp9TiBZCKZM0jx2xmKqnVY=

deploy/tests/images/proxy-protocol/main.go

@@ -0,0 +1,38 @@
+package main
+
+import (
+	"fmt"
+	"net"
+	"net/http"
+	"os"
+
+	"github.com/pires/go-proxyproto"
+)
+
+func main() {
+	// Create a TCP listener on port 8080
+	addr := ":8080"
+	tcpListener, err := net.Listen("tcp", addr)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "Error creating TCP listener: %v\n", err)
+		os.Exit(1)
+	}
+
+	// Wrap it with the PROXY protocol listener
+	proxyListener := &proxyproto.Listener{Listener: tcpListener}
+
+	// Ensure the listener is closed on shutdown
+	defer proxyListener.Close()
+
+	// HTTP handler
+	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		fmt.Fprint(w, "hello!")
+	})
+
+	// Serve using custom listener
+	fmt.Printf("Listening on %s with PROXY protocol support...\n", addr)
+	if err := http.Serve(proxyListener, nil); err != nil {
+		fmt.Fprintf(os.Stderr, "HTTP server error: %v\n", err)
+		os.Exit(1)
+	}
+}