@@ -27,11 +27,12 @@ import (
2727 clientset "k8s.io/client-go/kubernetes"
2828 "sigs.k8s.io/controller-runtime/pkg/client"
2929
30+ "sigs.k8s.io/gateway-api/conformance/utils/config"
3031 "sigs.k8s.io/gateway-api/conformance/utils/kubernetes"
3132 "sigs.k8s.io/gateway-api/conformance/utils/tlog"
3233)
3334
34- func ExpectMirroredRequest (t * testing.T , client client.Client , clientset clientset.Interface , mirrorPods []MirroredBackend , path string ) {
35+ func ExpectMirroredRequest (t * testing.T , client client.Client , clientset clientset.Interface , mirrorPods []MirroredBackend , path string , timeoutConfig config. TimeoutConfig ) {
3536 for i , mirrorPod := range mirrorPods {
3637 if mirrorPod .Name == "" {
3738 tlog .Fatalf (t , "Mirrored BackendRef[%d].Name wasn't provided in the testcase, this test should only check http request mirror." , i )
@@ -64,7 +65,7 @@ func ExpectMirroredRequest(t *testing.T, client client.Client, clientset clients
6465 }
6566 }
6667 return false
67- }, 60 * time . Second , time .Millisecond * 100 , `Couldn't find mirrored request in "%s/%s" logs` , mirrorPod .Namespace , mirrorPod .Name )
68+ }, timeoutConfig . RequestTimeout , time .Second * 1 , `Couldn't find mirrored request in "%s/%s" logs` , mirrorPod .Namespace , mirrorPod .Name )
6869 }(mirrorPod )
6970 }
7071
0 commit comments