registry/registry.go
func filterOwnedRecords(ownerID string, eps []*endpoint.Endpoint) []*endpoint.Endpoint {
	filtered := []*endpoint.Endpoint{}
	for _, ep := range eps {
		if endpointOwner, ok := ep.Labels[endpoint.OwnerLabelKey]; !ok || endpointOwner != ownerID {
			log.Debugf(`Skipping endpoint %v because owner id does not match, found: "%s", required: "%s"`, ep, endpointOwner, ownerID)
			continue
		}
		filtered = append(filtered, ep)
	}
	return filtered
}
func filterOwnedRecords(ownerID string, eps []*endpoint.Endpoint) []*endpoint.Endpoint {
	filtered := []*endpoint.Endpoint{}
	for _, ep := range eps {
		if endpointOwner, ok := ep.Labels[endpoint.OwnerLabelKey]; !ok || endpointOwner != ownerID {
			log.Debugf(`Skipping endpoint %v because owner id does not match, found: "%s", required: "%s"`, ep, endpointOwner, ownerID)
			continue
		}
		filtered = append(filtered, ep)
	}
	return filtered
}
func filterOwnedRecords ( ownerID string , eps [ ] * endpoint . Endpoint ) [ ] * endpoint . Endpoint { filtered := [ ] * endpoint . Endpoint { } for _ , ep := range eps { if endpointOwner , ok := ep . Labels [ endpoint . OwnerLabelKey ] ; ! ok || endpointOwner != ownerID { log . Debugf ( `Skipping endpoint %v because owner id does not match, found: "%s", required: "%s"` , ep , endpointOwner , ownerID ) continue } filtered = append ( filtered , ep ) } return filtered }
//TODO(ideahitme): consider moving this to Plan
TODO ( ideahitme ) : consider moving this to Plan