Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ServiceInstanceToTarget (0.4 sec)

  1. pilot/pkg/serviceregistry/memory/discovery.go

    	}
    	out := make([]model.ServiceTarget, 0)
    	for _, ip := range node.IPAddresses {
    		si, found := sd.ip2instance[ip]
    		if found {
    			out = append(out, slices.Map(si, model.ServiceInstanceToTarget)...)
    		}
    	}
    	return out
    }
    
    func (sd *ServiceDiscovery) GetProxyWorkloadLabels(proxy *model.Proxy) labels.Instance {
    	sd.mutex.Lock()
    	defer sd.mutex.Unlock()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 23:10:01 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/controller.go

    			// control.
    			if node.Metadata.Namespace == "" || i.Service.Attributes.Namespace == node.Metadata.Namespace {
    				out = append(out, model.ServiceInstanceToTarget(i))
    			}
    		}
    	}
    	return out
    }
    
    func (s *Controller) GetProxyWorkloadLabels(proxy *model.Proxy) labels.Instance {
    	s.mutex.RLock()
    	defer s.mutex.RUnlock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/controller.go

    					targetPort.num = servicePort.Port
    				}
    
    				instance := serviceInstanceFromWorkloadInstance(service, servicePort, targetPort, si)
    				if instance != nil {
    					out = append(out, model.ServiceInstanceToTarget(instance))
    				}
    			}
    		}
    	}
    	return out
    }
    
    // WorkloadInstanceHandler defines the handler for service instances generated by other registries
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  4. pilot/pkg/model/service.go

    	ServiceInstancePort struct {
    		ServicePort
    		TargetPort uint32
    	}
    )
    
    func ServiceInstanceToTarget(e *ServiceInstance) ServiceTarget {
    	return ServiceTarget{
    		Service: e.Service,
    		Port: ServiceInstancePort{
    			ServicePort: e.ServicePort,
    			TargetPort:  e.Endpoint.EndpointPort,
    		},
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    			}
    		})
    	}
    }
    
    func expectProxyInstances(t testing.TB, sd *Controller, expected []*model.ServiceInstance, ip string) {
    	t.Helper()
    	expectProxyTargets(t, sd, slices.Map(expected, model.ServiceInstanceToTarget), ip)
    }
    
    func expectProxyTargets(t testing.TB, sd *Controller, expected []model.ServiceTarget, ip string) {
    	t.Helper()
    	// The system is eventually consistent, so add some retries
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
Back to top