diff --git a/controller/destination/server.go b/controller/destination/server.go index 7e3ba082e..6d28c5258 100644 --- a/controller/destination/server.go +++ b/controller/destination/server.go @@ -85,12 +85,16 @@ func (s *server) Get(dest *common.Destination, stream pb.Destination_GetServer) } // service.namespace.svc.cluster.local domains := strings.Split(host, ".") - service := domains[0] - namespace := "default" - if len(domains) > 1 { - namespace = domains[1] + + if len(domains) < 2 { + err := fmt.Errorf("not a service: %s", host) + log.Error(err) + return err } + service := domains[0] + namespace := domains[1] + id := namespace + "/" + service listener := endpointListener{stream: stream}