Change field processingGuarantee to processingGuarantees for WindowConfig

Author: jiangpengcheng

.ci/tests/integration/cases/logging-window-function/verify.sh

@@ -43,6 +43,13 @@ if [ $? -ne 0 ]; then
   exit 1
 fi
 
+# verify the `processingGuarantees` config
+kubectl logs window-function-sample | grep processingGuarantees=ATLEAST_ONCE
+if [ $? -ne 0 ]; then
+  kubectl delete -f "${manifests_file}" > /dev/null 2>&1 || true
+  exit 1
+fi
+
 verify_java_result=$(NAMESPACE=${PULSAR_NAMESPACE} CLUSTER=${PULSAR_RELEASE_NAME} ci::send_test_data "persistent://public/default/window-function-input-topic" "test-message" 3 2>&1)
 if [ $? -ne 0 ]; then
   echo "$verify_java_result"

api/compute/v1alpha1/common.go

@@ -546,7 +546,7 @@ type WindowConfig struct {
 	MaxLagMs                      *int64                 `json:"maxLagMs,omitempty"`
 	WatermarkEmitIntervalMs       *int64                 `json:"watermarkEmitIntervalMs,omitempty"`
 	TimestampExtractorClassName   *string                `json:"timestampExtractorClassName,omitempty"`
-	ProcessingGuarantee           WindowProcessGuarantee `json:"processingGuarantee,omitempty"`
+	ProcessingGuarantees          WindowProcessGuarantee `json:"processingGuarantees,omitempty"`
 }
 
 type VPASpec struct {

charts/function-mesh-operator/charts/admission-webhook/templates/crd-compute.functionmesh.io-functionmeshes.yaml

@@ -3786,7 +3786,7 @@ spec:
                           maxLagMs:
                             format: int64
                             type: integer
-                          processingGuarantee:
+                          processingGuarantees:
                             enum:
                               - ATLEAST_ONCE
                               - ATMOST_ONCE

charts/function-mesh-operator/charts/admission-webhook/templates/crd-compute.functionmesh.io-functions.yaml

@@ -3805,7 +3805,7 @@ spec:
                     maxLagMs:
                       format: int64
                       type: integer
-                    processingGuarantee:
+                    processingGuarantees:
                       enum:
                         - ATLEAST_ONCE
                         - ATMOST_ONCE

config/crd/bases/compute.functionmesh.io_functionmeshes.yaml

@@ -3786,7 +3786,7 @@ spec:
                         maxLagMs:
                           format: int64
                           type: integer
-                        processingGuarantee:
+                        processingGuarantees:
                           enum:
                           - ATLEAST_ONCE
                           - ATMOST_ONCE

config/crd/bases/compute.functionmesh.io_functions.yaml

@@ -3783,7 +3783,7 @@ spec:
                   maxLagMs:
                     format: int64
                     type: integer
-                  processingGuarantee:
+                  processingGuarantees:
                     enum:
                     - ATLEAST_ONCE
                     - ATMOST_ONCE