- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for debounceC (0.15 sec)
-
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.go
func (s *DiscoveryServer) handleUpdates(stopCh <-chan struct{}) { debounce(s.pushChannel, stopCh, s.DebounceOptions, s.Push, s.CommittedUpdates) } // The debounce helper function is implemented to enable mocking func debounce(ch chan *model.PushRequest, stopCh <-chan struct{}, opts DebounceOptions, pushFn func(req *model.PushRequest), updateSent *atomic.Int64) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K 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) -
pilot/pkg/xds/delta_test.go
addTestClientEndpoints(s.MemRegistry) s.MemRegistry.AddHTTPService(edsIncSvc, edsIncVip, 8080) 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
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
// ListenerBuilder, if specified, allows making the server use the given // listener instead of a buffered conn. ListenerBuilder func() (net.Listener, error) // Time to debounce // By default, set to 0s to speed up tests DebounceTime time.Duration // EnableFakeXDSUpdater will use a XDSUpdater that can be used to watch events EnableFakeXDSUpdater bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/xds/eds.go
return false } for cfg := range req.ConfigsUpdated { if skippedEdsConfigs.Contains(cfg.Kind) { // the updated config does not impact EDS, skip it // this happens when push requests are merged due to debounce continue } if cfg.Kind != kind.ServiceEntry { return false } } return true } func (eds *EdsGenerator) buildEndpoints(proxy *model.Proxy, req *model.PushRequest,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
pilot/pkg/xds/bench_test.go
}, }, }, }) s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ Configs: configs, KubernetesObjectString: k8sConfig, // Allow debounce to avoid overwhelming with writes DebounceTime: time.Millisecond * 10, DisableSecretAuthorization: true, MeshConfig: m, }) return s, proxy } var (
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 22 18:13:40 UTC 2024 - 19.7K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
// RemoveShard removes all endpoints for the given shard key RemoveShard(shardKey ShardKey) } // PushRequest defines a request to push to proxies // It is used to send updates to the config update debouncer and pass to the PushQueue. type PushRequest struct { // Full determines whether a full push is required or not. If false, an incremental update will be sent. // Incremental pushes: // * Do not recompute the push context
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
caserver "istio.io/istio/security/pkg/server/ca" "istio.io/istio/security/pkg/server/ca/authenticate" "istio.io/istio/security/pkg/server/ca/authenticate/kubeauth" ) const ( // debounce file watcher events to minimize noise in logs watchDebounceDelay = 100 * time.Millisecond ) func init() { // Disable gRPC tracing. It has performance impacts (See https://github.com/grpc/grpc-go/issues/695)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0)