- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for debounceC (2.42 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) -
pkg/config/mesh/watcher.go
_ = fileWatcher.Add(file) go func() { var timerC <-chan time.Time for { select { case <-timerC: timerC = nil callback() case <-fileWatcher.Events(file): // Use a timer to debounce configuration updates if timerC == nil { timerC = time.After(100 * time.Millisecond) } } } }() } func PrettyFormatOfMeshConfig(meshConfig *meshconfig.MeshConfig) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/kube/inject/watcher.go
log.Errorf("update error: %v", err) } } case event, ok := <-w.watcher.Events: if !ok { return } log.Debugf("Injector watch update: %+v", event) // use a timer to debounce configuration updates if (event.Has(fsnotify.Write) || event.Has(fsnotify.Create)) && timerC == nil { timerC = time.After(watchDebounceDelay) } case err, ok := <-w.watcher.Errors: if !ok { return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.9K bytes - Viewed (0)