refactor: remove RetryPolicy (#411)

Signed-off-by: Lin Yang <[email protected]>

codegen/gen-crd-client.sh

@@ -75,32 +75,32 @@ function generate_client() {
     "${ROOT_DIR}/pkg/apis"
 }
 
-echo "##### Generating config.flomesh.io client ######"
-generate_client "config" "v1alpha1,v1alpha2,v1alpha3"
-
-echo "##### Generating policy.flomesh.io client ######"
-generate_client "policy" "v1alpha1"
-
-echo "##### Generating networking.k8s.io client ######"
-generate_client "networking" "v1"
-
-echo "##### Generating multicluster.flomesh.io client ######"
-generate_client "multicluster" "v1alpha1"
-
-echo "##### Generating flomesh.io plugin client ######"
-generate_client "plugin" "v1alpha1"
-
-echo "##### Generating flomesh.io machine client ######"
-generate_client "machine" "v1alpha1"
-
-echo "##### Generating flomesh.io connector client ######"
-generate_client "connector" "v1alpha1"
-
-echo "##### Generating networking.flomesh.io client ######"
-generate_client "namespacedingress" "v1alpha1"
+#echo "##### Generating config.flomesh.io client ######"
+#generate_client "config" "v1alpha1,v1alpha2,v1alpha3"
+#
+#echo "##### Generating policy.flomesh.io client ######"
+#generate_client "policy" "v1alpha1"
+#
+#echo "##### Generating networking.k8s.io client ######"
+#generate_client "networking" "v1"
+#
+#echo "##### Generating multicluster.flomesh.io client ######"
+#generate_client "multicluster" "v1alpha1"
+#
+#echo "##### Generating flomesh.io plugin client ######"
+#generate_client "plugin" "v1alpha1"
+#
+#echo "##### Generating flomesh.io machine client ######"
+#generate_client "machine" "v1alpha1"
+#
+#echo "##### Generating flomesh.io connector client ######"
+#generate_client "connector" "v1alpha1"
+#
+#echo "##### Generating networking.flomesh.io client ######"
+#generate_client "namespacedingress" "v1alpha1"
 
 echo "##### Generating gateway.flomesh.io PolicyAttachment client ######"
 generate_client "policyattachment" "v1alpha1,v1alpha2"
 
-echo "##### Generating extension.gateway.flomesh.io extension client ######"
-generate_client "extension" "v1alpha1"
+#echo "##### Generating extension.gateway.flomesh.io extension client ######"
+#generate_client "extension" "v1alpha1"

pkg/announcements/types.go

@@ -537,17 +537,6 @@ const (
 
 	// ---
 
-	// RetryPolicyAttachmentAdded is the type of announcement emitted when we observe an addition of retries.gateway.flomesh.io
-	RetryPolicyAttachmentAdded Kind = "retrypolicy-added"
-
-	// RetryPolicyAttachmentDeleted the type of announcement emitted when we observe a deletion of retries.gateway.flomesh.io
-	RetryPolicyAttachmentDeleted Kind = "retrypolicy-deleted"
-
-	// RetryPolicyAttachmentUpdated is the type of announcement emitted when we observe an update to retries.gateway.flomesh.io
-	RetryPolicyAttachmentUpdated Kind = "retrypolicy-updated"
-
-	// ---
-
 	// BackendTLSPolicyAdded is the type of announcement emitted when we observe an addition of backendtlspolicies.gateway.networking.k8s.io
 	BackendTLSPolicyAdded Kind = "backendtlspolicy-added"
 

pkg/controllers/gateway/v1/httproute_controller.go

@@ -141,7 +141,6 @@ func (r *httpRouteReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		Watches(&gwv1alpha3.BackendTLSPolicy{}, handler.EnqueueRequestsFromMapFunc(r.backendTLSToHTTPRoutes)).
 		Watches(&gwpav1alpha2.BackendLBPolicy{}, handler.EnqueueRequestsFromMapFunc(r.backendLBToHTTPRoutes)).
 		Watches(&gwpav1alpha2.HealthCheckPolicy{}, handler.EnqueueRequestsFromMapFunc(r.healthCheckToHTTPRoutes)).
-		Watches(&gwpav1alpha2.RetryPolicy{}, handler.EnqueueRequestsFromMapFunc(r.retryToHTTPRoutes)).
 		Watches(&gwv1beta1.ReferenceGrant{}, handler.EnqueueRequestsFromMapFunc(r.referenceGrantToHTTPRoutes)).
 		Complete(r); err != nil {
 		return err
@@ -200,16 +199,6 @@ func (r *httpRouteReconciler) healthCheckToHTTPRoutes(ctx context.Context, objec
 	return r.policyToHTTPRoutes(ctx, policy, policy.Spec.TargetRefs)
 }
 
-func (r *httpRouteReconciler) retryToHTTPRoutes(ctx context.Context, object client.Object) []reconcile.Request {
-	policy, ok := object.(*gwpav1alpha2.HealthCheckPolicy)
-	if !ok {
-		log.Error().Msgf("Unexpected type %T", object)
-		return nil
-	}
-
-	return r.policyToHTTPRoutes(ctx, policy, policy.Spec.TargetRefs)
-}
-
 func (r *httpRouteReconciler) policyToHTTPRoutes(ctx context.Context, policy client.Object, targetRefs []gwv1alpha2.NamespacedPolicyTargetReference) []reconcile.Request {
 	var requests []reconcile.Request