- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for workloadType (0.17 sec)
-
pilot/pkg/xds/workload.go
aliases := addr.Aliases() removed.DeleteAll(aliases...) n := addr.ResourceName() have.Insert(n) haveAliases.InsertAll(aliases...) switch w.TypeUrl { case v3.WorkloadType: if addr.GetWorkload() != nil { resources = append(resources, &discovery.Resource{ Name: n, Aliases: aliases, Resource: protoconv.MessageToAny(addr.GetWorkload()), // TODO: pre-marshal
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 14:14:30 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
forward(resp) } func forwardDeltaToEnvoy(con *ProxyConnection, resp *discovery.DeltaDiscoveryResponse) { if !model.IsEnvoyType(resp.TypeUrl) && resp.TypeUrl != model.WorkloadType { proxyLog.Errorf("Skipping forwarding type url %s to Envoy as is not a valid Envoy type", resp.TypeUrl) return } if con.isClosed() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
Network: testNW, Addresses: [][]byte{parseIP("127.0.0.3")}, ServiceAccount: "sa3", Node: "", CanonicalName: "other", CanonicalRevision: "latest", WorkloadType: workloadapi.WorkloadType_POD, WorkloadName: "name3", ClusterId: testC, }, }, }, }}) s.assertEvent(t, s.wleXdsName("name2")) s.assertEvent(t, s.wleXdsName("name3"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
// order after the types listed here var PushOrder = []string{ v3.ClusterType, v3.EndpointType, v3.ListenerType, v3.RouteType, v3.SecretType, v3.AddressType, v3.WorkloadType, v3.WorkloadAuthorizationType, } // KnownOrderedTypeUrls has typeUrls for which we know the order of push. var KnownOrderedTypeUrls = sets.New(PushOrder...)
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.go
// This is used when resources are spontaneously pushed during Delta XDS func requiresResourceNamesModification(url string) bool { return url == v3.AddressType || url == v3.WorkloadType } // neverRemoveDelta checks if a type should never remove resources func neverRemoveDelta(url string) bool { // https://github.com/envoyproxy/envoy/issues/32823
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
} } func forwardToEnvoy(con *ProxyConnection, resp *discovery.DiscoveryResponse) { if !model.IsEnvoyType(resp.TypeUrl) && resp.TypeUrl != model.WorkloadType { proxyLog.Errorf("Skipping forwarding type url %s to Envoy as is not a valid Envoy type", resp.TypeUrl) return } if con.isClosed() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)