coredns-headless

kubernetes.go

func (k *Kubernetes) findServices(r recordRequest, zone string) (services []msg.Service, err error) {
  idx := r.service + "." + r.namespace
  serviceList = k.APIConn.SvcIndex(idx)
  for _, svc := range serviceList {
    if svc.ClusterIP == api.ClusterIPNone || r.endpoint != "" {
      for _, ep := range endpointsList {
        for _, eps := range ep.Subsets {
          for _, addr := range eps.Addresses {
            for _, p := range eps.Ports {
              s := msg.Service{Host: addr.IP, Port: int(p.Port), TTL: k.ttl}
              err = nil
              services = append(services, s)
            }
          }
        }
      }
    }
  }
  return services, err
}