- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ExpectEmptyResponse (0.17 sec)
-
pilot/pkg/xds/workload_test.go
ads.Request(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"*"}, ResourceNamesUnsubscribe: []string{"*"}, }) ads.ExpectEmptyResponse() // Now subscribe to the pod, should get it back resp := ads.RequestResponseAck(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"/127.0.0.1"}, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
} return resp case err := <-a.error: a.t.Fatalf("got error: %v", err) } return nil } // ExpectResponse waits until a response is received and returns it func (a *DeltaAdsTest) ExpectEmptyResponse() *discovery.DeltaDiscoveryResponse { a.t.Helper() select { case <-time.After(a.timeout): a.t.Fatalf("did not get response in time") case resp := <-a.responses: if resp == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0)