feat(service): add support for nodePort (#205)

Closes #204 Signed-off-by: mueller-ma <[email protected]>
dragonflydb · Jul 1, 2024 · f66bfc4 · f66bfc4
1 parent 400c2b0
commit f66bfc4
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 0 deletions.
diff --git a/api/v1alpha1/dragonfly_types.go b/api/v1alpha1/dragonfly_types.go
@@ -141,6 +141,11 @@ type ServiceSpec struct {
 	// +kubebuilder:validation:Optional
 	Name string `json:"name,omitempty"`
 
+	// (Optional) Dragonfly Service nodePort
+	// +optional
+	// +kubebuilder:validation:Optional
+	NodePort int32 `json:"nodePort,omitempty"`
+
 	// (Optional) Dragonfly Service Annotations
 	// +optional
 	// +kubebuilder:validation:Optional

diff --git a/config/crd/bases/dragonflydb.io_dragonflies.yaml b/config/crd/bases/dragonflydb.io_dragonflies.yaml
@@ -1138,6 +1138,10 @@ spec:
                   name:
                     description: (Optional) Dragonfly Service name
                     type: string
+                  nodePort:
+                    description: (Optional) Dragonfly Service nodePort
+                    format: int32
+                    type: integer
                   type:
                     description: (Optional) Dragonfly Service type
                     type: string

diff --git a/internal/resources/resources.go b/internal/resources/resources.go
@@ -385,6 +385,7 @@ func GetDragonflyResources(ctx context.Context, df *resourcesv1.Dragonfly) ([]cl
 		service.Spec.Type = df.Spec.ServiceSpec.Type
 		service.Annotations = df.Spec.ServiceSpec.Annotations
 		service.Labels = df.Spec.ServiceSpec.Labels
+		service.Spec.Ports[0].NodePort = df.Spec.ServiceSpec.NodePort
 	}
 	if df.Spec.MemcachedPort != 0 {
 		service.Spec.Ports = append(service.Spec.Ports, corev1.ServicePort{