mumoshu/kube-collocated-pod-proxy

kube-collocated-pod-proxy

https://github.com/mumoshu/kube-collocated-pod-proxy/

镜像概述

kube-collocated-pod-proxy是一个Kubernetes sidecar容器，通过运行Nginx（支持UDP，TCP即将支持）负载均衡器，将流量代理到同一节点上匹配用户指定Pod选择器的Pod。它帮助应用避免硬编码IP/主机名，实现与Kubernetes集群的松耦合连接。

核心功能

1. 动态发现同节点Pod：自动识别运行在同一节点、符合指定选择器的Pod；
2. 生成Nginx配置：根据环境变量动态生成代理配置；
3. TCP/UDP代理：支持UDP代理（TCP功能待添加）；
4. 松耦合连接：应用只需连接localhost:<指定端口>即可访问目标Pod。

使用场景

• 连接同节点的监控代理（如Datadog的dd-agent DaemonSet）；
• 访问同节点的缓存服务（如Redis）；
• 其他需要同节点Pod间通信且避免硬编码地址的场景。

配置说明

通过环境变量配置代理行为：

• PORT：代理监听端口；
• SELECTOR：目标Pod的选择器（如app=dd-agent）；
• PROTOCOL：代理协议（支持udp，TCP即将支持）；
• NAMESPACE：目标Pod所在的命名空间；
• SOURCE_PORT（可选）：源端口，默认与PORT相同；
• TARGET_PORT（可选）：目标Pod端口，默认与PORT相同。

部署示例

连接localhost:8125到同节点的dogstatsd

yaml
apiVersion: v1
kind: Pod
metadata:
  name: myapp
  labels:
    app: web
spec:
  containers:
    - name: myapp
      image: ***-gcr.xuanyuan.run/google_containers/ubuntu-slim:0.4
      command: ["sleep", "9999"]
    - name: collocated-pod-proxy
      image: docker.xuanyuan.run/mumoshu/kube-collocated-pod-proxy:kube-1.3.6
      ports:
        - containerPort: 8125
      env:
      - name: PORT
        value: "8125"
      - name: SELECTOR
        value: "app=dd-agent"
      - name: PROTOCOL
        value: "udp"
      - name: NAMESPACE
        value: "kube-system"

执行部署：kubectl create -f example.pod.yaml

Demo操作步骤

1. 运行测试Pod：

bash
PORT=8125 SELECTOR="app=dd-agent" PROTOCOL=udp make clean build kubectl-run

2. 附加到Pod查看内部流程：

bash
kubectl exec -it collocated-pod-proxy-test sh

3. 测试代理功能（发送Datadog指标）：

bash
apt-get update && apt-get install ruby -y && gem install dogstatsd-ruby && irb -r datadog/statsd
statsd = Datadog::Statsd.new
statsd.increment("test.counter")

4. 验证Nginx代理日志，确认流量转发成功。