- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ChannelHasItem (0.13 sec)
-
pkg/test/util/assert/assert.go
func NoError(t test.Failer, err error) { t.Helper() if err != nil { t.Fatalf("expected no error but got: %v", err) } } // ChannelHasItem asserts a channel has an element within 5s and returns the element func ChannelHasItem[T any](t test.Failer, c <-chan T) T { t.Helper() select { case r := <-c: return r case <-time.After(time.Second * 5):
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 18 17:21:50 UTC 2023 - 4.4K bytes - Viewed (0) -
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)