- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for WaitClear (0.43 sec)
-
pilot/pkg/xds/eds_test.go
s.Discovery.Push(&model.PushRequest{Full: true}) if _, err := ads.Wait(time.Second*5, watchAll...); err != nil { t.Fatal(err) } }) t.Run("Incremental Push with updated services", func(t *testing.T) { ads.WaitClear() s.Discovery.Push(&model.PushRequest{ Full: false, ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.ServiceEntry, Name: "destall.default.svc.cluster.local", Namespace: "testns"}), })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pkg/adsc/delta.go
req.ResourceNamesUnsubscribe = unsub.UnsortedList() } err := c.xdsClient.Send(req) if err != nil { c.errChan <- err } } // WaitClear will clear the waiting events, so next call to Wait will get // the next push type. func (c *Client) WaitClear() { for { select { case <-c.deltaXDSUpdates: case <-c.errChan: default: return } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0) -
pkg/adsc/adsc.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
}, } for _, c := range svcCases { t.Run(c.desc, func(t *testing.T) { // Let events from previous tests complete time.Sleep(time.Millisecond * 50) adscConn.WaitClear() var wantUpdates []string wantUpdates = append(wantUpdates, c.expectedUpdates...) wantUpdates = append(wantUpdates, c.unexpectedUpdates...) switch c.ev { case model.EventAdd:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0)