- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for EnsureSynced (0.16 sec)
-
pilot/pkg/xds/delta_test.go
s.MemRegistry.SetEndpoints(edsIncSvc, "", newEndpointWithAccount("127.0.0.1", "hello-sa", "v1")) // Wait until the above debounce, to ensure we can precisely check XDS responses without spurious pushes s.EnsureSynced(t) ads := s.ConnectDeltaADS().WithID("sidecar~127.0.0.1~test.default~default.svc.cluster.local") // Initially we get everything ads.Request(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/test/xds/fake.go
func (f *FakeDiscoveryServer) T() test.Failer { return f.t } // EnsureSynced checks that all ConfigUpdates sent have been established // This does NOT ensure that the change has been sent to all proxies; only that PushContext is updated // Typically, if trying to ensure changes are sent, its better to wait for the push event. func (f *FakeDiscoveryServer) EnsureSynced(t test.Failer) { c := f.Discovery.InboundUpdates.Load()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0)