- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for debounceC (0.43 sec)
-
pilot/pkg/config/monitor/monitor.go
return err } watcher := recursiveWatcher{fs} if err = watcher.watchRecursive(path); err != nil { return err } go func() { defer watcher.Close() var debounceC <-chan time.Time for { select { case <-debounceC: debounceC = nil ch <- struct{}{} case e := <-watcher.Events: s, err := os.Stat(e.Name) if err == nil && s != nil && s.IsDir() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 17:36:33 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/util/concurrent/debouncer.go
// limitations under the License. package concurrent import ( "time" "istio.io/istio/pkg/util/sets" ) type Debouncer[T comparable] struct{} func (d *Debouncer[T]) Run(ch chan T, stopCh <-chan struct{}, debounceMinInterval, debounceMaxInterval time.Duration, pushFn func(sets.Set[T])) { var timeChan <-chan time.Time var startDebounce time.Time
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 01 13:44:06 UTC 2024 - 2.4K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
enableEDSDebounce: false, } tests := []struct { name string test func(updateCh chan *model.PushRequest, expect func(partial, full int32)) }{ { name: "Should not debounce partial pushes", test: func(updateCh chan *model.PushRequest, expect func(partial, full int32)) { updateCh <- &model.PushRequest{Full: false} expect(1, 0) updateCh <- &model.PushRequest{Full: false}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/config/analysis/incluster/controller.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0)