Route controller uses v1 APIs (#6855)

pkg/apis/serving/v1/route_lifecycle.go

@@ -17,9 +17,14 @@ limitations under the License.
 package v1
 
 import (
+	"fmt"
+
+	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 
 	"knative.dev/pkg/apis"
+	duckv1 "knative.dev/pkg/apis/duck/v1"
+	"knative.dev/serving/pkg/apis/networking/v1alpha1"
 )
 
 var routeCondSet = apis.NewLivingConditionSet(
@@ -41,3 +46,119 @@ func (rs *RouteStatus) IsReady() bool {
 func (rs *RouteStatus) InitializeConditions() {
 	routeCondSet.Manage(rs).InitializeConditions()
 }
+
+// MarkServiceNotOwned changes the IngressReady status to be false with the reason being that
+// there is a pre-existing placeholder service with the name we wanted to use.
+func (rs *RouteStatus) MarkServiceNotOwned(name string) {
+	routeCondSet.Manage(rs).MarkFalse(RouteConditionIngressReady, "NotOwned",
+		fmt.Sprintf("There is an existing placeholder Service %q that we do not own.", name))
+}
+
+// MarkIngressNotConfigured changes the IngressReady condition to be unknown to reflect
+// that the Ingress does not yet have a Status
+func (rs *RouteStatus) MarkIngressNotConfigured() {
+	routeCondSet.Manage(rs).MarkUnknown(RouteConditionIngressReady,
+		"IngressNotConfigured", "Ingress has not yet been reconciled.")
+}
+
+func (rs *RouteStatus) MarkTrafficAssigned() {
+	routeCondSet.Manage(rs).MarkTrue(RouteConditionAllTrafficAssigned)
+}
+
+func (rs *RouteStatus) MarkUnknownTrafficError(msg string) {
+	routeCondSet.Manage(rs).MarkUnknown(RouteConditionAllTrafficAssigned, "Unknown", msg)
+}
+
+func (rs *RouteStatus) MarkConfigurationNotReady(name string) {
+	routeCondSet.Manage(rs).MarkUnknown(RouteConditionAllTrafficAssigned,
+		"RevisionMissing",
+		"Configuration %q is waiting for a Revision to become ready.", name)
+}
+
+func (rs *RouteStatus) MarkConfigurationFailed(name string) {
+	routeCondSet.Manage(rs).MarkFalse(RouteConditionAllTrafficAssigned,
+		"RevisionMissing",
+		"Configuration %q does not have any ready Revision.", name)
+}
+
+func (rs *RouteStatus) MarkRevisionNotReady(name string) {
+	routeCondSet.Manage(rs).MarkUnknown(RouteConditionAllTrafficAssigned,
+		"RevisionMissing",
+		"Revision %q is not yet ready.", name)
+}
+
+func (rs *RouteStatus) MarkRevisionFailed(name string) {
+	routeCondSet.Manage(rs).MarkFalse(RouteConditionAllTrafficAssigned,
+		"RevisionMissing",
+		"Revision %q failed to become ready.", name)
+}
+
+func (rs *RouteStatus) MarkMissingTrafficTarget(kind, name string) {
+	routeCondSet.Manage(rs).MarkFalse(RouteConditionAllTrafficAssigned,
+		kind+"Missing",
+		"%s %q referenced in traffic not found.", kind, name)
+}
+
+func (rs *RouteStatus) MarkCertificateProvisionFailed(name string) {
+	routeCondSet.Manage(rs).SetCondition(apis.Condition{
+		Type:     RouteConditionCertificateProvisioned,
+		Status:   corev1.ConditionFalse,
+		Severity: apis.ConditionSeverityWarning,
+		Reason:   "CertificateProvisionFailed",
+		Message:  fmt.Sprintf("Certificate %s fails to be provisioned.", name),
+	})
+}
+
+func (rs *RouteStatus) MarkCertificateReady(name string) {
+	routeCondSet.Manage(rs).SetCondition(apis.Condition{
+		Type:     RouteConditionCertificateProvisioned,
+		Status:   corev1.ConditionTrue,
+		Severity: apis.ConditionSeverityWarning,
+		Reason:   "CertificateReady",
+		Message:  fmt.Sprintf("Certificate %s is successfully provisioned", name),
+	})
+}
+
+func (rs *RouteStatus) MarkCertificateNotReady(name string) {
+	routeCondSet.Manage(rs).SetCondition(apis.Condition{
+		Type:     RouteConditionCertificateProvisioned,
+		Status:   corev1.ConditionUnknown,
+		Severity: apis.ConditionSeverityWarning,
+		Reason:   "CertificateNotReady",
+		Message:  fmt.Sprintf("Certificate %s is not ready.", name),
+	})
+}
+
+func (rs *RouteStatus) MarkCertificateNotOwned(name string) {
+	routeCondSet.Manage(rs).SetCondition(apis.Condition{
+		Type:     RouteConditionCertificateProvisioned,
+		Status:   corev1.ConditionFalse,
+		Severity: apis.ConditionSeverityWarning,
+		Reason:   "CertificateNotOwned",
+		Message:  fmt.Sprintf("There is an existing certificate %s that we don't own.", name),
+	})
+}
+
+// PropagateIngressStatus update RouteConditionIngressReady condition
+// in RouteStatus according to IngressStatus.
+func (rs *RouteStatus) PropagateIngressStatus(cs v1alpha1.IngressStatus) {
+	cc := cs.GetCondition(v1alpha1.IngressConditionReady)
+	if cc == nil {
+		rs.MarkIngressNotConfigured()
+		return
+	}
+
+	m := routeCondSet.Manage(rs)
+	switch cc.Status {
+	case corev1.ConditionTrue:
+		m.MarkTrue(RouteConditionIngressReady)
+	case corev1.ConditionFalse:
+		m.MarkFalse(RouteConditionIngressReady, cc.Reason, cc.Message)
+	case corev1.ConditionUnknown:
+		m.MarkUnknown(RouteConditionIngressReady, cc.Reason, cc.Message)
+	}
+}
+
+func (rs *RouteStatus) duck() *duckv1.Status {
+	return &rs.Status
+}