Method ServiceEndpointsByPort

pilot/pkg/model/push_context.go:2522–2558

ServiceEndpointsByPort returns the cached instances by port if it exists.

(svc *Service, port int, labels labels.Instance)

// ServiceEndpointsByPort returns the cached instances by port if it exists.
func (ps *PushContext) ServiceEndpointsByPort(svc *Service, port int, labels labels.Instance) []*IstioEndpoint {
	var out []*IstioEndpoint

	// For InferencePool services, return ALL endpoints regardless of port
	// because they may have different target ports but belong to the same cluster
	if svc.UseInferenceSemantics() {
		allPorts := ps.ServiceIndex.instancesByPort[svc.Key()]
		for _, instances := range allPorts {
			if len(labels) == 0 {
				out = append(out, instances...)
				continue
			}
			for _, instance := range instances {
				if labels.SubsetOf(instance.Labels) {
					out = append(out, instance)
				}
			}
		}
		return out
	}

	if instances, exists := ps.ServiceIndex.instancesByPort[svc.Key()][port]; exists {
		// Use cached version of instances by port when labels are empty.
		if len(labels) == 0 {
			return instances
		}
		// If there are labels,	we will filter instances by pod labels.
		for _, instance := range instances {
			// check that one of the input labels is a subset of the labels
			if labels.SubsetOf(instance.Labels) {
				out = append(out, instance)
			}
		}
	}

	return out
}

// ServiceEndpoints returns the cached instances by svc if exists.
func (ps *PushContext) ServiceEndpoints(svcKey string) map[int][]*IstioEndpoint {