Skip to content

Commit

Permalink
give test more time (should de-flake it)
Browse files Browse the repository at this point in the history
  • Loading branch information
yuval-k committed Nov 22, 2024
1 parent 4aa9ca7 commit bfd6e43
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions projects/gateway2/setup/ggv2setup_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -580,7 +580,7 @@ type xdsFetcher struct {

func (x *xdsFetcher) getclusters(t *testing.T, ctx context.Context) []*envoycluster.Cluster {

ctx, cancel := context.WithTimeout(ctx, time.Second)
ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
defer cancel()

cds := envoy_service_cluster_v3.NewClusterDiscoveryServiceClient(x.conn)
Expand Down Expand Up @@ -634,7 +634,7 @@ func getroutesnames(l *envoylistener.Listener) []string {

func (x *xdsFetcher) getlisteners(t *testing.T, ctx context.Context) []*envoylistener.Listener {

ctx, cancel := context.WithTimeout(ctx, time.Second)
ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
defer cancel()

ds := envoy_service_listener_v3.NewListenerDiscoveryServiceClient(x.conn)
Expand Down Expand Up @@ -667,7 +667,7 @@ func (x *xdsFetcher) getlisteners(t *testing.T, ctx context.Context) []*envoylis
func (x *xdsFetcher) getendpoints(t *testing.T, ctx context.Context, clusterServiceNames []string) []*envoyendpoint.ClusterLoadAssignment {

eds := envoy_service_endpoint_v3.NewEndpointDiscoveryServiceClient(x.conn)
ctx, cancel := context.WithTimeout(ctx, time.Second)
ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
defer cancel()

epcli, err := eds.StreamEndpoints(ctx)
Expand Down Expand Up @@ -700,7 +700,7 @@ func (x *xdsFetcher) getendpoints(t *testing.T, ctx context.Context, clusterServ
func (x *xdsFetcher) getroutes(t *testing.T, ctx context.Context, rosourceNames []string) []*envoy_config_route_v3.RouteConfiguration {

eds := envoy_service_route_v3.NewRouteDiscoveryServiceClient(x.conn)
ctx, cancel := context.WithTimeout(ctx, time.Second)
ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
defer cancel()

epcli, err := eds.StreamRoutes(ctx)
Expand Down

0 comments on commit bfd6e43

Please sign in to comment.