feat(main): delete udp feature (labring#51)

j4ckzh0u · Jan 20, 2022 · 297bb45 · 297bb45
1 parent 33f631b
commit 297bb45
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 40 deletions.
diff --git a/api/network/v1beta1/types.go b/api/network/v1beta1/types.go
diff --git a/api/network/v1beta1/zz_generated.deepcopy.go b/api/network/v1beta1/zz_generated.deepcopy.go
diff --git a/config/charts/endpoints-operator/crds/sealyun.com_clusterendpoints.yaml b/config/charts/endpoints-operator/crds/sealyun.com_clusterendpoints.yaml
@@ -156,15 +156,6 @@ spec:
                         https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes'
                       format: int32
                       type: integer
-                    udpSocket:
-                      description: UDPSocket specifies an action involving a UDP port.
-                        UDP hooks not yet supported
-                      properties:
-                        enable:
-                          type: boolean
-                      required:
-                      - enable
-                      type: object
                   required:
                   - port
                   - targetPort

diff --git a/config/crd/sealyun.com_clusterendpoints.yaml b/config/crd/sealyun.com_clusterendpoints.yaml
@@ -156,15 +156,6 @@ spec:
                         https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes'
                       format: int32
                       type: integer
-                    udpSocket:
-                      description: UDPSocket specifies an action involving a UDP port.
-                        UDP hooks not yet supported
-                      properties:
-                        enable:
-                          type: boolean
-                      required:
-                      - enable
-                      type: object
                   required:
                   - port
                   - targetPort

diff --git a/controllers/sync.go b/controllers/sync.go
@@ -174,12 +174,6 @@ func healthyCheck(host string, cep *v1beta1.ClusterEndpoint) ([]v1beta1.ServiceP
 					HTTPHeaders: port.HTTPGet.HTTPHeaders,
 				}
 			}
-			if port.UDPSocket != nil && port.UDPSocket.Enable {
-				pro.TCPSocket = &libv1.TCPSocketAction{
-					Port: intstr.FromInt(int(port.TargetPort)),
-					Host: host,
-				}
-			}
 			network := ""
 			if port.TCPSocket != nil && port.TCPSocket.Enable {
 				network = "tcp"
@@ -188,13 +182,6 @@ func healthyCheck(host string, cep *v1beta1.ClusterEndpoint) ([]v1beta1.ServiceP
 					Host: host,
 				}
 			}
-			if port.UDPSocket != nil && port.UDPSocket.Enable {
-				network = "udp"
-				pro.TCPSocket = &libv1.TCPSocketAction{
-					Port: intstr.FromInt(int(port.TargetPort)),
-					Host: host,
-				}
-			}
 			w := &work{p: pro, network: network}
 			for w.doProbe() {
 			}