address the latest changes

.github/workflows/e2e_test.yml

@@ -46,10 +46,10 @@ jobs:
           docker rmi $(docker images -q) -f
           df -h
 
-      - name: Set up Go 1.22.7
+      - name: Set up Go 1.22.11
         uses: actions/setup-go@v3
         with:
-          go-version: '1.22.7'
+          go-version: '1.22.11'
         id: go
 
       - name: Set up Git token

Dockerfile

@@ -13,7 +13,7 @@
 # limitations under the License.
 
 # Build the manager binary
-FROM golang:1.22.7-alpine3.20 as builder
+FROM golang:1.22.11-alpine3.20 as builder
 
 ARG ACCESS_TOKEN="none"
 

api/v1alpha1/computeflinkdeployment_types.go

@@ -54,6 +54,14 @@ type ComputeFlinkDeploymentSpec struct {
 	// DefaultPulsarCluster is the default pulsar cluster to use
 	// +optional
 	DefaultPulsarCluster *string `json:"defaultPulsarCluster,omitempty"`
+
+	// Configuration is the list of configurations to deploy with the Flink deployment.
+	// +optional
+	Configuration *Configuration `json:"configuration,omitempty"`
+
+	// ImagePullSecrets is the list of image pull secrets to use for the deployment.
+	// +optional
+	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
 }
 
 // ComputeFlinkDeploymentStatus defines the observed state of ComputeFlinkDeployment
@@ -267,6 +275,9 @@ type Artifact struct {
 
 	// +optional
 	URI string `json:"uri,omitempty"`
+
+	// +optional
+	ArtifactImage string `json:"artifactImage,omitempty"`
 }
 
 // VvpDeploymentStatus defines the deployment status
@@ -409,6 +420,35 @@ type VvpDeploymentDetailsTemplateSpecKubernetesSpec struct {
 	Labels map[string]string `json:"labels,omitempty"`
 }
 
+// SecretReference references a StreamNative Cloud secret.
+type SecretReference struct {
+	// Name of the ENV variable.
+	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
+
+	// ValueFrom references a secret in the same namespace.
+	ValueFrom *corev1.SecretKeySelector `json:"valueFrom,omitempty" protobuf:"bytes,2,opt,name=valueFrom"`
+}
+
+// EnvVar defines an environment variable.
+type EnvVar struct {
+	// Name of the environment variable.
+	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
+
+	// Value of the environment variable.
+	Value string `json:"value" protobuf:"bytes,2,opt,name=value"`
+}
+
+// Configuration defines the additional configuration for the Flink deployment
+type Configuration struct {
+	// Envs is the list of environment variables to set in the Flink deployment.
+	// +optional
+	Envs []EnvVar `json:"envs,omitempty" protobuf:"bytes,1,opt,name=envs"`
+
+	//Secrets is the list of secrets referenced to deploy with the Flink deployment.
+	// +optional
+	Secrets []SecretReference `json:"secrets,omitempty" protobuf:"bytes,2,opt,name=secrets"`
+}
+
 func init() {
 	SchemeBuilder.Register(&ComputeFlinkDeployment{}, &ComputeFlinkDeploymentList{})
 }

api/v1alpha1/secret_types.go

@@ -56,6 +56,10 @@ type SecretSpec struct {
 	// +optional
 	// +listType=atomic
 	Tolerations []Toleration `json:"tolerations,omitempty"`
+
+	// Type Used to facilitate programmatic handling of secret data.
+	// +optional
+	Type *corev1.SecretType `json:"type,omitempty"`
 }
 
 // SecretStatus defines the observed state of StreamNative Cloud Secret