@@ -28,7 +28,7 @@ func (n Node) DOTAttributes() []dot.Attribute {

 // The graph needs something in that location to track the information we have about the node, but the

 // backing object doesn't exist.

 type ExistenceChecker interface {

-	// Found returns true if the node represents an object that we don't have the backing object for

+	// Found returns false if the node represents an object that we don't have the backing object for

 	Found() bool

 }

@@ -11,6 +11,8 @@ import (

 	kubeedges "github.com/openshift/origin/pkg/api/kubegraph"

 	kubegraph "github.com/openshift/origin/pkg/api/kubegraph/nodes"

 	deploygraph "github.com/openshift/origin/pkg/deploy/graph/nodes"

+	routeedges "github.com/openshift/origin/pkg/route/graph"

+	routegraph "github.com/openshift/origin/pkg/route/graph/nodes"

 )

 // ServiceGroup is a service, the DeploymentConfigPipelines it covers, and lists of the other nodes that fulfill it

@@ -23,6 +25,8 @@ type ServiceGroup struct {

 	FulfillingDCs  []*deploygraph.DeploymentConfigNode

 	FulfillingRCs  []*kubegraph.ReplicationControllerNode

 	FulfillingPods []*kubegraph.PodNode

+

+	ExposingRoutes []*routegraph.RouteNode

 }

 // AllServiceGroups returns all the ServiceGroups that aren't in the excludes set and the set of covered NodeIDs

@@ -40,11 +44,11 @@ func AllServiceGroups(g osgraph.Graph, excludeNodeIDs IntSet) ([]ServiceGroup, I

 		services = append(services, service)

 	}

-	sort.Sort(SortedServiceGroups(services))

+	sort.Sort(ServiceGroupByObjectMeta(services))

 	return services, covered

 }

-// NewServiceGroup returns the ServiceGroup and a set of all the NodeIDs covered by the service service

+// NewServiceGroup returns the ServiceGroup and a set of all the NodeIDs covered by the service

 func NewServiceGroup(g osgraph.Graph, serviceNode *kubegraph.ServiceNode) (ServiceGroup, IntSet) {

 	covered := IntSet{}

 	covered.Insert(serviceNode.ID())

@@ -62,7 +66,17 @@ func NewServiceGroup(g osgraph.Graph, serviceNode *kubegraph.ServiceNode) (Servi

 			service.FulfillingRCs = append(service.FulfillingRCs, castContainer)

 		case *kubegraph.PodNode:

 			service.FulfillingPods = append(service.FulfillingPods, castContainer)

+		default:

+			util.HandleError(fmt.Errorf("unrecognized container: %v", castContainer))

+		}

+	}

+

+	for _, uncastServiceFulfiller := range g.PredecessorNodesByEdgeKind(serviceNode, routeedges.ExposedThroughRouteEdgeKind) {

+		container := osgraph.GetTopLevelContainerNode(g, uncastServiceFulfiller)

+		switch castContainer := container.(type) {

+		case *routegraph.RouteNode:

+			service.ExposingRoutes = append(service.ExposingRoutes, castContainer)

 		default:

 			util.HandleError(fmt.Errorf("unrecognized container: %v", castContainer))

 		}

@@ -86,11 +100,11 @@ func NewServiceGroup(g osgraph.Graph, serviceNode *kubegraph.ServiceNode) (Servi

 	return service, covered

 }

-type SortedServiceGroups []ServiceGroup

+type ServiceGroupByObjectMeta []ServiceGroup

-func (m SortedServiceGroups) Len() int      { return len(m) }

-func (m SortedServiceGroups) Swap(i, j int) { m[i], m[j] = m[j], m[i] }

-func (m SortedServiceGroups) Less(i, j int) bool {

+func (m ServiceGroupByObjectMeta) Len() int      { return len(m) }

+func (m ServiceGroupByObjectMeta) Swap(i, j int) { m[i], m[j] = m[j], m[i] }

+func (m ServiceGroupByObjectMeta) Less(i, j int) bool {

 	a, b := m[i], m[j]

 	return CompareObjectMeta(&a.Service.Service.ObjectMeta, &b.Service.Service.ObjectMeta)

 }

new file mode 100644

@@ -0,0 +1,15 @@

+apiVersion: v1

+kind: Route

+metadata:

+  creationTimestamp: 2015-10-13T10:13:11Z

+  labels:

+    route: lonely

+  name: lonely-route

+  resourceVersion: "260"

+  uid: 025407f7-7193-11e5-b84d-080027c5bfa9

+spec:

+  host: www.example.com

+  to:

+    kind: Service

+    name: frontend

+status: {}

new file mode 100644

@@ -0,0 +1,47 @@

+apiVersion: v1

+kind: List

+items:

+- apiVersion: v1

+  kind: Service

+  metadata:

+    creationTimestamp: 2015-10-13T10:13:11Z

+    labels:

+      test: missing-route-port

+    name: frontend

+    resourceVersion: "259"

+    selfLink: /api/v1/namespaces/test/services/frontend

+    uid: 024d82eb-7193-11e5-b84d-080027c5bfa9

+  spec:

+    clusterIP: 172.30.182.32

+    portalIP: 172.30.182.32

+    ports:

+    - name: web

+      port: 5432

+      protocol: TCP

+      targetPort: 8080

+    - name: web2

+      port: 5433

+      protocol: TCP

+      targetPort: 8080

+    selector:

+      name: frontend

+    sessionAffinity: None

+    type: ClusterIP

+  status:

+    loadBalancer: {}

+- apiVersion: v1

+  kind: Route

+  metadata:

+    creationTimestamp: 2015-10-13T10:13:11Z

+    labels:

+      test: missing-route-port

+    name: route-edge

+    resourceVersion: "260"

+    selfLink: /oapi/v1/namespaces/test/routes/route-edge

+    uid: 025407f7-7193-11e5-b84d-080027c5bfa9

+  spec:

+    host: www.example.com

+    to:

+      kind: Service

+      name: frontend

+  status: {}

@@ -19,6 +19,8 @@ import (

 	deploygraph "github.com/openshift/origin/pkg/deploy/graph/nodes"

 	imageapi "github.com/openshift/origin/pkg/image/api"

 	imagegraph "github.com/openshift/origin/pkg/image/graph/nodes"

+	routeapi "github.com/openshift/origin/pkg/route/api"

+	routegraph "github.com/openshift/origin/pkg/route/graph/nodes"

 )

 // typeToEnsureMethod stores types to Ensure*Node methods

@@ -55,6 +57,9 @@ func init() {

 	if err := RegisterEnsureNode(&kapi.ReplicationController{}, kubegraph.EnsureReplicationControllerNode); err != nil {

 		panic(err)

 	}

+	if err := RegisterEnsureNode(&routeapi.Route{}, routegraph.EnsureRouteNode); err != nil {

+		panic(err)

+	}

 }

 func RegisterEnsureNode(containedType, ensureFunction interface{}) error {

@@ -37,7 +37,17 @@ func EnsureServiceNode(g osgraph.MutableUniqueGraph, svc *kapi.Service) *Service

 	return osgraph.EnsureUnique(g,

 		ServiceNodeName(svc),

 		func(node osgraph.Node) graph.Node {

-			return &ServiceNode{node, svc}

+			return &ServiceNode{node, svc, true}

+		},

+	).(*ServiceNode)

+}

+

+// FindOrCreateSyntheticServiceNode returns the existing service node or creates a synthetic node in its place

+func FindOrCreateSyntheticServiceNode(g osgraph.MutableUniqueGraph, svc *kapi.Service) *ServiceNode {

+	return osgraph.EnsureUnique(g,

+		ServiceNodeName(svc),

+		func(node osgraph.Node) graph.Node {

+			return &ServiceNode{node, svc, false}

 		},

 	).(*ServiceNode)

 }

@@ -27,6 +27,8 @@ func ServiceNodeName(o *kapi.Service) osgraph.UniqueName {

 type ServiceNode struct {

 	osgraph.Node

 	*kapi.Service

+

+	IsFound bool

 }

 func (n ServiceNode) Object() interface{} {

@@ -45,6 +47,10 @@ func (*ServiceNode) Kind() string {

 	return ServiceNodeKind

 }

+func (n ServiceNode) Found() bool {

+	return n.IsFound

+}

+

 func PodNodeName(o *kapi.Pod) osgraph.UniqueName {

 	return osgraph.GetUniqueRuntimeObjectNodeName(PodNodeKind, o)

 }

@@ -35,6 +35,10 @@ import (

 	imageedges "github.com/openshift/origin/pkg/image/graph"

 	imagegraph "github.com/openshift/origin/pkg/image/graph/nodes"

 	projectapi "github.com/openshift/origin/pkg/project/api"

+	routeapi "github.com/openshift/origin/pkg/route/api"

+	routeedges "github.com/openshift/origin/pkg/route/graph"

+	routeanalysis "github.com/openshift/origin/pkg/route/graph/analysis"

+	routegraph "github.com/openshift/origin/pkg/route/graph/nodes"

 	"github.com/openshift/origin/pkg/util/errors"

 	"github.com/openshift/origin/pkg/util/parallel"

 )

@@ -63,6 +67,7 @@ func (d *ProjectStatusDescriber) MakeGraph(namespace string) (osgraph.Graph, set

 		&buildLoader{namespace: namespace, lister: d.C},

 		&isLoader{namespace: namespace, lister: d.C},

 		&dcLoader{namespace: namespace, lister: d.C},

+		&routeLoader{namespace: namespace, lister: d.C},

 	}

 	loadingFuncs := []func() error{}

 	for _, loader := range loaders {

@@ -103,6 +108,7 @@ func (d *ProjectStatusDescriber) MakeGraph(namespace string) (osgraph.Graph, set

 	deployedges.AddAllTriggerEdges(g)

 	deployedges.AddAllDeploymentEdges(g)

 	imageedges.AddAllImageStreamRefEdges(g)

+	routeedges.AddAllRouteEdges(g)

 	return g, forbiddenResources, nil

 }

@@ -138,6 +144,10 @@ func (d *ProjectStatusDescriber) Describe(namespace, name string) (string, error

 		fmt.Fprintf(out, describeProjectAndServer(project, d.Server))

 		for _, service := range services {

+			if !service.Service.Found() {

+				continue

+			}

+

 			fmt.Fprintln(out)

 			printLines(out, indent, 0, describeServiceInServiceGroup(service)...)

@@ -165,6 +175,10 @@ func (d *ProjectStatusDescriber) Describe(namespace, name string) (string, error

 				}

 				printLines(out, indent, 1, describePodInServiceGroup(podNode)...)

 			}

+

+			for _, routeNode := range service.ExposingRoutes {

+				printLines(out, indent, 1, describeRouteInServiceGroup(routeNode)...)

+			}

 		}

 		for _, standaloneDC := range standaloneDCs {

@@ -242,6 +256,7 @@ func getMarkerScanners() []osgraph.MarkerScanner {

 		kubeanalysis.FindMissingSecrets,

 		buildanalysis.FindUnpushableBuildConfigs,

 		buildanalysis.FindCircularBuilds,

+		routeanalysis.FindMissingPortMapping,

 	}

 }

@@ -275,7 +290,7 @@ func describeProjectAndServer(project *projectapi.Project, server string) string

 func describeDeploymentInServiceGroup(deploy graphview.DeploymentConfigPipeline) []string {

 	includeLastPass := deploy.ActiveDeployment == nil

 	if len(deploy.Images) == 1 {

-		lines := []string{fmt.Sprintf("dc/%s deploys %s %s", deploy.Deployment.Name, describeImageInPipeline(deploy.Images[0], deploy.Deployment.Namespace), describeDeploymentConfigTrigger(deploy.Deployment.DeploymentConfig))}

+		lines := []string{fmt.Sprintf("%s deploys %s %s", deploy.Deployment.ResourceString(), describeImageInPipeline(deploy.Images[0], deploy.Deployment.Namespace), describeDeploymentConfigTrigger(deploy.Deployment.DeploymentConfig))}

 		if len(lines[0]) > 120 && strings.Contains(lines[0], " <- ") {

 			segments := strings.SplitN(lines[0], " <- ", 2)

 			lines[0] = segments[0] + " <-"

@@ -286,7 +301,7 @@ func describeDeploymentInServiceGroup(deploy graphview.DeploymentConfigPipeline)

 		return lines

 	}

-	lines := []string{fmt.Sprintf("dc/%s deploys: %s", deploy.Deployment.Name, describeDeploymentConfigTrigger(deploy.Deployment.DeploymentConfig))}

+	lines := []string{fmt.Sprintf("%s deploys: %s", deploy.Deployment.ResourceString(), describeDeploymentConfigTrigger(deploy.Deployment.DeploymentConfig))}

 	for _, image := range deploy.Images {

 		lines = append(lines, describeImageInPipeline(image, deploy.Deployment.Namespace))

 		lines = append(lines, indentLines("  ", describeAdditionalBuildDetail(image.Build, image.LastSuccessfulBuild, image.LastUnsuccessfulBuild, image.ActiveBuilds, image.DestinationResolved, includeLastPass)...)...)

@@ -305,7 +320,7 @@ func describeRCInServiceGroup(rcNode *kubegraph.ReplicationControllerNode) []str

 		images = append(images, container.Image)

 	}

-	lines := []string{fmt.Sprintf("rc/%s runs %s", rcNode.ReplicationController.Name, strings.Join(images, ", "))}

+	lines := []string{fmt.Sprintf("%s runs %s", rcNode.ResourceString(), strings.Join(images, ", "))}

 	lines = append(lines, describeRCStatus(rcNode.ReplicationController))

 	return lines

@@ -317,10 +332,17 @@ func describePodInServiceGroup(podNode *kubegraph.PodNode) []string {

 		images = append(images, container.Image)

 	}

-	lines := []string{fmt.Sprintf("pod/%s runs %s", podNode.Pod.Name, strings.Join(images, ", "))}

+	lines := []string{fmt.Sprintf("%s runs %s", podNode.ResourceString(), strings.Join(images, ", "))}

 	return lines

 }

+func describeRouteInServiceGroup(routeNode *routegraph.RouteNode) []string {

+	if routeNode.Spec.Port != nil && len(routeNode.Spec.Port.TargetPort.String()) > 0 {

+		return []string{fmt.Sprintf("exposed by %s on pod port %s", routeNode.ResourceString(), routeNode.Spec.Port.TargetPort.String())}

+	}

+	return []string{fmt.Sprintf("exposed by %s", routeNode.ResourceString())}

+}

+

 func describeDeploymentConfigTrigger(dc *deployapi.DeploymentConfig) string {

 	if len(dc.Triggers) == 0 {

 		return "(manual)"

@@ -332,7 +354,7 @@ func describeDeploymentConfigTrigger(dc *deployapi.DeploymentConfig) string {

 func describeStandaloneBuildGroup(pipeline graphview.ImagePipeline, namespace string) []string {

 	switch {

 	case pipeline.Build != nil:

-		lines := []string{fmt.Sprintf("bc/%s %s", pipeline.Build.BuildConfig.Name, describeBuildInPipeline(pipeline.Build.BuildConfig, pipeline.BaseImage))}

+		lines := []string{fmt.Sprintf("%s %s", pipeline.Build.ResourceString(), describeBuildInPipeline(pipeline.Build.BuildConfig, pipeline.BaseImage))}

 		if pipeline.Image != nil {

 			lines = append(lines, fmt.Sprintf("pushes to %s", describeImageTagInPipeline(pipeline.Image, namespace)))

 		}

@@ -363,7 +385,7 @@ func describeImageTagInPipeline(image graphview.ImageTagLocation, namespace stri

 		if t.ImageStreamTag.Namespace != namespace {

 			return image.ImageSpec()

 		}

-		return "istag/" + t.ImageStreamTag.Name

+		return t.ResourceString()

 	default:

 		return image.ImageSpec()

 	}

@@ -672,11 +694,11 @@ func describeServiceInServiceGroup(svc graphview.ServiceGroup) []string {

 	port := describeServicePorts(spec)

 	switch {

 	case ip == "None":

-		return []string{fmt.Sprintf("service/%s (headless)%s", svc.Service.Name, port)}

+		return []string{fmt.Sprintf("%s (headless)%s", svc.Service.ResourceString(), port)}

 	case len(ip) == 0:

-		return []string{fmt.Sprintf("service/%s <initializing>%s", svc.Service.Name, port)}

+		return []string{fmt.Sprintf("%s <initializing>%s", svc.Service.ResourceString(), port)}

 	default:

-		return []string{fmt.Sprintf("service/%s - %s%s", svc.Service.Name, ip, port)}

+		return []string{fmt.Sprintf("%s - %s%s", svc.Service.ResourceString(), ip, port)}

 	}

 }

@@ -932,3 +954,27 @@ func (l *buildLoader) AddToGraph(g osgraph.Graph) error {

 	return nil

 }

+

+type routeLoader struct {

+	namespace string

+	lister    client.RoutesNamespacer

+	items     []routeapi.Route

+}

+

+func (l *routeLoader) Load() error {

+	list, err := l.lister.Routes(l.namespace).List(labels.Everything(), fields.Everything())

+	if err != nil {

+		return err

+	}

+

+	l.items = list.Items

+	return nil

+}

+

+func (l *routeLoader) AddToGraph(g osgraph.Graph) error {

+	for i := range l.items {

+		routegraph.EnsureRouteNode(g, &l.items[i])

+	}

+

+	return nil

+}

@@ -61,7 +61,7 @@ func TestProjectStatus(t *testing.T) {

 			ErrFn: func(err error) bool { return err == nil },

 			Contains: []string{

 				"In project example on server https://example.com:8443\n",

-				"service/empty-service",

+				"svc/empty-service",

 				"<initializing>:5432",

 				"To see more, use",

 			},

@@ -76,7 +76,7 @@ func TestProjectStatus(t *testing.T) {

 			ErrFn: func(err error) bool { return err == nil },

 			Contains: []string{

 				"In project example on server https://example.com:8443\n",

-				"service/database-rc",

+				"svc/database-rc",

 				"rc/database-rc-1 runs mysql",

 				"0/1 pods growing to 1",

 				"To see more, use",

@@ -122,7 +122,7 @@ func TestProjectStatus(t *testing.T) {

 			ErrFn: func(err error) bool { return err == nil },

 			Contains: []string{

 				"In project example on server https://example.com:8443\n",

-				"service/frontend-app",

+				"svc/frontend-app",

 				"pod/frontend-app-1-bjwh8 runs openshift/ruby-hello-world",

 				"To see more, use",

 			},

@@ -151,7 +151,7 @@ func TestProjectStatus(t *testing.T) {

 			ErrFn: func(err error) bool { return err == nil },

 			Contains: []string{

 				"In project example on server https://example.com:8443\n",

-				"service/sinatra-example-2 - 172.30.17.48:8080",

+				"svc/sinatra-example-2 - 172.30.17.48:8080",

 				"builds git://github.com",

 				"with docker.io/openshift/ruby-20-centos7:latest",

 				"not built yet",

@@ -193,7 +193,7 @@ func TestProjectStatus(t *testing.T) {

 			ErrFn: func(err error) bool { return err == nil },

 			Contains: []string{

 				"In project example on server https://example.com:8443\n",

-				"service/sinatra-example-1 - 172.30.17.47:8080",

+				"svc/sinatra-example-1 - 172.30.17.47:8080",

 				"builds git://github.com",

 				"with docker.io/openshift/ruby-20-centos7:latest",

 				"#1 build running for about a minute",

@@ -212,7 +212,7 @@ func TestProjectStatus(t *testing.T) {

 			ErrFn: func(err error) bool { return err == nil },

 			Contains: []string{

 				"In project example on server https://example.com:8443\n",

-				"service/sinatra-app-example - 172.30.17.49:8080",

+				"svc/sinatra-app-example - 172.30.17.49:8080",

 				"sinatra-app-example-a deploys",

 				"sinatra-app-example-b deploys",

 				"with docker.io/openshift/ruby-20-centos7:latest",

@@ -232,8 +232,9 @@ func TestProjectStatus(t *testing.T) {

 			ErrFn: func(err error) bool { return err == nil },

 			Contains: []string{

 				"In project example on server https://example.com:8443\n",

-				"service/database - 172.30.17.240:5434 -> 3306",

-				"service/frontend - 172.30.17.154:5432 -> 8080",

+				"svc/database - 172.30.17.240:5434 -> 3306",

+				"exposed by route/frontend on pod port 8080",

+				"svc/frontend - 172.30.17.154:5432 -> 8080",

 				"database deploys",

 				"frontend deploys",

 				"with docker.io/openshift/ruby-20-centos7:latest",

@@ -18,5 +18,4 @@ Kubernetes Service port and let it do the load balancing and routing. Alternatel

 a more meaningful implementation of a router could take the endpoints for the service

 and route/load balance the incoming requests to the corresponding service endpoints.

 */

-

 package route

new file mode 100644

@@ -0,0 +1,65 @@

+package analysis

+

+import (

+	"fmt"

+

+	"github.com/gonum/graph"

+

+	osgraph "github.com/openshift/origin/pkg/api/graph"

+	kubegraph "github.com/openshift/origin/pkg/api/kubegraph/nodes"

+	routeedges "github.com/openshift/origin/pkg/route/graph"

+	routegraph "github.com/openshift/origin/pkg/route/graph/nodes"

+)

+

+const (

+	// MissingRoutePortWarning is returned when a route has no route port specified

+	// and the service it routes to has multiple ports.

+	MissingRoutePortWarning = "MissingRoutePort"

+	// MissingServiceWarning is returned when there is no service for the specific route.

+	MissingServiceWarning = "MissingService"

+)

+

+// FindMissingPortMapping checks all routes and reports those that don't specify a port while

+// the service they are routing to, has multiple ports. Also if a service for a route doesn't

+// exist, will be reported.

+func FindMissingPortMapping(g osgraph.Graph) []osgraph.Marker {

+	markers := []osgraph.Marker{}

+

+route:

+	for _, uncastRouteNode := range g.NodesByKind(routegraph.RouteNodeKind) {

+		for _, uncastServiceNode := range g.SuccessorNodesByEdgeKind(uncastRouteNode, routeedges.ExposedThroughRouteEdgeKind) {

+			routeNode := uncastRouteNode.(*routegraph.RouteNode)

+			svcNode := uncastServiceNode.(*kubegraph.ServiceNode)

+

+			if !svcNode.Found() {

+				markers = append(markers, osgraph.Marker{

+					Node:         routeNode,

+					RelatedNodes: []graph.Node{svcNode},

+

+					Severity: osgraph.WarningSeverity,

+					Key:      MissingServiceWarning,

+					Message: fmt.Sprintf("%s is supposed to route traffic to %s but %s doesn't exist.",

+						routeNode.ResourceString(), svcNode.ResourceString(), svcNode.ResourceString()),

+				})

+

+				continue route

+			}

+

+			if len(svcNode.Spec.Ports) > 1 && (routeNode.Spec.Port == nil || len(routeNode.Spec.Port.TargetPort.String()) == 0) {

+				markers = append(markers, osgraph.Marker{

+					Node:         routeNode,

+					RelatedNodes: []graph.Node{svcNode},

+

+					Severity: osgraph.WarningSeverity,

+					Key:      MissingRoutePortWarning,

+					Message: fmt.Sprintf("%s doesn't have a port specified and is routing traffic to %s which uses multiple ports.",

+						routeNode.ResourceString(), svcNode.ResourceString()),

+				})

+

+				continue route

+			}

+		}

+	}

+

+	return markers

+}

new file mode 100644

@@ -0,0 +1,40 @@

+package analysis

+

+import (

+	"testing"

+

+	osgraphtest "github.com/openshift/origin/pkg/api/graph/test"

+	routeedges "github.com/openshift/origin/pkg/route/graph"

+)

+

+func TestMissingPortMapping(t *testing.T) {

+	// Multiple service ports - no route port specified

+	g, _, err := osgraphtest.BuildGraph("../../../api/graph/test/missing-route-port.yaml")

+	if err != nil {

+		t.Fatalf("unexpected error: %v", err)

+	}

+	routeedges.AddAllRouteEdges(g)

+

+	markers := FindMissingPortMapping(g)

+	if expected, got := 1, len(markers); expected != got {

+		t.Fatalf("expected %d markers, got %d", expected, got)

+	}

+	if expected, got := MissingRoutePortWarning, markers[0].Key; expected != got {

+		t.Fatalf("expected %s marker key, got %s", expected, got)

+	}

+

+	// Dangling route

+	g, _, err = osgraphtest.BuildGraph("../../../api/graph/test/lonely-route.yaml")

+	if err != nil {

+		t.Fatalf("unexpected error: %v", err)

+	}

+	routeedges.AddAllRouteEdges(g)

+

+	markers = FindMissingPortMapping(g)

+	if expected, got := 1, len(markers); expected != got {

+		t.Fatalf("expected %d markers, got %d", expected, got)

+	}

+	if expected, got := MissingServiceWarning, markers[0].Key; expected != got {

+		t.Fatalf("expected %s marker key, got %s", expected, got)

+	}

+}

new file mode 100644

@@ -0,0 +1,3 @@

+// Package analysis provides functions that analyse routes and setup markers

+// that will be reported by oc status

+package analysis

new file mode 100644

@@ -0,0 +1,2 @@

+// Package graph contains graph utilities for routes

+package graph

new file mode 100644

@@ -0,0 +1,36 @@

+package graph

+

+import (

+	"github.com/gonum/graph"

+

+	kapi "k8s.io/kubernetes/pkg/api"

+

+	osgraph "github.com/openshift/origin/pkg/api/graph"

+	kubegraph "github.com/openshift/origin/pkg/api/kubegraph/nodes"

+	routegraph "github.com/openshift/origin/pkg/route/graph/nodes"

+)

+

+const (

+	// ExposedThroughRouteEdgeKind is an edge from a route to any object that

+	// is exposed through routes

+	ExposedThroughRouteEdgeKind = "ExposedThroughRoute"

+)

+

+// AddRouteEdges adds an edge that connect a service to a route in the given graph

+func AddRouteEdges(g osgraph.MutableUniqueGraph, node *routegraph.RouteNode) {

+	syntheticService := &kapi.Service{}

+	syntheticService.Namespace = node.Namespace

+	syntheticService.Name = node.Spec.To.Name

+

+	serviceNode := kubegraph.FindOrCreateSyntheticServiceNode(g, syntheticService)

+	g.AddEdge(node, serviceNode, ExposedThroughRouteEdgeKind)

+}

+

+// AddAllRouteEdges adds service edges to all route nodes in the given graph

+func AddAllRouteEdges(g osgraph.MutableUniqueGraph) {

+	for _, node := range g.(graph.Graph).Nodes() {

+		if routeNode, ok := node.(*routegraph.RouteNode); ok {

+			AddRouteEdges(g, routeNode)

+		}

+	}

+}

new file mode 100644

@@ -0,0 +1,2 @@

+// Package nodes contains graph functions and types for routes

+package nodes

new file mode 100644

@@ -0,0 +1,22 @@

+package nodes

+

+import (

+	"github.com/gonum/graph"

+

+	osgraph "github.com/openshift/origin/pkg/api/graph"

+	routeapi "github.com/openshift/origin/pkg/route/api"

+)

+

+// EnsureRouteNode adds a graph node for the specific route if it does not exist

+func EnsureRouteNode(g osgraph.MutableUniqueGraph, route *routeapi.Route) *RouteNode {

+	return osgraph.EnsureUnique(

+		g,

+		RouteNodeName(route),

+		func(node osgraph.Node) graph.Node {

+			return &RouteNode{

+				Node:  node,

+				Route: route,

+			}

+		},

+	).(*RouteNode)

+}

new file mode 100644

@@ -0,0 +1,37 @@

+package nodes

+

+import (

+	"reflect"

+

+	osgraph "github.com/openshift/origin/pkg/api/graph"

+	routeapi "github.com/openshift/origin/pkg/route/api"

+)

+

+var (

+	RouteNodeKind = reflect.TypeOf(routeapi.Route{}).Name()

+)

+

+func RouteNodeName(o *routeapi.Route) osgraph.UniqueName {

+	return osgraph.GetUniqueRuntimeObjectNodeName(RouteNodeKind, o)

+}

+

+type RouteNode struct {

+	osgraph.Node

+	*routeapi.Route

+}

+

+func (n RouteNode) Object() interface{} {

+	return n.Route

+}

+

+func (n RouteNode) String() string {

+	return string(RouteNodeName(n.Route))

+}

+

+func (n RouteNode) ResourceString() string {

+	return "route/" + n.Name

+}

+

+func (*RouteNode) Kind() string {

+	return RouteNodeKind

+}

@@ -470,6 +470,24 @@ items:

     type: ClusterIP

   status:

     loadBalancer: {}

+- apiVersion: v1beta3

+  kind: Route

+  metadata:

+    annotations:

+      openshift.io/host.generated: "true"

+    creationTimestamp: 2015-04-07T04:12:17Z

+    labels:

+      template: application-template-stibuild

+    name: frontend

+    namespace: example

+    resourceVersion: "393"

+  spec:

+    host: frontend-example.router.default.svc.cluster.local

+    port:

+      targetPort: 8080

+    to:

+      kind: Service

+      name: frontend

 kind: List

 metadata:

   resourceVersion: "592"