- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for serviceTargets (0.43 sec)
-
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) -
pilot/pkg/networking/core/gateway_test.go
gateways []config.Config virtualServices []config.Config expectedListeners []string }{ { "targetPort overrides service port", &pilot_model.Proxy{ ServiceTargets: []pilot_model.ServiceTarget{ { Service: &pilot_model.Service{ Hostname: "test", }, Port: pilot_model.ServiceInstancePort{ ServicePort: &pilot_model.Port{ Port: 80,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 144K bytes - Viewed (0) -
pilot/pkg/model/policyattachment_test.go
IsWaypoint: false, } sampleWaypoint := WorkloadPolicyMatcher{ Namespace: "default", WorkloadLabels: labels.Instance{ constants.GatewayNameLabel: "sample-waypoint", }, IsWaypoint: true, } serviceTarget := WorkloadPolicyMatcher{ Namespace: "default", WorkloadLabels: labels.Instance{ "app": "my-app", constants.GatewayNameLabel: "sample-waypoint", }, IsWaypoint: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
// 'in' services. func (sd *ServiceDiscovery) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget { sd.mutex.Lock() defer sd.mutex.Unlock() if sd.WantGetProxyServiceTargets != nil { return sd.WantGetProxyServiceTargets } out := make([]model.ServiceTarget, 0) for _, ip := range node.IPAddresses { si, found := sd.ip2instance[ip] if found {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
return !r.Cluster().Equals(nodeClusterID) } // GetProxyServiceTargets lists service instances co-located with a given proxy func (c *Controller) GetProxyServiceTargets(node *model.Proxy) []model.ServiceTarget { out := make([]model.ServiceTarget, 0) nodeClusterID := nodeClusterID(node) for _, r := range c.GetRegistries() { if skipSearchingRegistryForProxy(nodeClusterID, r) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
ClusterID: clusterID, Labels: map[string]string{ "app": "prod-app", label.SecurityTlsMode.Name: "mutual", }, }, }) expected := model.ServiceTarget{ Service: &model.Service{ Hostname: "svc1.nsa.svc.company.com", ClusterVIPs: model.AddressMap{ Addresses: map[cluster.ID][]string{clusterID: {"10.0.0.1"}}, }, DefaultAddress: "10.0.0.1",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
name string direction model.TrafficDirection cluster *cluster.Cluster svcInsts []model.ServiceTarget service *model.Service want *core.Metadata }{ { name: "no cluster", direction: model.TrafficDirectionInbound, cluster: nil, svcInsts: []model.ServiceTarget{ { Service: &model.Service{ Attributes: model.ServiceAttributes{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pilot/pkg/model/gateway_test.go
}, }, }, } svc := &Service{ Attributes: ServiceAttributes{ Labels: map[string]string{}, }, } gatewayServiceTargets := []ServiceTarget{ { Service: svc, Port: ServiceInstancePort{ ServicePort: &Port{Port: 80}, TargetPort: 80, }, }, { Service: svc, Port: ServiceInstancePort{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 02:36:23 UTC 2024 - 9K bytes - Viewed (0)