[To be split] Make broker ingress/filter be able to use knative service

Gopkg.toml

@@ -39,6 +39,10 @@ required = [
   name = "knative.dev/pkg"
   branch = "master"
 
+[[override]]
+  name = "knative.dev/serving"
+  branch = "master"
+
 # TODO why is this overridden?
 [[override]]
   name = "gopkg.in/yaml.v2"
@@ -120,7 +124,7 @@ required = [
 
 [[constraint]]
   name = "github.com/tsenart/vegeta"
-  version = "12.7.0"
+  branch = "master"
 
 [[constraint]]
   name = "contrib.go.opencensus.io/exporter/ocagent"

config/core/deployments/controller.yaml

@@ -64,6 +64,10 @@ spec:
             value: eventing-broker-filter
           - name: BROKER_IMAGE_PULL_SECRET_NAME
             value:
+          # Uncomment the following to use knative service for
+          # broker components.
+          # - name: BROKER_RESOURCE_FLAVOR
+          #   value: knative
           # Legacy CronJobSource
           - name: CRONJOB_RA_IMAGE
             value: knative.dev/eventing/cmd/cronjob_receive_adapter

config/core/roles/controller-clusterroles.yaml

@@ -51,6 +51,13 @@ rules:
       - "rolebindings"
     verbs: *everything
 
+  # To make use knative serving API.
+  - apiGroups:
+      - serving.knative.dev
+    resources:
+      - services
+    verbs: *everything
+
   # Our own resources and statuses we care about.
   - apiGroups:
       - "eventing.knative.dev"

pkg/apis/eventing/v1alpha1/broker_lifecycle.go

@@ -66,6 +66,10 @@ func (bs *BrokerStatus) MarkIngressFailed(reason, format string, args ...interfa
 	brokerCondSet.Manage(bs).MarkFalse(BrokerConditionIngress, reason, format, args...)
 }
 
+func (bs *BrokerStatus) MarkIngressReady() {
+	brokerCondSet.Manage(bs).MarkTrue(BrokerConditionIngress)
+}
+
 func (bs *BrokerStatus) PropagateIngressDeploymentAvailability(d *appsv1.Deployment) {
 	if duck.DeploymentIsAvailable(&d.Status, true) {
 		brokerCondSet.Manage(bs).MarkTrue(BrokerConditionIngress)
@@ -94,6 +98,10 @@ func (bs *BrokerStatus) MarkFilterFailed(reason, format string, args ...interfac
 	brokerCondSet.Manage(bs).MarkFalse(BrokerConditionFilter, reason, format, args...)
 }
 
+func (bs *BrokerStatus) MarkFilterReady() {
+	brokerCondSet.Manage(bs).MarkTrue(BrokerConditionFilter)
+}
+
 func (bs *BrokerStatus) PropagateFilterDeploymentAvailability(d *appsv1.Deployment) {
 	if duck.DeploymentIsAvailable(&d.Status, true) {
 		brokerCondSet.Manage(bs).MarkTrue(BrokerConditionFilter)