Add default haproxy image (#47)

Sets a default HAProxy image when one is not specified in the
RedisFailover CR. When the RedisFailover includes a HAProxy Spec, the
operator errors unless an Image attribute is present.

CHANGELOG.md

@@ -11,6 +11,7 @@ Also check this project's [releases](https://github.com/powerhome/redis-operator
 
 ### Changed
 
+- Add default haproxy image #47
 - Update metrics exporter images  #45
 
 ## [v2.0.2] - 2024-02-13

api/redisfailover/v1/defaults.go

@@ -6,6 +6,7 @@ const (
 	defaultSentinelExporterImage = "leominov/redis_sentinel_exporter:1.7.1"
 	defaultExporterImage         = "quay.io/oliver006/redis_exporter:v1.57.0"
 	defaultImage                 = "redis:6.2.6-alpine"
+	defaultHAProxyImage          = "haproxy:2.4"
 	defaultRedisPort             = 6379
 )
 

api/redisfailover/v1/validate.go

@@ -67,6 +67,12 @@ func (r *RedisFailover) Validate() error {
 		r.Spec.Sentinel.CustomConfig = defaultSentinelCustomConfig
 	}
 
+	if r.Spec.Haproxy != nil {
+		if r.Spec.Haproxy.Image == "" {
+			r.Spec.Haproxy.Image = defaultHAProxyImage
+		}
+	}
+
 	return nil
 }
 

api/redisfailover/v1/validate_test.go

@@ -16,6 +16,8 @@ func TestValidate(t *testing.T) {
 		rfSentinelCustomConfig []string
 		expectedError          string
 		expectedBootstrapNode  *BootstrapSettings
+		rfHAProxyConfig        *HaproxySettings
+		expectedHAProxyConfig  *HaproxySettings
 	}{
 		{
 			name:   "populates default values",
@@ -65,6 +67,18 @@ func TestValidate(t *testing.T) {
 			rfBootstrapNode:       &BootstrapSettings{Host: "127.0.0.1", Enabled: true},
 			expectedBootstrapNode: &BootstrapSettings{Host: "127.0.0.1", Port: "6379", Enabled: true},
 		},
+		{
+			name:                  "HAProxy config no image provided",
+			rfName:                "test",
+			rfHAProxyConfig:       &HaproxySettings{},
+			expectedHAProxyConfig: &HaproxySettings{Image: defaultHAProxyImage},
+		},
+		{
+			name:                  "HAProxy config custom image",
+			rfName:                "test",
+			rfHAProxyConfig:       &HaproxySettings{Image: "haproxy:0.0.1"},
+			expectedHAProxyConfig: &HaproxySettings{Image: "haproxy:0.0.1"},
+		},
 	}
 
 	for _, test := range tests {
@@ -73,7 +87,7 @@ func TestValidate(t *testing.T) {
 			rf := generateRedisFailover(test.rfName, test.rfBootstrapNode)
 			rf.Spec.Redis.CustomConfig = test.rfRedisCustomConfig
 			rf.Spec.Sentinel.CustomConfig = test.rfSentinelCustomConfig
-
+			rf.Spec.Haproxy = test.rfHAProxyConfig
 			err := rf.Validate()
 
 			if test.expectedError == "" {
@@ -119,9 +133,11 @@ func TestValidate(t *testing.T) {
 							},
 							Port: Port(26379),
 						},
+						Haproxy:       test.expectedHAProxyConfig,
 						BootstrapNode: test.expectedBootstrapNode,
 					},
 				}
+
 				assert.Equal(expectedRF, rf)
 			} else {
 				if assert.Error(err) {