Add query ingress enable switch

pkg/apis/io/v1alpha1/types.go

@@ -40,9 +40,15 @@ type JaegerStatus struct {
 
 // JaegerQuerySpec defines the options to be used when deploying the query
 type JaegerQuerySpec struct {
-	Size    int     `json:"size"`
-	Image   string  `json:"image"`
-	Options Options `json:"options"`
+	Ingress JaegerIngressSpec `json:"ingress"`
+	Size    int               `json:"size"`
+	Image   string            `json:"image"`
+	Options Options           `json:"options"`
+}
+
+// JaegerIngressSpec defines the options to be used when deploying the query ingress
+type JaegerIngressSpec struct {
+	Enabled *bool `json:"enabled"`
 }
 
 // JaegerAllInOneSpec defines the options to be used when deploying the query

pkg/deployment/query.go

@@ -117,9 +117,13 @@ func (q *Query) Services() []*v1.Service {
 
 // Ingresses returns a list of ingress rules to be deployed along with the all-in-one deployment
 func (q *Query) Ingresses() []*v1beta1.Ingress {
-	return []*v1beta1.Ingress{
-		ingress.NewQueryIngress(q.jaeger),
+	if q.jaeger.Spec.Query.Ingress.Enabled == nil || *q.jaeger.Spec.Query.Ingress.Enabled == true {
+		return []*v1beta1.Ingress{
+			ingress.NewQueryIngress(q.jaeger),
+		}
 	}
+
+	return []*v1beta1.Ingress{}
 }
 
 func (q *Query) selector() map[string]string {

pkg/deployment/query_test.go

@@ -62,8 +62,39 @@ func TestQueryServices(t *testing.T) {
 }
 
 func TestQueryIngresses(t *testing.T) {
-	query := NewQuery(v1alpha1.NewJaeger("TestQueryIngresses"))
-	svcs := query.Ingresses()
-
-	assert.Len(t, svcs, 1)
+	newBool := func(value bool) *bool {
+		return &value
+	}
+
+	subTestCases := []struct {
+		name                   string
+		ingressSpec            v1alpha1.JaegerIngressSpec
+		expectedIngressesCount int
+	}{
+		{
+			name:                   "IngressEnabledDefault",
+			ingressSpec:            v1alpha1.JaegerIngressSpec{},
+			expectedIngressesCount: 1,
+		},
+		{
+			name:                   "IngressEnabledFalse",
+			ingressSpec:            v1alpha1.JaegerIngressSpec{Enabled: newBool(false)},
+			expectedIngressesCount: 0,
+		},
+		{
+			name:                   "IngressEnabledTrue",
+			ingressSpec:            v1alpha1.JaegerIngressSpec{Enabled: newBool(true)},
+			expectedIngressesCount: 1,
+		},
+	}
+
+	for _, stc := range subTestCases {
+		t.Run(stc.name, func(t *testing.T) {
+			query := NewQuery(v1alpha1.NewJaeger("TestQueryIngresses"))
+			query.jaeger.Spec.Query.Ingress = stc.ingressSpec
+			ingresses := query.Ingresses()
+
+			assert.Len(t, ingresses, stc.expectedIngressesCount)
+		})
+	}
 }