- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for responses (0.11 sec)
-
pilot/pkg/xds/deltaadstest.go
} return } select { case a.responses <- resp: case <-a.context.Done(): return } } } // DrainResponses reads all responses, but does nothing to them func (a *DeltaAdsTest) DrainResponses() { a.t.Helper() for { select { case <-a.context.Done(): return case r := <-a.responses: log.Infof("drained response %v", r.TypeUrl) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
pilot/pkg/xds/adstest.go
} return } select { case a.responses <- resp: case <-a.context.Done(): return } } } // DrainResponses reads all responses, but does nothing to them func (a *AdsTest) DrainResponses() { for { select { case <-a.context.Done(): return case r := <-a.responses: log.Infof("drained response %v", r.TypeUrl) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
return nil, err } responses = append(responses, resp) return responses, nil } return responses, nil } func mergeShards(responses map[string]*discovery.DiscoveryResponse) (*discovery.DiscoveryResponse, error) { retval := discovery.DiscoveryResponse{} if len(responses) == 0 { return &retval, nil } for _, response := range responses {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
err := json.Unmarshal(resp, istiodDump) if err != nil { continue } c.istiod = istiodDump break } if c.istiod == nil { return nil, fmt.Errorf("unable to find config dump in Istiod responses") } envoyDump := &configdump.Wrapper{} err := json.Unmarshal(envoyResponse, envoyDump) if err != nil { return nil, err } c.envoy = envoyDump c.w = w c.context = 7
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 3.7K bytes - Viewed (0) -
pilot/pkg/features/xds.go
"If true, Pilot will cache XDS responses.").Get() // EnableCDSCaching determines if CDS caching is enabled. This is explicitly split out of ENABLE_XDS_CACHE, // so that in case there are issues with the CDS cache we can just disable the CDS cache. EnableCDSCaching = env.Register("PILOT_ENABLE_CDS_CACHE", true, "If true, Pilot will cache CDS responses. Note: this depends on PILOT_ENABLE_XDS_CACHE.").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 24 06:18:36 UTC 2024 - 3.4K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
"istio.io/istio/pilot/pkg/model" xdsresource "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/log" ) // XdsStatusWriter enables printing of sync status using multiple xdsapi.DiscoveryResponse Istiod responses type XdsStatusWriter struct { Writer io.Writer Namespace string InternalDebugAllIstiod bool } type xdsWriterStatus struct { proxyID string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/xds/statusgen.go
Server: s, } } // Generate XDS responses about internal events: // - connection status // - NACKs // We can also expose ACKS. func (sg *StatusGen) Generate(proxy *model.Proxy, w *model.WatchedResource, req *model.PushRequest) (model.Resources, model.XdsLogDetails, error) { return sg.handleInternalRequest(proxy, w, req) } // Generate delta XDS responses about internal events: // - connection status // - NACKs
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 23:30:28 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/xds/monitoring.go
"pilot_xds_rds_reject", "Pilot rejected RDS.", ) totalXDSRejects = monitoring.NewSum( "pilot_total_xds_rejects", "Total number of XDS responses from pilot rejected by proxy.", ) ResponseWriteTimeouts = monitoring.NewSum( "pilot_xds_write_timeout", "Pilot XDS response write timeouts.", ) sendTime = monitoring.NewDistribution( "pilot_xds_send_time",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
staticCluster: "", updateCluster: "", }, }) // Expect that we send an EDS response even though there was no request resp := ads.ExpectResponse() if resp.TypeUrl != v3.EndpointType { t.Fatalf("unexpected response type %v. Expected dependent EDS response", resp.TypeUrl) } // we must NOT get the cluster back
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
tests/integration/pilot/original_src_addr_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 1.9K bytes - Viewed (0)