WIP Move the Service controller to use the new controller model.

Fixes: #1134

pkg/apis/serving/v1alpha1/revision_types.go

@@ -398,13 +398,12 @@ func (rs *RevisionStatus) MarkContainerMissing(message string) {
 }
 
 func (rs *RevisionStatus) checkAndMarkReady() {
-	ra := rs.GetCondition(RevisionConditionResourcesAvailable)
-	if ra == nil || ra.Status != corev1.ConditionTrue {
-		return
-	}
-	ch := rs.GetCondition(RevisionConditionContainerHealthy)
-	if ch == nil || ch.Status != corev1.ConditionTrue {
-		return
+	rct := []RevisionConditionType{RevisionConditionContainerHealthy, RevisionConditionResourcesAvailable}
+	for _, cond := range rct {
+		c := rs.GetCondition(cond)
+		if c == nil || c.Status != corev1.ConditionTrue {
+			return
+		}
 	}
 	rs.markReady()
 }

pkg/apis/serving/v1alpha1/service_types.go

@@ -99,6 +99,12 @@ const (
 	// ServiceConditionReady is set when the service is configured
 	// and has available backends ready to receive traffic.
 	ServiceConditionReady ServiceConditionType = "Ready"
+	// ServiceConditionRouteReady is set when the service's underlying
+	// route has reported readiness.
+	ServiceConditionRouteReady ServiceConditionType = "RouteReady"
+	// ServiceConditionConfigurationReady is set when the service's underlying
+	// configuration has reported readiness.
+	ServiceConditionConfigurationReady ServiceConditionType = "ConfigurationReady"
 )
 
 type ServiceStatus struct {
@@ -183,7 +189,8 @@ func (ss *ServiceStatus) RemoveCondition(t ServiceConditionType) {
 }
 
 func (ss *ServiceStatus) InitializeConditions() {
-	sct := []ServiceConditionType{ServiceConditionReady}
+	sct := []ServiceConditionType{ServiceConditionReady,
+		ServiceConditionConfigurationReady, ServiceConditionRouteReady}
 	for _, cond := range sct {
 		if rc := ss.GetCondition(cond); rc == nil {
 			ss.setCondition(&ServiceCondition{
@@ -193,3 +200,67 @@ func (ss *ServiceStatus) InitializeConditions() {
 		}
 	}
 }
+
+func (ss *ServiceStatus) PropagateConfiguration(cs ConfigurationStatus) {
+	cc := cs.GetCondition(ConfigurationConditionReady)
+	if cc == nil {
+		return
+	}
+	sct := []ServiceConditionType{ServiceConditionConfigurationReady}
+	// If the underlying Configuration reported failure, then bubble it up.
+	if cc.Status == corev1.ConditionFalse {
+		sct = append(sct, ServiceConditionReady)
+	}
+	for _, cond := range sct {
+		ss.setCondition(&ServiceCondition{
+			Type:    cond,
+			Status:  cc.Status,
+			Reason:  cc.Reason,
+			Message: cc.Message,
+		})
+	}
+	if cc.Status == corev1.ConditionTrue {
+		ss.checkAndMarkReady()
+	}
+}
+
+func (ss *ServiceStatus) PropagateRoute(rs RouteStatus) {
+	rc := rs.GetCondition(RouteConditionReady)
+	if rc == nil {
+		return
+	}
+	sct := []ServiceConditionType{ServiceConditionRouteReady}
+	// If the underlying Route reported failure, then bubble it up.
+	if rc.Status == corev1.ConditionFalse {
+		sct = append(sct, ServiceConditionReady)
+	}
+	for _, cond := range sct {
+		ss.setCondition(&ServiceCondition{
+			Type:    cond,
+			Status:  rc.Status,
+			Reason:  rc.Reason,
+			Message: rc.Message,
+		})
+	}
+	if rc.Status == corev1.ConditionTrue {
+		ss.checkAndMarkReady()
+	}
+}
+
+func (ss *ServiceStatus) checkAndMarkReady() {
+	sct := []ServiceConditionType{ServiceConditionConfigurationReady, ServiceConditionRouteReady}
+	for _, cond := range sct {
+		c := ss.GetCondition(cond)
+		if c == nil || c.Status != corev1.ConditionTrue {
+			return
+		}
+	}
+	ss.markReady()
+}
+
+func (ss *ServiceStatus) markReady() {
+	ss.setCondition(&ServiceCondition{
+		Type:   ServiceConditionReady,
+		Status: corev1.ConditionTrue,
+	})
+}

pkg/controller/configuration/configuration.go

@@ -44,7 +44,7 @@ type Controller struct {
 
 	buildClientSet buildclientset.Interface
 
-	// lister indexes properties about Configuration
+	// listers index properties about resources
 	lister         listers.ConfigurationLister
 	revisionLister listers.RevisionLister
 }

pkg/controller/names.go

@@ -72,6 +72,14 @@ func GetElaK8SServiceName(u *v1alpha1.Route) string {
 	return u.Name + "-service"
 }
 
+func GetServiceConfigurationName(u *v1alpha1.Service) string {
+	return u.Name
+}
+
+func GetServiceRouteName(u *v1alpha1.Service) string {
+	return u.Name
+}
+
 func GetElaK8SActivatorServiceName() string {
 	return "activator-service"
 }