@@ -133,12 +133,14 @@ func TestAPIGateway_GatewayClassConfig(t *testing.T) {
133
133
k8sClient .DeleteAllOf (context .Background (), & gwv1beta1.Gateway {}, client .InNamespace (namespace ))
134
134
})
135
135
136
+
137
+
136
138
// Ensure it exists.
137
139
logger .Log (t , "checking that gateway is synchronized to Consul" )
138
140
checkConsulExists (t , consulClient , api .APIGateway , gatewayName )
139
141
140
142
// Scenario: Gateway deployment should match the default instances defined on the gateway class config
141
- logger . Log ( t , " checking that gateway instances match defined gateway class config" )
143
+ // checking that gateway instances match defined gateway class config
142
144
checkNumberOfInstances (t , k8sClient , consulClient , gateway .Name , gateway .Namespace , defaultInstances , gateway )
143
145
144
146
// Scenario: Updating the GatewayClassConfig should not affect gateways that have already been created
@@ -177,7 +179,7 @@ func scale(t *testing.T, client client.Client, name, namespace string, scaleTo *
177
179
func checkNumberOfInstances (t * testing.T , k8client client.Client , consulClient * api.Client , name , namespace string , wantNumber * int32 , gateway * gwv1beta1.Gateway ) {
178
180
t .Helper ()
179
181
180
- retryCheckWithWait (t , 30 , 10 * time .Second , func (r * retry.R ) {
182
+ retryCheckWithWait (t , 40 , 10 * time .Second , func (r * retry.R ) {
181
183
logger .Log (t , "checking that gateway instances match defined gateway class config" )
182
184
logger .Log (t , fmt .Sprintf ("want: %d" , * wantNumber ))
183
185
0 commit comments