- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for serviceTargets (0.34 sec)
-
pilot/pkg/model/context_test.go
} proxy := &model.Proxy{} proxy.SetServiceTargets(env) assert.Equal(t, len(proxy.ServiceTargets), 3) assert.Equal(t, proxy.ServiceTargets[0].Service.Hostname, "test2.com") assert.Equal(t, proxy.ServiceTargets[1].Service.Hostname, "test3.com") assert.Equal(t, proxy.ServiceTargets[2].Service.Hostname, "test1.com") } func TestGlobalUnicastIP(t *testing.T) { cases := []struct { name string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 23:51:52 UTC 2024 - 11.2K bytes - Viewed (0) -
pilot/pkg/xds/proxy_dependencies.go
if ConfigAffectsProxy(req, proxy) { return true } // If the proxy's service updated, need push for it. if len(proxy.ServiceTargets) > 0 && req.ConfigsUpdated != nil { for _, svc := range proxy.ServiceTargets { if _, ok := req.ConfigsUpdated[model.ConfigKey{ Kind: kind.ServiceEntry, Name: string(svc.Service.Hostname),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 3.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
} // NewClusterBuilder builds an instance of ClusterBuilder. func NewClusterBuilder(proxy *model.Proxy, req *model.PushRequest, cache model.XdsCache) *ClusterBuilder { cb := &ClusterBuilder{ serviceTargets: proxy.ServiceTargets, proxyID: proxy.ID, proxyType: proxy.Type, proxyVersion: proxy.Metadata.IstioVersion, sidecarScope: proxy.SidecarScope,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/plugin/authn/authentication.go
if port == ingressListener.Port.Number { return false } } return true } // If there is no Sidecar, check if the port is appearing in any service. for _, si := range node.ServiceTargets { if port == si.Port.TargetPort { return false } } return true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 4.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
func (esc *endpointSliceController) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget { eps := esc.slices.List(proxy.Metadata.Namespace, endpointSliceSelector) var out []model.ServiceTarget for _, ep := range eps { instances := esc.serviceTargets(ep, proxy) out = append(out, instances...) } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/model/context.go
PrevMergedGateway *PrevMergedGateway // ServiceTargets contains a list of all Services associated with the proxy, contextualized for this particular proxy. // These are unique to this proxy, as the port information is specific to it - while a ServicePort is shared with the // service, the target port may be distinct per-endpoint. So this maintains a view specific to this proxy.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
pilot/pkg/model/service.go
// will return an empty slice. // // There are two reasons why this returns multiple ServiceTargets instead of one: // - A ServiceTargets has a single Port. But a Service // may have many ports. So a workload implementing such a Service would need // multiple ServiceTargets, one for each port. // - A single workload may implement multiple logical Services. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/lds.go
return nil } var out model.Resources mtlsPolicy := authn.NewMtlsPolicy(push, node.Metadata.Namespace, node.Labels, node.IsWaypointProxy()) serviceInstancesByPort := map[uint32]model.ServiceTarget{} for _, si := range node.ServiceTargets { serviceInstancesByPort[si.Port.TargetPort] = si } for _, name := range names { listenAddress := strings.TrimPrefix(name, grpcxds.ServerListenerNamePrefix)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
type buildClusterOpts struct { mesh *meshconfig.MeshConfig mutable *clusterWrapper policy *networking.TrafficPolicy port *model.Port serviceAccounts []string serviceTargets []model.ServiceTarget // Used for traffic across multiple network clusters // the east-west gateway in a remote cluster will use this value to route // traffic to the appropriate service istioMtlsSni string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
gwsvcs := strings.Split(gwsvcstr, ",") known := sets.New[string](gwsvcs...) matchingInstances := make([]ServiceTarget, 0, len(proxy.ServiceTargets)) for _, si := range proxy.ServiceTargets { if _, f := known[string(si.Service.Hostname)]; f && si.Service.Attributes.Namespace == cfg.Namespace { matchingInstances = append(matchingInstances, si) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)