160acdf876
By changing to use WatchCtx we will actually block for changes to the peering list. WatchCh creates a goroutine to collect errors from WatchCtx and returns immediately. The existing behavior wouldn't result in a tight loop because of the rate limiting in the surrounding function, but it would still lead to more work than is necessary. |
||
|---|---|---|
| .. | ||
| service.go | ||
| service_oss_test.go | ||
| service_test.go | ||
| stream_test.go | ||
| stream_tracker.go | ||
| stream_tracker_test.go | ||
| subscription_manager.go | ||
| subscription_manager_test.go | ||
| subscription_view.go | ||
| subscription_view_test.go | ||
| testing.go | ||
| testutil_oss_test.go | ||
| validate.go | ||
| validate_test.go | ||