- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for ServiceTargets (0.38 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/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/serviceregistry/kube/controller/endpointslice.go
var out []model.ServiceTarget for _, ep := range eps { instances := esc.serviceTargets(ep, proxy) out = append(out, instances...) } return out } func serviceNameForEndpointSlice(labels map[string]string) string { return labels[v1.LabelServiceName] } func (esc *endpointSliceController) serviceTargets(ep *v1.EndpointSlice, proxy *model.Proxy) []model.ServiceTarget { var out []model.ServiceTarget
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/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
} 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
clusters := make([]*cluster.Cluster, 0) resources := model.Resources{} envoyFilterPatches := req.Push.EnvoyFilters(proxy) cb := NewClusterBuilder(proxy, req, configgen.Cache) instances := proxy.ServiceTargets cacheStats := cacheStats{} switch proxy.Type { case model.SidecarProxy: // Setup outbound clusters outboundPatcher := clusterPatcher{efw: envoyFilterPatches, pctx: networking.EnvoyFilter_SIDECAR_OUTBOUND}
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)