- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ChannelHasItem (0.11 sec)
-
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
Namespace: "default", }, Spec: k8s.GatewaySpec{ GatewayClassName: k8s.ObjectName(features.GatewayAPIDefaultGatewayClass), }, } gws.Create(defaultGateway) assert.Equal(t, assert.ChannelHasItem(t, writes), buildPatch(ControllerVersion)) expectReconciled() assert.ChannelIsEmpty(t, writes) // Test fake doesn't actual do Apply, so manually do this
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
} c.AppendNetworkGatewayHandler(func() { setGws(c.NetworkGateways()) notifyCh <- struct{}{} }) expectGateways := func(t *testing.T, expectedGws int) { // wait for a notification assert.ChannelHasItem(t, notifyCh) if n := len(getGws()); n != expectedGws { t.Errorf("expected %d gateways but got %d", expectedGws, n) } } t.Run("add meshnetworks", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0)