- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for serviceTargets (0.35 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/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/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/serviceregistry/kube/controller/controller.go
} // GetProxyServiceTargetsFromMetadata retrieves ServiceTargets using proxy Metadata rather than // from the Pod. This allows retrieving Instances immediately, regardless of delays in Kubernetes. // If the proxy doesn't have enough metadata, an error is returned func (c *Controller) GetProxyServiceTargetsFromMetadata(proxy *model.Proxy) ([]model.ServiceTarget, error) { if len(proxy.Labels) == 0 { return nil, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
ingressPortListSet := sets.New[int]() sidecarScope := lb.node.SidecarScope if sidecarScope.HasIngressListener() { ingressPortListSet = getSidecarIngressPortList(lb.node) } for _, i := range lb.node.ServiceTargets { bindToPort := getBindToPort(networking.CaptureMode_DEFAULT, lb.node) // Skip ports we cannot bind to if !lb.node.CanBindToPort(bindToPort, i.Port.TargetPort) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
return nil } func (s *DiscoveryServer) instancesz(w http.ResponseWriter, req *http.Request) { instances := map[string][]model.ServiceTarget{} for _, con := range s.Clients() { con.proxy.RLock() if con.proxy != nil { instances[con.proxy.ID] = con.proxy.ServiceTargets } con.proxy.RUnlock() } writeJSON(w, instances, req) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0)