- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 93 for Eads (0.04 sec)
-
pilot/pkg/xds/ads.go
func (s *DiscoveryServer) processRequest(req *discovery.DiscoveryRequest, con *Connection) error { stype := v3.GetShortType(req.TypeUrl) log.Debugf("ADS:%s: REQ %s resources:%d nonce:%s version:%s ", stype, con.ID(), len(req.ResourceNames), req.ResponseNonce, req.VersionInfo) if req.TypeUrl == v3.HealthInfoType { s.handleWorkloadHealthcheck(con.proxy, req) return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.ClusterType) ads.RequestResponseAck(nil) } func TestDeltaAdsClusterUpdate(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.EndpointType) nonce := "" sendEDSReqAndVerify := func(add, remove, expect []string) { t.Helper() res := ads.RequestResponseAck(&discovery.DeltaDiscoveryRequest{
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/pkg/xds/ads_test.go
s := xdsfake.NewFakeDiscoveryServer(t, xdsfake.FakeOptions{}) ads := s.ConnectADS().WithType(v3.EndpointType) res := ads.RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{"fake-cluster"}}) // Close the connection and reconnect ads.Cleanup() ads = s.ConnectADS().WithType(v3.EndpointType) // Reconnect with the same resources ads.RequestResponseAck(t, &discovery.DiscoveryRequest{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
pilot/pkg/xds/debug_test.go
ads := s.ConnectADS() ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.ClusterType}) ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.ListenerType}) ads.RequestResponseAck(t, &discovery.DiscoveryRequest{ TypeUrl: v3.EndpointType, ResourceNames: []string{"outbound|9080||app2.default.svc.cluster.local"}, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 7.8K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
}) ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithMetadata(model.NodeMetadata{NodeName: "node"}) ads.Request(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"*"}, ResourceNamesUnsubscribe: []string{"*"}, }) ads.ExpectEmptyResponse() // Now subscribe to the pod, should get it back resp := ads.RequestResponseAck(&discovery.DeltaDiscoveryRequest{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/model/xds.go
return "NDS" case ProxyConfigType: return "PCDS" case ExtensionConfigurationType: return "ECDS" case AddressType, WorkloadType: return "WDS" case WorkloadAuthorizationType: return "WADS" default: return typeURL } } // GetMetricType returns the form of a type reported for metrics func GetMetricType(typeURL string) string { switch typeURL { case ClusterType: return "cds"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 3.7K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
}) if _, err := ads.Wait(time.Second*5, watchAll...); err != nil { t.Fatal(err) } if len(ads.GetEndpoints()) != 1 { t.Fatalf("Expected a partial EDS update, but got: %v", xdstest.MapKeys(ads.GetEndpoints())) } }) t.Run("Full Push with updated services and virtual services", func(t *testing.T) { ads.WaitClear() s.Discovery.Push(&model.PushRequest{ Full: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pkg/xds/server.go
if alwaysRespond { log.Infof("ADS:%s: FORCE RESPONSE %s for warming.", stype, id) return true, emptyResourceDelta } if len(removed) == 0 && len(added) == 0 { log.Debugf("ADS:%s: ACK %s %s %s", stype, id, request.VersionInfo, request.ResponseNonce) return false, emptyResourceDelta } log.Debugf("ADS:%s: RESOURCE CHANGE added %v removed %v %s %s %s", stype,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
tools/packaging/common/gcp_envoy_bootstrap.json
{{ end }} }, "metadata": {{ .meta_json_str }} }, "dynamic_resources": { "lds_config": { "resource_api_version": "V3", "ads": {} }, "cds_config": { "resource_api_version": "V3", "ads": {} }, "ads_config": { "api_type": "GRPC", "transport_api_version": "V3", "grpc_services": [ { "google_grpc": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 6.9K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
// even though Nonce match and it looks like an ACK. if alwaysRespond { deltaLog.Infof("ADS:%s: FORCE RESPONSE %s for warming.", stype, con.ID()) return true } deltaLog.Debugf("ADS:%s: ACK %s %s", stype, con.ID(), request.ResponseNonce) return false } deltaLog.Debugf("ADS:%s: RESOURCE CHANGE previous resources: %v, new resources: %v %s %s", stype,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)