- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for debounceC (0.44 sec)
-
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/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) -
architecture/networking/pilot.md
Various components described in Config Ingestion can trigger a Config Update. These are batched up ("debounced"), to avoid excessive activity when many changes happen in succession, and eventually enqueued in the Push Queue.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 17:53:24 UTC 2024 - 19.1K 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/eds_test.go
addEdsCluster(s, "edsdns.svc.cluster.local", "http", "10.0.0.53", 8080) addEdsCluster(s, "other.local", "http", "1.1.1.1", 8080) s.EnsureSynced(t) // Wait for debounce adscConn := s.Connect(nil, nil, watchAll) // Validate that endpoints are pushed correctly. testEndpoints("10.0.0.53", "outbound|8080||edsdns.svc.cluster.local", adscConn, t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K 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/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)