fix knative envoyfilter

Signed-off-by: DavidSpek <[email protected]>
pluralsh · Sep 9, 2022 · a99665f · a99665f
1 parent e432ce5
commit a99665f
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 12 deletions.
diff --git a/apis/kubeflow.org/v1/groupversion_info.go b/apis/kubeflow.org/v1/groupversion_info.go
@@ -15,8 +15,8 @@ limitations under the License.
 */
 
 // Package v1 contains API Schema definitions for the  v1 API group
-//+kubebuilder:object:generate=true
-//+groupName=kubeflow.org
+// +kubebuilder:object:generate=true
+// +groupName=kubeflow.org
 package v1
 
 import (

diff --git a/apis/kubeflow.org/v1beta1/groupversion_info.go b/apis/kubeflow.org/v1beta1/groupversion_info.go
@@ -15,8 +15,8 @@ limitations under the License.
 */
 
 // Package v1beta1 contains API Schema definitions for the  v1beta1 API group
-//+kubebuilder:object:generate=true
-//+groupName=kubeflow.org
+// +kubebuilder:object:generate=true
+// +groupName=kubeflow.org
 package v1beta1
 
 import (

diff --git a/apis/kubeflow.org/v2alpha1/groupversion_info.go b/apis/kubeflow.org/v2alpha1/groupversion_info.go
@@ -15,8 +15,8 @@ limitations under the License.
 */
 
 // Package v2alpha1 contains API Schema definitions for the kubeflow.org v2alpha1 API group
-//+kubebuilder:object:generate=true
-//+groupName=kubeflow.org
+// +kubebuilder:object:generate=true
+// +groupName=kubeflow.org
 package v2alpha1
 
 import (

diff --git a/apis/platform/v1alpha1/groupversion_info.go b/apis/platform/v1alpha1/groupversion_info.go
@@ -15,8 +15,8 @@ limitations under the License.
 */
 
 // Package v1alpha1 contains API Schema definitions for the platform v1alpha1 API group
-//+kubebuilder:object:generate=true
-//+groupName=platform.kubeflow.org
+// +kubebuilder:object:generate=true
+// +groupName=platform.kubeflow.org
 package v1alpha1
 
 import (

diff --git a/controllers/kubeflow.org/profile_controller.go b/controllers/kubeflow.org/profile_controller.go
@@ -1091,6 +1091,11 @@ func (r *ProfileReconciler) generatePeerAuthentication(profileIns *profilev2alph
 
 func (r *ProfileReconciler) generateEnvoyFilter(profileIns *profilev2alpha1.Profile) *istioNetworkingClientv1alpha3.EnvoyFilter {
 
+	luaString := fmt.Sprintf(`function envoy_on_request(request_handle)
+  headers = request_handle:headers()
+  request_handle:headers():replace("kubeflow-request-source-namespace", "%s")
+end`, profileIns.Name)
+
 	envoyfilter := &istioNetworkingClientv1alpha3.EnvoyFilter{
 
 		ObjectMeta: metav1.ObjectMeta{
@@ -1137,10 +1142,7 @@ func (r *ProfileReconciler) generateEnvoyFilter(profileIns *profilev2alpha1.Prof
 												},
 												"inline_code": {
 													Kind: &structpb.Value_StringValue{
-														StringValue: `function envoy_on_request(request_handle)
-  headers = request_handle:headers()
-  request_handle:headers():replace("kubeflow-request-source-namespace", "david")
-end`,
+														StringValue: luaString,
 													},
 												},
 											},