- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for ServiceTargets (0.34 sec)
-
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) -
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
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) } func (s *DiscoveryServer) networkz(w http.ResponseWriter, req *http.Request) { if s.Env == nil || s.Env.NetworkManager == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0)