Update k8s library to v0.24.1 (#454)

* Bump k8s deps Co-authored-by: Barna Kutassy <[email protected]>
spotify · Aug 24, 2022 · b5bcff3 · b5bcff3
1 parent b3e0159
commit b5bcff3
Show file tree

Hide file tree

Showing 7 changed files with 594 additions and 130 deletions.
diff --git a/apis/flinkcluster/v1beta1/flinkcluster_default.go b/apis/flinkcluster/v1beta1/flinkcluster_default.go
@@ -134,7 +134,7 @@ func _SetJobManagerDefault(jmSpec *JobManagerSpec, flinkVersion *version.Version
 	}
 
 	var livenessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(*jmSpec.Ports.RPC)),
 			},
@@ -150,7 +150,7 @@ func _SetJobManagerDefault(jmSpec *JobManagerSpec, flinkVersion *version.Version
 	jmSpec.LivenessProbe = &livenessProbe
 
 	var readinessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(*jmSpec.Ports.RPC)),
 			},
@@ -205,7 +205,7 @@ func _SetTaskManagerDefault(tmSpec *TaskManagerSpec, flinkVersion *version.Versi
 	}
 
 	var livenessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(*tmSpec.Ports.RPC)),
 			},
@@ -221,7 +221,7 @@ func _SetTaskManagerDefault(tmSpec *TaskManagerSpec, flinkVersion *version.Versi
 	tmSpec.LivenessProbe = &livenessProbe
 
 	var readinessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(*tmSpec.Ports.RPC)),
 			},

diff --git a/apis/flinkcluster/v1beta1/flinkcluster_default_test.go b/apis/flinkcluster/v1beta1/flinkcluster_default_test.go
@@ -61,7 +61,7 @@ func TestSetDefault(t *testing.T) {
 	resources := DefaultResources
 	tmReplicas := int32(DefaultTaskManagerReplicas)
 	var defaultJmReadinessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(defaultJmRPCPort)),
 			},
@@ -72,7 +72,7 @@ func TestSetDefault(t *testing.T) {
 		FailureThreshold:    60,
 	}
 	var defaultJmLivenessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(defaultJmRPCPort)),
 			},
@@ -83,7 +83,7 @@ func TestSetDefault(t *testing.T) {
 		FailureThreshold:    5,
 	}
 	var defaultTmReadinessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(defaultTmRPCPort)),
 			},
@@ -94,7 +94,7 @@ func TestSetDefault(t *testing.T) {
 		FailureThreshold:    60,
 	}
 	var defaultTmLivenessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(defaultTmRPCPort)),
 			},
@@ -220,7 +220,7 @@ func TestSetNonDefault(t *testing.T) {
 	}
 	tmReplicas := int32(DefaultTaskManagerReplicas)
 	var jmReadinessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(jmRPCPort)),
 			},
@@ -230,7 +230,7 @@ func TestSetNonDefault(t *testing.T) {
 		FailureThreshold:    600,
 	}
 	var jmLivenessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(jmRPCPort)),
 			},
@@ -240,7 +240,7 @@ func TestSetNonDefault(t *testing.T) {
 		FailureThreshold:    50,
 	}
 	var tmReadinessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(tmRPCPort)),
 			},
@@ -251,7 +251,7 @@ func TestSetNonDefault(t *testing.T) {
 		FailureThreshold:    600,
 	}
 	var tmLivenessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(tmRPCPort)),
 			},
@@ -330,7 +330,7 @@ func TestSetNonDefault(t *testing.T) {
 	_SetDefault(&cluster)
 
 	var jmExpectedReadinessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(jmRPCPort)),
 			},
@@ -341,7 +341,7 @@ func TestSetNonDefault(t *testing.T) {
 		FailureThreshold:    600,
 	}
 	var jmExpectedLivenessProbe = corev1.Probe{
-		Handler: corev1.Handler{
+		ProbeHandler: corev1.ProbeHandler{
 			TCPSocket: &corev1.TCPSocketAction{
 				Port: intstr.FromInt(int(jmRPCPort)),
 			},