Repository: knative-sandbox/eventing-kafka-broker
Pull request #101 (2020-08-16 15:48:17)

Migrate reconcilers to use eventing.* v1
## Proposed Changes

- Migrate reconcilers (Broker and Trigger) to use eventing.* v1

knative-prow-robot: [APPROVALNOTIFIER] This PR is **NOT APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/101#" title="Author self-approved">pierDipi</a>*
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please assign **grantr**
You can assign the PR to them by writing `/assign @grantr` in a comment when ready.

The full list of commands accepted by this bot can be found [here](https://go.k8s.io/bot-commands?repo=knative-sandbox%2Feventing-kafka-broker).

<details open>
Needs approval from an approver in each of these files:

- **[OWNERS](https://github.com/knative-sandbox/eventing-kafka-broker/blob/master/OWNERS)**

Approvers can indicate their approval by writing `/approve` in a comment
Approvers can cancel approval by writing `/approve cancel` in a comment
</details>
<!-- META={"approvers":["grantr"]} -->
knative-prow-robot: @pierDipi: The following test **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-broker-build-tests | 9642339ea5f88aa38ce4cacd9b03e05519e6af45 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/101/pull-knative-sandbox-eventing-kafka-broker-build-tests/1295024765857173505) | `/test pull-knative-sandbox-eventing-kafka-broker-build-tests`

[Full PR test history](https://gubernator.knative.dev/pr/knative-sandbox_eventing-kafka-broker/101). [Your PR dashboard](https://gubernator.knative.dev/pr/pierDipi).

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @pierDipi: The following test **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-broker-integration-tests | 085eb1cb80240babc97ec86fc5fd964a5ce8f684 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/101/pull-knative-sandbox-eventing-kafka-broker-integration-tests/1295026653046509571) | `/test pull-knative-sandbox-eventing-kafka-broker-integration-tests`

[Full PR test history](https://gubernator.knative.dev/pr/knative-sandbox_eventing-kafka-broker/101). [Your PR dashboard](https://gubernator.knative.dev/pr/pierDipi).

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->

Patch:
diff --git a/control-plane/pkg/reconciler/broker/broker.go b/control-plane/pkg/reconciler/broker/broker.go
index b52eb15f2..0f03180d3 100644
--- a/control-plane/pkg/reconciler/broker/broker.go
+++ b/control-plane/pkg/reconciler/broker/broker.go
@@ -28,7 +28,7 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	corelisters "k8s.io/client-go/listers/core/v1"
 	"k8s.io/client-go/util/retry"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	"knative.dev/eventing/pkg/logging"
 	"knative.dev/pkg/controller"
 	"knative.dev/pkg/reconciler"
diff --git a/control-plane/pkg/reconciler/broker/broker_lifecycle.go b/control-plane/pkg/reconciler/broker/broker_lifecycle.go
index 30ff86ed3..82c366451 100644
--- a/control-plane/pkg/reconciler/broker/broker_lifecycle.go
+++ b/control-plane/pkg/reconciler/broker/broker_lifecycle.go
@@ -21,7 +21,7 @@ import (
 
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/client-go/tools/record"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	"knative.dev/eventing/pkg/reconciler/names"
 	"knative.dev/pkg/apis"
 	"knative.dev/pkg/reconciler"
diff --git a/control-plane/pkg/reconciler/broker/controller.go b/control-plane/pkg/reconciler/broker/controller.go
index 52c53166f..ca8e94253 100644
--- a/control-plane/pkg/reconciler/broker/controller.go
+++ b/control-plane/pkg/reconciler/broker/controller.go
@@ -24,15 +24,15 @@ import (
 	"go.uber.org/zap"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/tools/cache"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	"knative.dev/eventing/pkg/logging"
 	kubeclient "knative.dev/pkg/client/injection/kube/client"
 	"knative.dev/pkg/configmap"
 	"knative.dev/pkg/controller"
 	"knative.dev/pkg/resolver"
 
-	brokerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker"
-	brokerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/broker"
+	brokerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker"
+	brokerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/broker"
 	configmapinformer "knative.dev/pkg/client/injection/kube/informers/core/v1/configmap"
 	podinformer "knative.dev/pkg/client/injection/kube/informers/core/v1/pod"
 
diff --git a/control-plane/pkg/reconciler/broker/topic.go b/control-plane/pkg/reconciler/broker/topic.go
index da545d3cf..2a3438c18 100644
--- a/control-plane/pkg/reconciler/broker/topic.go
+++ b/control-plane/pkg/reconciler/broker/topic.go
@@ -21,7 +21,7 @@ import (
 
 	"github.com/Shopify/sarama"
 	"go.uber.org/zap"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 )
 
 func (r *Reconciler) CreateTopic(logger *zap.Logger, topic string, config *Config) (string, error) {
diff --git a/control-plane/pkg/reconciler/kafka/broker_class.go b/control-plane/pkg/reconciler/kafka/broker_class.go
index 75c3ff665..312b9d700 100644
--- a/control-plane/pkg/reconciler/kafka/broker_class.go
+++ b/control-plane/pkg/reconciler/kafka/broker_class.go
@@ -19,7 +19,7 @@ package kafka
 import (
 	pkgreconciler "knative.dev/pkg/reconciler"
 
-	brokerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/broker"
+	brokerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/broker"
 )
 
 const (
diff --git a/control-plane/pkg/reconciler/trigger/controller.go b/control-plane/pkg/reconciler/trigger/controller.go
index 40be43baf..bbea60a80 100644
--- a/control-plane/pkg/reconciler/trigger/controller.go
+++ b/control-plane/pkg/reconciler/trigger/controller.go
@@ -30,12 +30,12 @@ import (
 	"knative.dev/pkg/resolver"
 
 	apiseventing "knative.dev/eventing/pkg/apis/eventing"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	eventingclient "knative.dev/eventing/pkg/client/injection/client"
-	brokerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker"
-	triggerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger"
-	triggerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger"
-	eventinglisters "knative.dev/eventing/pkg/client/listers/eventing/v1beta1"
+	brokerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker"
+	triggerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger"
+	triggerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger"
+	eventinglisters "knative.dev/eventing/pkg/client/listers/eventing/v1"
 
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/base"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/broker"
diff --git a/control-plane/pkg/reconciler/trigger/trigger.go b/control-plane/pkg/reconciler/trigger/trigger.go
index e70adbc65..e1ea333c6 100644
--- a/control-plane/pkg/reconciler/trigger/trigger.go
+++ b/control-plane/pkg/reconciler/trigger/trigger.go
@@ -25,9 +25,9 @@ import (
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/util/retry"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	eventingclientset "knative.dev/eventing/pkg/client/clientset/versioned"
-	eventinglisters "knative.dev/eventing/pkg/client/listers/eventing/v1beta1"
+	eventinglisters "knative.dev/eventing/pkg/client/listers/eventing/v1"
 	"knative.dev/pkg/controller"
 	"knative.dev/pkg/reconciler"
 	"knative.dev/pkg/resolver"
@@ -39,8 +39,6 @@ import (
 )
 
 const (
-	trigger = "Trigger"
-
 	noTrigger = brokerreconciler.NoBroker
 )
 
@@ -207,7 +205,7 @@ func (r *Reconciler) reconcileKind(ctx context.Context, trigger *eventing.Trigge
 	if apierrors.IsNotFound(err) {
 
 		// Actually check if the broker doesn't exist.
-		broker, err = r.EventingClient.EventingV1beta1(). // Note: do not introduce another `broker` variable with `:`
+		broker, err = r.EventingClient.EventingV1(). // Note: do not introduce another `broker` variable with `:`
 									Brokers(trigger.Namespace).
 									Get(trigger.Spec.Broker, metav1.GetOptions{})
 
diff --git a/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go b/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go
index 0ed40db45..9d9f96889 100644
--- a/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go
+++ b/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go
@@ -21,7 +21,7 @@ import (
 
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/client-go/tools/record"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	"knative.dev/pkg/apis"
 	"knative.dev/pkg/reconciler"
 
diff --git a/data-plane/config/template/500-receiver.yaml b/data-plane/config/template/500-receiver.yaml
index 411eec468..349af00f0 100644
--- a/data-plane/config/template/500-receiver.yaml
+++ b/data-plane/config/template/500-receiver.yaml
@@ -126,5 +126,4 @@ spec:
       port: 80
       protocol: TCP
       targetPort: 8080
-  type: NodePort
 ---
diff --git a/go.mod b/go.mod
index 75fbaacfc..8d4e1d9bd 100644
--- a/go.mod
+++ b/go.mod
@@ -18,9 +18,9 @@ require (
 	k8s.io/client-go v11.0.1-0.20190805182717-6502b5e7b1b5+incompatible
 	k8s.io/kubernetes v1.14.7
 	k8s.io/utils v0.0.0-20200603063816-c1c6865ac451
-	knative.dev/eventing v0.16.1-0.20200812203106-45c93e360a11
-	knative.dev/pkg v0.0.0-20200811233205-6b7eccba3b9c
-	knative.dev/test-infra v0.0.0-20200811195106-afcd1747545f
+	knative.dev/eventing v0.16.1-0.20200818065713-9f3fb3ffde17
+	knative.dev/pkg v0.0.0-20200812224206-44c860147a87
+	knative.dev/test-infra v0.0.0-20200813220834-388e55a496cf
 )
 
 replace (
diff --git a/go.sum b/go.sum
index cd82a9c9e..67074d171 100644
--- a/go.sum
+++ b/go.sum
@@ -1851,8 +1851,8 @@ k8s.io/utils v0.0.0-20200603063816-c1c6865ac451 h1:v8ud2Up6QK1lNOKFgiIVrZdMg7Mpm
 k8s.io/utils v0.0.0-20200603063816-c1c6865ac451/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
 knative.dev/caching v0.0.0-20190719140829-2032732871ff/go.mod h1:dHXFU6CGlLlbzaWc32g80cR92iuBSpsslDNBWI8C7eg=
 knative.dev/caching v0.0.0-20200116200605-67bca2c83dfa/go.mod h1:dHXFU6CGlLlbzaWc32g80cR92iuBSpsslDNBWI8C7eg=
-knative.dev/eventing v0.16.1-0.20200812203106-45c93e360a11 h1:kZusigUJCz+ayHs7eLXLXDT6lok76CfKtacOEGNj00Y=
-knative.dev/eventing v0.16.1-0.20200812203106-45c93e360a11/go.mod h1:QW3WT6Z59vBzONzfkCM9A+KnAam9id3mh8/e7QmH2cc=
+knative.dev/eventing v0.16.1-0.20200818065713-9f3fb3ffde17 h1:3y7/7gMTsFAZtZzrqv3SpnNarQ2wl2Y4+A+qjADckOY=
+knative.dev/eventing v0.16.1-0.20200818065713-9f3fb3ffde17/go.mod h1:9NwCSwLnMCKmgz3YQBNax18mSgBjud8CvfsUUVOZ1sA=
 knative.dev/eventing-contrib v0.6.1-0.20190723221543-5ce18048c08b/go.mod h1:SnXZgSGgMSMLNFTwTnpaOH7hXDzTFtw0J8OmHflNx3g=
 knative.dev/eventing-contrib v0.11.2/go.mod h1:SnXZgSGgMSMLNFTwTnpaOH7hXDzTFtw0J8OmHflNx3g=
 knative.dev/pkg v0.0.0-20191101194912-56c2594e4f11/go.mod h1:pgODObA1dTyhNoFxPZTTjNWfx6F0aKsKzn+vaT9XO/Q=
@@ -1863,16 +1863,16 @@ knative.dev/pkg v0.0.0-20200505191044-3da93ebb24c2/go.mod h1:Q6sL35DdGs8hIQZKdaC
 knative.dev/pkg v0.0.0-20200515002500-16d7b963416f/go.mod h1:tMOHGbxtRz8zYFGEGpV/bpoTEM1o89MwYFC4YJXl3GY=
 knative.dev/pkg v0.0.0-20200528142800-1c6815d7e4c9/go.mod h1:QgNZTxnwpB/oSpNcfnLVlw+WpEwwyKAvJlvR3hgeltA=
 knative.dev/pkg v0.0.0-20200711004937-22502028e31a/go.mod h1:AqAJV6rYi8IGikDjJ/9ZQd9qKdkXVlesVnVjwx62YB8=
-knative.dev/pkg v0.0.0-20200811233205-6b7eccba3b9c h1:6bZkmyYu6towiuNw6WqOUkTrk8d2WhMzI7ku8ZLxgbI=
-knative.dev/pkg v0.0.0-20200811233205-6b7eccba3b9c/go.mod h1:udIbxBS/SJCL4sqnCG8HZArez9HjWmeqJCaVJP/h32I=
+knative.dev/pkg v0.0.0-20200812224206-44c860147a87 h1:argvd9DHJr2YeeV2pl1ogXPB3raIWnOqJivfBK/qsiM=
+knative.dev/pkg v0.0.0-20200812224206-44c860147a87/go.mod h1:udIbxBS/SJCL4sqnCG8HZArez9HjWmeqJCaVJP/h32I=
 knative.dev/test-infra v0.0.0-20200407185800-1b88cb3b45a5/go.mod h1:xcdUkMJrLlBswIZqL5zCuBFOC22WIPMQoVX1L35i0vQ=
 knative.dev/test-infra v0.0.0-20200505052144-5ea2f705bb55/go.mod h1:WqF1Azka+FxPZ20keR2zCNtiQA1MP9ZB4BH4HuI+SIU=
 knative.dev/test-infra v0.0.0-20200513011557-d03429a76034/go.mod h1:aMif0KXL4g19YCYwsy4Ocjjz5xgPlseYV+B95Oo4JGE=
 knative.dev/test-infra v0.0.0-20200519015156-82551620b0a9/go.mod h1:A5b2OAXTOeHT3hHhVQm3dmtbuWvIDP7qzgtqxA3/2pE=
 knative.dev/test-infra v0.0.0-20200707183444-aed09e56ddc7/go.mod h1:RjYAhXnZqeHw9+B0zsbqSPlae0lCvjekO/nw5ZMpLCs=
 knative.dev/test-infra v0.0.0-20200811030605-72f8c9f3e933/go.mod h1:Pmg2c7Z7q7BGFUV/GOpU5BlrD3ePJft4MPqx8AYBplc=
-knative.dev/test-infra v0.0.0-20200811195106-afcd1747545f h1:VLGSL2XW7xty70B+SWezfmi2KHb3/OaJW7DtFvTr5BU=
-knative.dev/test-infra v0.0.0-20200811195106-afcd1747545f/go.mod h1:Pmg2c7Z7q7BGFUV/GOpU5BlrD3ePJft4MPqx8AYBplc=
+knative.dev/test-infra v0.0.0-20200813220834-388e55a496cf h1:GrIpJgHa/iWE1Gk2WKGXSEv1Uw7qPepjCELY+Jjzewo=
+knative.dev/test-infra v0.0.0-20200813220834-388e55a496cf/go.mod h1:Pmg2c7Z7q7BGFUV/GOpU5BlrD3ePJft4MPqx8AYBplc=
 modernc.org/cc v1.0.0/go.mod h1:1Sk4//wdnYJiUIxnW8ddKpaOJCF37yAdqYnkxUpaYxw=
 modernc.org/golex v1.0.0/go.mod h1:b/QX9oBD/LhixY6NDh+IdGv17hgB+51fET1i2kPSmvk=
 modernc.org/mathutil v1.0.0/go.mod h1:wU0vUrJsVWBZ4P6e7xtFJEhFSNsfRLJ8H458uRjg03k=
diff --git a/hack/update-deps.sh b/hack/update-deps.sh
index 9ebb57484..24209398f 100755
--- a/hack/update-deps.sh
+++ b/hack/update-deps.sh
@@ -25,14 +25,14 @@ export GO111MODULE=on
 export GOFLAGS=-mod=
 
 # This controls the release branch we track.
-VERSION="master"
+VERSION="release-0.17"
 
 cd "${ROOT_DIR}"
 
 # The list of dependencies that we track at HEAD and periodically
 # float forward in this repository.
 FLOATING_DEPS=(
-  "knative.dev/test-infra@release-0.17"
+  "knative.dev/test-infra@${VERSION}"
   "knative.dev/eventing@${VERSION}"
 )
 
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/broker_types.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/broker_types.go
index 7771fc866..53e1c7808 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/broker_types.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/broker_types.go
@@ -33,7 +33,7 @@ import (
 
 // Broker collects a pool of events that are consumable using Triggers. Brokers
 // provide a well-known endpoint for event delivery that senders can use with
-// minimal knowledge of the event routing strategy. Receivers use Triggers to
+// minimal knowledge of the event routing strategy. Subscribers use Triggers to
 // request delivery of events from a Broker's pool to a specific URL or
 // Addressable endpoint.
 type Broker struct {
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go
index db53dcf3c..c401388e7 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go
@@ -41,7 +41,7 @@ const (
 // +genreconciler
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
-// Trigger represents a request to have events delivered to a consumer from a
+// Trigger represents a request to have events delivered to a subscriber from a
 // Broker's event pool.
 type Trigger struct {
 	metav1.TypeMeta `json:",inline"`
@@ -75,8 +75,7 @@ var (
 )
 
 type TriggerSpec struct {
-	// Broker is the broker that this trigger receives events from. If not specified, will default
-	// to 'default'.
+	// Broker is the broker that this trigger receives events from.
 	Broker string `json:"broker,omitempty"`
 
 	// Filter is the filter to apply against all events from the Broker. Only events that pass this
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go
index 6a480b6f0..035337d8d 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go
@@ -29,6 +29,7 @@ import (
 // +genreconciler
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
+// EventType represents a type of event that can be consumed from a Broker.
 type EventType struct {
 	metav1.TypeMeta `json:",inline"`
 	// +optional
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_conversion.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_conversion.go
deleted file mode 100644
index b1c7c5ae6..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_conversion.go
+++ /dev/null
@@ -1,88 +0,0 @@
-/*
-Copyright 2020 The Knative Authors.
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-package v1alpha1
-
-import (
-	"context"
-	"fmt"
-	"reflect"
-
-	"knative.dev/eventing/pkg/apis/sources/v1alpha2"
-	"knative.dev/pkg/apis"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-)
-
-// ConvertTo implements apis.Convertible.
-// Converts source (from v1alpha1.PingSource) into v1alpha2.PingSource
-func (source *PingSource) ConvertTo(ctx context.Context, obj apis.Convertible) error {
-	switch sink := obj.(type) {
-	case *v1alpha2.PingSource:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Spec = v1alpha2.PingSourceSpec{
-			Schedule: source.Spec.Schedule,
-			JsonData: source.Spec.Data,
-		}
-		sink.Status = v1alpha2.PingSourceStatus{
-			SourceStatus: duckv1.SourceStatus{
-				Status:               source.Status.Status,
-				SinkURI:              source.Status.SinkURI,
-				CloudEventAttributes: source.Status.CloudEventAttributes,
-			},
-		}
-		// Optionals
-		if source.Spec.Sink != nil {
-			sink.Spec.Sink = *source.Spec.Sink.DeepCopy()
-		}
-		if source.Spec.CloudEventOverrides != nil {
-			sink.Spec.CloudEventOverrides = source.Spec.CloudEventOverrides.DeepCopy()
-		}
-		if source.Status.SinkURI != nil {
-			sink.Status.SinkURI = source.Status.SinkURI.DeepCopy()
-		}
-		return nil
-	default:
-		return fmt.Errorf("Unknown conversion, got: %T", sink)
-	}
-}
-
-// ConvertFrom implements apis.Convertible.
-// Converts obj from v1alpha2.PingSource into v1alpha1.PingSource
-func (sink *PingSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error {
-	switch source := obj.(type) {
-	case *v1alpha2.PingSource:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Spec = PingSourceSpec{
-			Schedule:            source.Spec.Schedule,
-			Data:                source.Spec.JsonData,
-			Sink:                source.Spec.Sink.DeepCopy(),
-			CloudEventOverrides: source.Spec.CloudEventOverrides,
-		}
-		sink.Status = PingSourceStatus{
-			SourceStatus: duckv1.SourceStatus{
-				Status:               source.Status.Status,
-				SinkURI:              source.Status.SinkURI,
-				CloudEventAttributes: source.Status.CloudEventAttributes,
-			},
-		}
-		if reflect.DeepEqual(*sink.Spec.Sink, duckv1.Destination{}) {
-			sink.Spec.Sink = nil
-		}
-		return nil
-	default:
-		return fmt.Errorf("Unknown conversion, got: %T", source)
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_defaults.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_defaults.go
deleted file mode 100644
index 4c54f9216..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_defaults.go
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-package v1alpha1
-
-import (
-	"context"
-)
-
-func (s *PingSource) SetDefaults(ctx context.Context) {
-	s.Spec.SetDefaults(ctx)
-}
-
-func (ss *PingSourceSpec) SetDefaults(ctx context.Context) {
-	// TODO anything?
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_lifecycle.go
deleted file mode 100644
index 33881faee..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_lifecycle.go
+++ /dev/null
@@ -1,147 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-package v1alpha1
-
-import (
-	"fmt"
-
-	appsv1 "k8s.io/api/apps/v1"
-	corev1 "k8s.io/api/core/v1"
-	"k8s.io/apimachinery/pkg/runtime/schema"
-	"knative.dev/pkg/apis"
-)
-
-const (
-	// PingSourceConditionReady has status True when the PingSource is ready to send events.
-	PingSourceConditionReady = apis.ConditionReady
-
-	// PingSourceConditionValidSchedule has status True when the PingSource has been configured with a valid schedule.
-	PingSourceConditionValidSchedule apis.ConditionType = "ValidSchedule"
-
-	// PingSourceConditionSinkProvided has status True when the PingSource has been configured with a sink target.
-	PingSourceConditionSinkProvided apis.ConditionType = "SinkProvided"
-
-	// PingSourceConditionDeployed has status True when the PingSource has had it's receive adapter deployment created.
-	PingSourceConditionDeployed apis.ConditionType = "Deployed"
-
-	// PingSourceConditionResources is True when the resources listed for the PingSource have been properly
-	// parsed and match specified syntax for resource quantities
-	PingSourceConditionResources apis.ConditionType = "ResourcesCorrect"
-)
-
-var PingSourceCondSet = apis.NewLivingConditionSet(
-	PingSourceConditionValidSchedule,
-	PingSourceConditionSinkProvided,
-	PingSourceConditionDeployed)
-
-const (
-	// PingSourceEventType is the default PingSource CloudEvent type.
-	PingSourceEventType = "dev.knative.sources.ping"
-)
-
-// PingSourceSource returns the PingSource CloudEvent source.
-func PingSourceSource(namespace, name string) string {
-	return fmt.Sprintf("/apis/v1/namespaces/%s/pingsources/%s", namespace, name)
-}
-
-// GetUntypedSpec returns the spec of the PingSource.
-func (s *PingSource) GetUntypedSpec() interface{} {
-	return s.Spec
-}
-
-// GetGroupVersionKind returns the GroupVersionKind.
-func (s *PingSource) GetGroupVersionKind() schema.GroupVersionKind {
-	return SchemeGroupVersion.WithKind("PingSource")
-}
-
-// GetCondition returns the condition currently associated with the given type, or nil.
-func (s *PingSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition {
-	return PingSourceCondSet.Manage(s).GetCondition(t)
-}
-
-// GetTopLevelCondition returns the top level Condition.
-func (ps *PingSourceStatus) GetTopLevelCondition() *apis.Condition {
-	return PingSourceCondSet.Manage(ps).GetTopLevelCondition()
-}
-
-// IsReady returns true if the resource is ready overall.
-func (s *PingSourceStatus) IsReady() bool {
-	return PingSourceCondSet.Manage(s).IsHappy()
-}
-
-// InitializeConditions sets relevant unset conditions to Unknown state.
-func (s *PingSourceStatus) InitializeConditions() {
-	PingSourceCondSet.Manage(s).InitializeConditions()
-}
-
-// TODO: this is a bad method name, change it.
-// MarkSchedule sets the condition that the source has a valid schedule configured.
-func (s *PingSourceStatus) MarkSchedule() {
-	PingSourceCondSet.Manage(s).MarkTrue(PingSourceConditionValidSchedule)
-}
-
-// MarkInvalidSchedule sets the condition that the source does not have a valid schedule configured.
-func (s *PingSourceStatus) MarkInvalidSchedule(reason, messageFormat string, messageA ...interface{}) {
-	PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionValidSchedule, reason, messageFormat, messageA...)
-}
-
-// MarkSink sets the condition that the source has a sink configured.
-func (s *PingSourceStatus) MarkSink(uri *apis.URL) {
-	// TODO: Update sources to use MarkSink(url.URL or apis.URI)
-	s.SinkURI = uri
-	if uri != nil {
-		PingSourceCondSet.Manage(s).MarkTrue(PingSourceConditionSinkProvided)
-	} else {
-		PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionSinkProvided, "SinkEmpty", "Sink has resolved to empty.")
-	}
-}
-
-// MarkNoSink sets the condition that the source does not have a sink configured.
-func (s *PingSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{}) {
-	PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionSinkProvided, reason, messageFormat, messageA...)
-}
-
-// PropagateDeploymentAvailability uses the availability of the provided Deployment to determine if
-// PingSourceConditionDeployed should be marked as true or false.
-func (s *PingSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment) {
-	deploymentAvailableFound := false
-	for _, cond := range d.Status.Conditions {
-		if cond.Type == appsv1.DeploymentAvailable {
-			deploymentAvailableFound = true
-			if cond.Status == corev1.ConditionTrue {
-				PingSourceCondSet.Manage(s).MarkTrue(PingSourceConditionDeployed)
-			} else if cond.Status == corev1.ConditionFalse {
-				PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionDeployed, cond.Reason, cond.Message)
-			} else if cond.Status == corev1.ConditionUnknown {
-				PingSourceCondSet.Manage(s).MarkUnknown(PingSourceConditionDeployed, cond.Reason, cond.Message)
-			}
-		}
-	}
-	if !deploymentAvailableFound {
-		PingSourceCondSet.Manage(s).MarkUnknown(PingSourceConditionDeployed, "DeploymentUnavailable", "The Deployment '%s' is unavailable.", d.Name)
-	}
-}
-
-// MarkResourcesCorrect sets the condition that the source resources are properly parsable quantities
-func (s *PingSourceStatus) MarkResourcesCorrect() {
-	PingSourceCondSet.Manage(s).MarkTrue(PingSourceConditionResources)
-}
-
-// MarkResourcesIncorrect sets the condition that the source resources are not properly parsable quantities
-func (s *PingSourceStatus) MarkResourcesIncorrect(reason, messageFormat string, messageA ...interface{}) {
-	PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionResources, reason, messageFormat, messageA...)
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_types.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_types.go
deleted file mode 100644
index 8068d2d87..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_types.go
+++ /dev/null
@@ -1,115 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-package v1alpha1
-
-import (
-	"knative.dev/pkg/apis"
-
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-	"knative.dev/pkg/kmeta"
-)
-
-// +genclient
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-// +k8s:defaulter-gen=true
-
-// PingSource is the Schema for the PingSources API.
-type PingSource struct {
-	metav1.TypeMeta   `json:",inline"`
-	metav1.ObjectMeta `json:"metadata,omitempty"`
-
-	Spec   PingSourceSpec   `json:"spec,omitempty"`
-	Status PingSourceStatus `json:"status,omitempty"`
-}
-
-// TODO: Check that PingSource can be validated and can be defaulted.
-
-var (
-	// Check that it is a runtime object.
-	_ runtime.Object = (*PingSource)(nil)
-
-	// Check that we can create OwnerReferences to a PingSource.
-	_ kmeta.OwnerRefable = (*PingSource)(nil)
-
-	// Check that PingSource can return its spec untyped.
-	_ apis.HasSpec = (*PingSource)(nil)
-)
-
-type PingRequestsSpec struct {
-	ResourceCPU    string `json:"cpu,omitempty"`
-	ResourceMemory string `json:"memory,omitempty"`
-}
-
-type PingLimitsSpec struct {
-	ResourceCPU    string `json:"cpu,omitempty"`
-	ResourceMemory string `json:"memory,omitempty"`
-}
-
-type PingResourceSpec struct {
-	Requests PingRequestsSpec `json:"requests,omitempty"`
-	Limits   PingLimitsSpec   `json:"limits,omitempty"`
-}
-
-// PingSourceSpec defines the desired state of the PingSource.
-type PingSourceSpec struct {
-	// Schedule is the cronjob schedule.
-	// +required
-	Schedule string `json:"schedule"`
-
-	// Data is the data posted to the target function.
-	Data string `json:"data,omitempty"`
-
-	// Sink is a reference to an object that will resolve to a uri to use as the sink.
-	Sink *duckv1.Destination `json:"sink,omitempty"`
-
-	// CloudEventOverrides defines overrides to control the output format and
-	// modifications of the event sent to the sink.
-	// +optional
-	CloudEventOverrides *duckv1.CloudEventOverrides `json:"ceOverrides,omitempty"`
-
-	// ServiceAccoutName is the name of the ServiceAccount that will be used to run the Receive
-	// Adapter Deployment.
-	// Deprecated: v1beta1 drops this field.
-	ServiceAccountName string `json:"serviceAccountName,omitempty"`
-
-	// Resource limits and Request specifications of the Receive Adapter Deployment
-	// Deprecated: v1beta1 drops this field.
-	Resources PingResourceSpec `json:"resources,omitempty"`
-}
-
-// PingSourceStatus defines the observed state of PingSource.
-type PingSourceStatus struct {
-	// inherits duck/v1 SourceStatus, which currently provides:
-	// * ObservedGeneration - the 'Generation' of the Service that was last
-	//   processed by the controller.
-	// * Conditions - the latest available observations of a resource's current
-	//   state.
-	// * SinkURI - the current active sink URI that has been configured for the
-	//   Source.
-	duckv1.SourceStatus `json:",inline"`
-}
-
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-
-// PingSourceList contains a list of PingSources.
-type PingSourceList struct {
-	metav1.TypeMeta `json:",inline"`
-	metav1.ListMeta `json:"metadata,omitempty"`
-	Items           []PingSource `json:"items"`
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_validation.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_validation.go
deleted file mode 100644
index 8336259d6..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/ping_validation.go
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-package v1alpha1
-
-import (
-	"context"
-
-	"github.com/robfig/cron/v3"
-	"knative.dev/pkg/apis"
-
-	"knative.dev/eventing/pkg/apis/sources/v1alpha2"
-)
-
-func (c *PingSource) Validate(ctx context.Context) *apis.FieldError {
-	errs := c.Spec.Validate(ctx).ViaField("spec")
-	return v1alpha2.ValidateAnnotations(errs, c.Annotations)
-}
-
-func (cs *PingSourceSpec) Validate(ctx context.Context) *apis.FieldError {
-	var errs *apis.FieldError
-
-	if _, err := cron.ParseStandard(cs.Schedule); err != nil {
-		fe := apis.ErrInvalidValue(cs.Schedule, "schedule")
-		errs = errs.Also(fe)
-	}
-
-	if cs.Sink == nil {
-		fe := apis.ErrMissingField("sink")
-		errs = errs.Also(fe)
-	} else if fe := cs.Sink.Validate(ctx); fe != nil {
-		errs = errs.Also(fe.ViaField("sink"))
-	}
-	return errs
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/register.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/register.go
index 23aafaf34..8120c413c 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/register.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/register.go
@@ -47,8 +47,6 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 	scheme.AddKnownTypes(SchemeGroupVersion,
 		&ApiServerSource{},
 		&ApiServerSourceList{},
-		&PingSource{},
-		&PingSourceList{},
 		&SinkBinding{},
 		&SinkBindingList{},
 	)
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go
index 448fa4a85..2f1923809 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go
@@ -161,161 +161,6 @@ func (in *ApiServerSourceStatus) DeepCopy() *ApiServerSourceStatus {
 	return out
 }
 
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *PingLimitsSpec) DeepCopyInto(out *PingLimitsSpec) {
-	*out = *in
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PingLimitsSpec.
-func (in *PingLimitsSpec) DeepCopy() *PingLimitsSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(PingLimitsSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *PingRequestsSpec) DeepCopyInto(out *PingRequestsSpec) {
-	*out = *in
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PingRequestsSpec.
-func (in *PingRequestsSpec) DeepCopy() *PingRequestsSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(PingRequestsSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *PingResourceSpec) DeepCopyInto(out *PingResourceSpec) {
-	*out = *in
-	out.Requests = in.Requests
-	out.Limits = in.Limits
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PingResourceSpec.
-func (in *PingResourceSpec) DeepCopy() *PingResourceSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(PingResourceSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *PingSource) DeepCopyInto(out *PingSource) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
-	in.Spec.DeepCopyInto(&out.Spec)
-	in.Status.DeepCopyInto(&out.Status)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PingSource.
-func (in *PingSource) DeepCopy() *PingSource {
-	if in == nil {
-		return nil
-	}
-	out := new(PingSource)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *PingSource) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *PingSourceList) DeepCopyInto(out *PingSourceList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]PingSource, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PingSourceList.
-func (in *PingSourceList) DeepCopy() *PingSourceList {
-	if in == nil {
-		return nil
-	}
-	out := new(PingSourceList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *PingSourceList) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *PingSourceSpec) DeepCopyInto(out *PingSourceSpec) {
-	*out = *in
-	if in.Sink != nil {
-		in, out := &in.Sink, &out.Sink
-		*out = new(v1.Destination)
-		(*in).DeepCopyInto(*out)
-	}
-	if in.CloudEventOverrides != nil {
-		in, out := &in.CloudEventOverrides, &out.CloudEventOverrides
-		*out = new(v1.CloudEventOverrides)
-		(*in).DeepCopyInto(*out)
-	}
-	out.Resources = in.Resources
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PingSourceSpec.
-func (in *PingSourceSpec) DeepCopy() *PingSourceSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(PingSourceSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *PingSourceStatus) DeepCopyInto(out *PingSourceStatus) {
-	*out = *in
-	in.SourceStatus.DeepCopyInto(&out.SourceStatus)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PingSourceStatus.
-func (in *PingSourceStatus) DeepCopy() *PingSourceStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(PingSourceStatus)
-	in.DeepCopyInto(out)
-	return out
-}
-
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
 func (in *SinkBinding) DeepCopyInto(out *SinkBinding) {
 	*out = *in
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_pingsource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_pingsource.go
deleted file mode 100644
index d753a7d6b..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_pingsource.go
+++ /dev/null
@@ -1,140 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-// Code generated by client-gen. DO NOT EDIT.
-
-package fake
-
-import (
-	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	labels "k8s.io/apimachinery/pkg/labels"
-	schema "k8s.io/apimachinery/pkg/runtime/schema"
-	types "k8s.io/apimachinery/pkg/types"
-	watch "k8s.io/apimachinery/pkg/watch"
-	testing "k8s.io/client-go/testing"
-	v1alpha1 "knative.dev/eventing/pkg/apis/sources/v1alpha1"
-)
-
-// FakePingSources implements PingSourceInterface
-type FakePingSources struct {
-	Fake *FakeSourcesV1alpha1
-	ns   string
-}
-
-var pingsourcesResource = schema.GroupVersionResource{Group: "sources.knative.dev", Version: "v1alpha1", Resource: "pingsources"}
-
-var pingsourcesKind = schema.GroupVersionKind{Group: "sources.knative.dev", Version: "v1alpha1", Kind: "PingSource"}
-
-// Get takes name of the pingSource, and returns the corresponding pingSource object, and an error if there is any.
-func (c *FakePingSources) Get(name string, options v1.GetOptions) (result *v1alpha1.PingSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewGetAction(pingsourcesResource, c.ns, name), &v1alpha1.PingSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1alpha1.PingSource), err
-}
-
-// List takes label and field selectors, and returns the list of PingSources that match those selectors.
-func (c *FakePingSources) List(opts v1.ListOptions) (result *v1alpha1.PingSourceList, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewListAction(pingsourcesResource, pingsourcesKind, c.ns, opts), &v1alpha1.PingSourceList{})
-
-	if obj == nil {
-		return nil, err
-	}
-
-	label, _, _ := testing.ExtractFromListOptions(opts)
-	if label == nil {
-		label = labels.Everything()
-	}
-	list := &v1alpha1.PingSourceList{ListMeta: obj.(*v1alpha1.PingSourceList).ListMeta}
-	for _, item := range obj.(*v1alpha1.PingSourceList).Items {
-		if label.Matches(labels.Set(item.Labels)) {
-			list.Items = append(list.Items, item)
-		}
-	}
-	return list, err
-}
-
-// Watch returns a watch.Interface that watches the requested pingSources.
-func (c *FakePingSources) Watch(opts v1.ListOptions) (watch.Interface, error) {
-	return c.Fake.
-		InvokesWatch(testing.NewWatchAction(pingsourcesResource, c.ns, opts))
-
-}
-
-// Create takes the representation of a pingSource and creates it.  Returns the server's representation of the pingSource, and an error, if there is any.
-func (c *FakePingSources) Create(pingSource *v1alpha1.PingSource) (result *v1alpha1.PingSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewCreateAction(pingsourcesResource, c.ns, pingSource), &v1alpha1.PingSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1alpha1.PingSource), err
-}
-
-// Update takes the representation of a pingSource and updates it. Returns the server's representation of the pingSource, and an error, if there is any.
-func (c *FakePingSources) Update(pingSource *v1alpha1.PingSource) (result *v1alpha1.PingSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateAction(pingsourcesResource, c.ns, pingSource), &v1alpha1.PingSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1alpha1.PingSource), err
-}
-
-// UpdateStatus was generated because the type contains a Status member.
-// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
-func (c *FakePingSources) UpdateStatus(pingSource *v1alpha1.PingSource) (*v1alpha1.PingSource, error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateSubresourceAction(pingsourcesResource, "status", c.ns, pingSource), &v1alpha1.PingSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1alpha1.PingSource), err
-}
-
-// Delete takes name of the pingSource and deletes it. Returns an error if one occurs.
-func (c *FakePingSources) Delete(name string, options *v1.DeleteOptions) error {
-	_, err := c.Fake.
-		Invokes(testing.NewDeleteAction(pingsourcesResource, c.ns, name), &v1alpha1.PingSource{})
-
-	return err
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *FakePingSources) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error {
-	action := testing.NewDeleteCollectionAction(pingsourcesResource, c.ns, listOptions)
-
-	_, err := c.Fake.Invokes(action, &v1alpha1.PingSourceList{})
-	return err
-}
-
-// Patch applies the patch and returns the patched pingSource.
-func (c *FakePingSources) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.PingSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewPatchSubresourceAction(pingsourcesResource, c.ns, name, pt, data, subresources...), &v1alpha1.PingSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1alpha1.PingSource), err
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go
index 59cd493e7..41fe65677 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go
@@ -32,10 +32,6 @@ func (c *FakeSourcesV1alpha1) ApiServerSources(namespace string) v1alpha1.ApiSer
 	return &FakeApiServerSources{c, namespace}
 }
 
-func (c *FakeSourcesV1alpha1) PingSources(namespace string) v1alpha1.PingSourceInterface {
-	return &FakePingSources{c, namespace}
-}
-
 func (c *FakeSourcesV1alpha1) SinkBindings(namespace string) v1alpha1.SinkBindingInterface {
 	return &FakeSinkBindings{c, namespace}
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go
index aa618931e..e0130fb3a 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go
@@ -20,6 +20,4 @@ package v1alpha1
 
 type ApiServerSourceExpansion interface{}
 
-type PingSourceExpansion interface{}
-
 type SinkBindingExpansion interface{}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/pingsource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/pingsource.go
deleted file mode 100644
index 89315a511..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/pingsource.go
+++ /dev/null
@@ -1,191 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-// Code generated by client-gen. DO NOT EDIT.
-
-package v1alpha1
-
-import (
-	"time"
-
-	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	types "k8s.io/apimachinery/pkg/types"
-	watch "k8s.io/apimachinery/pkg/watch"
-	rest "k8s.io/client-go/rest"
-	v1alpha1 "knative.dev/eventing/pkg/apis/sources/v1alpha1"
-	scheme "knative.dev/eventing/pkg/client/clientset/versioned/scheme"
-)
-
-// PingSourcesGetter has a method to return a PingSourceInterface.
-// A group's client should implement this interface.
-type PingSourcesGetter interface {
-	PingSources(namespace string) PingSourceInterface
-}
-
-// PingSourceInterface has methods to work with PingSource resources.
-type PingSourceInterface interface {
-	Create(*v1alpha1.PingSource) (*v1alpha1.PingSource, error)
-	Update(*v1alpha1.PingSource) (*v1alpha1.PingSource, error)
-	UpdateStatus(*v1alpha1.PingSource) (*v1alpha1.PingSource, error)
-	Delete(name string, options *v1.DeleteOptions) error
-	DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error
-	Get(name string, options v1.GetOptions) (*v1alpha1.PingSource, error)
-	List(opts v1.ListOptions) (*v1alpha1.PingSourceList, error)
-	Watch(opts v1.ListOptions) (watch.Interface, error)
-	Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.PingSource, err error)
-	PingSourceExpansion
-}
-
-// pingSources implements PingSourceInterface
-type pingSources struct {
-	client rest.Interface
-	ns     string
-}
-
-// newPingSources returns a PingSources
-func newPingSources(c *SourcesV1alpha1Client, namespace string) *pingSources {
-	return &pingSources{
-		client: c.RESTClient(),
-		ns:     namespace,
-	}
-}
-
-// Get takes name of the pingSource, and returns the corresponding pingSource object, and an error if there is any.
-func (c *pingSources) Get(name string, options v1.GetOptions) (result *v1alpha1.PingSource, err error) {
-	result = &v1alpha1.PingSource{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("pingsources").
-		Name(name).
-		VersionedParams(&options, scheme.ParameterCodec).
-		Do().
-		Into(result)
-	return
-}
-
-// List takes label and field selectors, and returns the list of PingSources that match those selectors.
-func (c *pingSources) List(opts v1.ListOptions) (result *v1alpha1.PingSourceList, err error) {
-	var timeout time.Duration
-	if opts.TimeoutSeconds != nil {
-		timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
-	}
-	result = &v1alpha1.PingSourceList{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("pingsources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Do().
-		Into(result)
-	return
-}
-
-// Watch returns a watch.Interface that watches the requested pingSources.
-func (c *pingSources) Watch(opts v1.ListOptions) (watch.Interface, error) {
-	var timeout time.Duration
-	if opts.TimeoutSeconds != nil {
-		timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
-	}
-	opts.Watch = true
-	return c.client.Get().
-		Namespace(c.ns).
-		Resource("pingsources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Watch()
-}
-
-// Create takes the representation of a pingSource and creates it.  Returns the server's representation of the pingSource, and an error, if there is any.
-func (c *pingSources) Create(pingSource *v1alpha1.PingSource) (result *v1alpha1.PingSource, err error) {
-	result = &v1alpha1.PingSource{}
-	err = c.client.Post().
-		Namespace(c.ns).
-		Resource("pingsources").
-		Body(pingSource).
-		Do().
-		Into(result)
-	return
-}
-
-// Update takes the representation of a pingSource and updates it. Returns the server's representation of the pingSource, and an error, if there is any.
-func (c *pingSources) Update(pingSource *v1alpha1.PingSource) (result *v1alpha1.PingSource, err error) {
-	result = &v1alpha1.PingSource{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("pingsources").
-		Name(pingSource.Name).
-		Body(pingSource).
-		Do().
-		Into(result)
-	return
-}
-
-// UpdateStatus was generated because the type contains a Status member.
-// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus().
-
-func (c *pingSources) UpdateStatus(pingSource *v1alpha1.PingSource) (result *v1alpha1.PingSource, err error) {
-	result = &v1alpha1.PingSource{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("pingsources").
-		Name(pingSource.Name).
-		SubResource("status").
-		Body(pingSource).
-		Do().
-		Into(result)
-	return
-}
-
-// Delete takes name of the pingSource and deletes it. Returns an error if one occurs.
-func (c *pingSources) Delete(name string, options *v1.DeleteOptions) error {
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("pingsources").
-		Name(name).
-		Body(options).
-		Do().
-		Error()
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *pingSources) DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error {
-	var timeout time.Duration
-	if listOptions.TimeoutSeconds != nil {
-		timeout = time.Duration(*listOptions.TimeoutSeconds) * time.Second
-	}
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("pingsources").
-		VersionedParams(&listOptions, scheme.ParameterCodec).
-		Timeout(timeout).
-		Body(options).
-		Do().
-		Error()
-}
-
-// Patch applies the patch and returns the patched pingSource.
-func (c *pingSources) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha1.PingSource, err error) {
-	result = &v1alpha1.PingSource{}
-	err = c.client.Patch(pt).
-		Namespace(c.ns).
-		Resource("pingsources").
-		SubResource(subresources...).
-		Name(name).
-		Body(data).
-		Do().
-		Into(result)
-	return
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go
index 08031fe80..c862359f1 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go
@@ -27,7 +27,6 @@ import (
 type SourcesV1alpha1Interface interface {
 	RESTClient() rest.Interface
 	ApiServerSourcesGetter
-	PingSourcesGetter
 	SinkBindingsGetter
 }
 
@@ -40,10 +39,6 @@ func (c *SourcesV1alpha1Client) ApiServerSources(namespace string) ApiServerSour
 	return newApiServerSources(c, namespace)
 }
 
-func (c *SourcesV1alpha1Client) PingSources(namespace string) PingSourceInterface {
-	return newPingSources(c, namespace)
-}
-
 func (c *SourcesV1alpha1Client) SinkBindings(namespace string) SinkBindingInterface {
 	return newSinkBindings(c, namespace)
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/generic.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/generic.go
index 5302d0d00..1ecd8e52e 100644
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/generic.go
+++ b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/generic.go
@@ -110,8 +110,6 @@ func (f *sharedInformerFactory) ForResource(resource schema.GroupVersionResource
 		// Group=sources.knative.dev, Version=v1alpha1
 	case sourcesv1alpha1.SchemeGroupVersion.WithResource("apiserversources"):
 		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1alpha1().ApiServerSources().Informer()}, nil
-	case sourcesv1alpha1.SchemeGroupVersion.WithResource("pingsources"):
-		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1alpha1().PingSources().Informer()}, nil
 	case sourcesv1alpha1.SchemeGroupVersion.WithResource("sinkbindings"):
 		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1alpha1().SinkBindings().Informer()}, nil
 
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1alpha1/interface.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1alpha1/interface.go
index 9ddc57ca5..b33cdf570 100644
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1alpha1/interface.go
+++ b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1alpha1/interface.go
@@ -26,8 +26,6 @@ import (
 type Interface interface {
 	// ApiServerSources returns a ApiServerSourceInformer.
 	ApiServerSources() ApiServerSourceInformer
-	// PingSources returns a PingSourceInformer.
-	PingSources() PingSourceInformer
 	// SinkBindings returns a SinkBindingInformer.
 	SinkBindings() SinkBindingInformer
 }
@@ -48,11 +46,6 @@ func (v *version) ApiServerSources() ApiServerSourceInformer {
 	return &apiServerSourceInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
 }
 
-// PingSources returns a PingSourceInformer.
-func (v *version) PingSources() PingSourceInformer {
-	return &pingSourceInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
-}
-
 // SinkBindings returns a SinkBindingInformer.
 func (v *version) SinkBindings() SinkBindingInformer {
 	return &sinkBindingInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1alpha1/pingsource.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1alpha1/pingsource.go
deleted file mode 100644
index 97bccc9ff..000000000
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1alpha1/pingsource.go
+++ /dev/null
@@ -1,89 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-// Code generated by informer-gen. DO NOT EDIT.
-
-package v1alpha1
-
-import (
-	time "time"
-
-	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	runtime "k8s.io/apimachinery/pkg/runtime"
-	watch "k8s.io/apimachinery/pkg/watch"
-	cache "k8s.io/client-go/tools/cache"
-	sourcesv1alpha1 "knative.dev/eventing/pkg/apis/sources/v1alpha1"
-	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
-	internalinterfaces "knative.dev/eventing/pkg/client/informers/externalversions/internalinterfaces"
-	v1alpha1 "knative.dev/eventing/pkg/client/listers/sources/v1alpha1"
-)
-
-// PingSourceInformer provides access to a shared informer and lister for
-// PingSources.
-type PingSourceInformer interface {
-	Informer() cache.SharedIndexInformer
-	Lister() v1alpha1.PingSourceLister
-}
-
-type pingSourceInformer struct {
-	factory          internalinterfaces.SharedInformerFactory
-	tweakListOptions internalinterfaces.TweakListOptionsFunc
-	namespace        string
-}
-
-// NewPingSourceInformer constructs a new informer for PingSource type.
-// Always prefer using an informer factory to get a shared informer instead of getting an independent
-// one. This reduces memory footprint and number of connections to the server.
-func NewPingSourceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
-	return NewFilteredPingSourceInformer(client, namespace, resyncPeriod, indexers, nil)
-}
-
-// NewFilteredPingSourceInformer constructs a new informer for PingSource type.
-// Always prefer using an informer factory to get a shared informer instead of getting an independent
-// one. This reduces memory footprint and number of connections to the server.
-func NewFilteredPingSourceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer {
-	return cache.NewSharedIndexInformer(
-		&cache.ListWatch{
-			ListFunc: func(options v1.ListOptions) (runtime.Object, error) {
-				if tweakListOptions != nil {
-					tweakListOptions(&options)
-				}
-				return client.SourcesV1alpha1().PingSources(namespace).List(options)
-			},
-			WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
-				if tweakListOptions != nil {
-					tweakListOptions(&options)
-				}
-				return client.SourcesV1alpha1().PingSources(namespace).Watch(options)
-			},
-		},
-		&sourcesv1alpha1.PingSource{},
-		resyncPeriod,
-		indexers,
-	)
-}
-
-func (f *pingSourceInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
-	return NewFilteredPingSourceInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
-}
-
-func (f *pingSourceInformer) Informer() cache.SharedIndexInformer {
-	return f.factory.InformerFor(&sourcesv1alpha1.PingSource{}, f.defaultInformer)
-}
-
-func (f *pingSourceInformer) Lister() v1alpha1.PingSourceLister {
-	return v1alpha1.NewPingSourceLister(f.Informer().GetIndexer())
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker/fake/fake.go b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/fake/fake.go
similarity index 94%
rename from vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker/fake/fake.go
rename to vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/fake/fake.go
index 04658f7c8..5dc3b1c76 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker/fake/fake.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/fake/fake.go
@@ -21,7 +21,7 @@ package fake
 import (
 	context "context"
 
-	broker "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker"
+	broker "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker"
 	fake "knative.dev/eventing/pkg/client/injection/informers/factory/fake"
 	controller "knative.dev/pkg/controller"
 	injection "knative.dev/pkg/injection"
@@ -35,6 +35,6 @@ func init() {
 
 func withInformer(ctx context.Context) (context.Context, controller.Informer) {
 	f := fake.Get(ctx)
-	inf := f.Eventing().V1beta1().Brokers()
+	inf := f.Eventing().V1().Brokers()
 	return context.WithValue(ctx, broker.Key{}, inf), inf.Informer()
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/fake/fake.go b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/fake/fake.go
similarity index 94%
rename from vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/fake/fake.go
rename to vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/fake/fake.go
index b95e6822e..bf33f84f0 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/fake/fake.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/fake/fake.go
@@ -21,7 +21,7 @@ package fake
 import (
 	context "context"
 
-	trigger "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger"
+	trigger "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger"
 	fake "knative.dev/eventing/pkg/client/injection/informers/factory/fake"
 	controller "knative.dev/pkg/controller"
 	injection "knative.dev/pkg/injection"
@@ -35,6 +35,6 @@ func init() {
 
 func withInformer(ctx context.Context) (context.Context, controller.Informer) {
 	f := fake.Get(ctx)
-	inf := f.Eventing().V1beta1().Triggers()
+	inf := f.Eventing().V1().Triggers()
 	return context.WithValue(ctx, trigger.Key{}, inf), inf.Informer()
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/trigger.go b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/trigger.go
similarity index 82%
rename from vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/trigger.go
rename to vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/trigger.go
index 6d398de04..3bd2d81ed 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/trigger.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/trigger.go
@@ -21,7 +21,7 @@ package trigger
 import (
 	context "context"
 
-	v1beta1 "knative.dev/eventing/pkg/client/informers/externalversions/eventing/v1beta1"
+	v1 "knative.dev/eventing/pkg/client/informers/externalversions/eventing/v1"
 	factory "knative.dev/eventing/pkg/client/injection/informers/factory"
 	controller "knative.dev/pkg/controller"
 	injection "knative.dev/pkg/injection"
@@ -37,16 +37,16 @@ type Key struct{}
 
 func withInformer(ctx context.Context) (context.Context, controller.Informer) {
 	f := factory.Get(ctx)
-	inf := f.Eventing().V1beta1().Triggers()
+	inf := f.Eventing().V1().Triggers()
 	return context.WithValue(ctx, Key{}, inf), inf.Informer()
 }
 
 // Get extracts the typed informer from the context.
-func Get(ctx context.Context) v1beta1.TriggerInformer {
+func Get(ctx context.Context) v1.TriggerInformer {
 	untyped := ctx.Value(Key{})
 	if untyped == nil {
 		logging.FromContext(ctx).Panic(
-			"Unable to fetch knative.dev/eventing/pkg/client/informers/externalversions/eventing/v1beta1.TriggerInformer from context.")
+			"Unable to fetch knative.dev/eventing/pkg/client/informers/externalversions/eventing/v1.TriggerInformer from context.")
 	}
-	return untyped.(v1beta1.TriggerInformer)
+	return untyped.(v1.TriggerInformer)
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/controller.go b/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/controller.go
similarity index 99%
rename from vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/controller.go
rename to vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/controller.go
index 2a3379424..504a628cf 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/controller.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/controller.go
@@ -33,7 +33,7 @@ import (
 	record "k8s.io/client-go/tools/record"
 	versionedscheme "knative.dev/eventing/pkg/client/clientset/versioned/scheme"
 	client "knative.dev/eventing/pkg/client/injection/client"
-	trigger "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger"
+	trigger "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger"
 	kubeclient "knative.dev/pkg/client/injection/kube/client"
 	controller "knative.dev/pkg/controller"
 	logging "knative.dev/pkg/logging"
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/reconciler.go b/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/reconciler.go
similarity index 86%
rename from vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/reconciler.go
rename to vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/reconciler.go
index 6d24e80a8..4876c7549 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/reconciler.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/reconciler.go
@@ -25,7 +25,7 @@ import (
 	reflect "reflect"
 
 	zap "go.uber.org/zap"
-	v1 "k8s.io/api/core/v1"
+	corev1 "k8s.io/api/core/v1"
 	equality "k8s.io/apimachinery/pkg/api/equality"
 	errors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -33,9 +33,9 @@ import (
 	types "k8s.io/apimachinery/pkg/types"
 	sets "k8s.io/apimachinery/pkg/util/sets"
 	record "k8s.io/client-go/tools/record"
-	v1beta1 "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	v1 "knative.dev/eventing/pkg/apis/eventing/v1"
 	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
-	eventingv1beta1 "knative.dev/eventing/pkg/client/listers/eventing/v1beta1"
+	eventingv1 "knative.dev/eventing/pkg/client/listers/eventing/v1"
 	controller "knative.dev/pkg/controller"
 	kmp "knative.dev/pkg/kmp"
 	logging "knative.dev/pkg/logging"
@@ -43,50 +43,50 @@ import (
 )
 
 // Interface defines the strongly typed interfaces to be implemented by a
-// controller reconciling v1beta1.Trigger.
+// controller reconciling v1.Trigger.
 type Interface interface {
-	// ReconcileKind implements custom logic to reconcile v1beta1.Trigger. Any changes
+	// ReconcileKind implements custom logic to reconcile v1.Trigger. Any changes
 	// to the objects .Status or .Finalizers will be propagated to the stored
 	// object. It is recommended that implementors do not call any update calls
 	// for the Kind inside of ReconcileKind, it is the responsibility of the calling
 	// controller to propagate those properties. The resource passed to ReconcileKind
 	// will always have an empty deletion timestamp.
-	ReconcileKind(ctx context.Context, o *v1beta1.Trigger) reconciler.Event
+	ReconcileKind(ctx context.Context, o *v1.Trigger) reconciler.Event
 }
 
 // Finalizer defines the strongly typed interfaces to be implemented by a
-// controller finalizing v1beta1.Trigger.
+// controller finalizing v1.Trigger.
 type Finalizer interface {
-	// FinalizeKind implements custom logic to finalize v1beta1.Trigger. Any changes
+	// FinalizeKind implements custom logic to finalize v1.Trigger. Any changes
 	// to the objects .Status or .Finalizers will be ignored. Returning a nil or
 	// Normal type reconciler.Event will allow the finalizer to be deleted on
 	// the resource. The resource passed to FinalizeKind will always have a set
 	// deletion timestamp.
-	FinalizeKind(ctx context.Context, o *v1beta1.Trigger) reconciler.Event
+	FinalizeKind(ctx context.Context, o *v1.Trigger) reconciler.Event
 }
 
 // ReadOnlyInterface defines the strongly typed interfaces to be implemented by a
-// controller reconciling v1beta1.Trigger if they want to process resources for which
+// controller reconciling v1.Trigger if they want to process resources for which
 // they are not the leader.
 type ReadOnlyInterface interface {
-	// ObserveKind implements logic to observe v1beta1.Trigger.
+	// ObserveKind implements logic to observe v1.Trigger.
 	// This method should not write to the API.
-	ObserveKind(ctx context.Context, o *v1beta1.Trigger) reconciler.Event
+	ObserveKind(ctx context.Context, o *v1.Trigger) reconciler.Event
 }
 
 // ReadOnlyFinalizer defines the strongly typed interfaces to be implemented by a
-// controller finalizing v1beta1.Trigger if they want to process tombstoned resources
+// controller finalizing v1.Trigger if they want to process tombstoned resources
 // even when they are not the leader.  Due to the nature of how finalizers are handled
 // there are no guarantees that this will be called.
 type ReadOnlyFinalizer interface {
-	// ObserveFinalizeKind implements custom logic to observe the final state of v1beta1.Trigger.
+	// ObserveFinalizeKind implements custom logic to observe the final state of v1.Trigger.
 	// This method should not write to the API.
-	ObserveFinalizeKind(ctx context.Context, o *v1beta1.Trigger) reconciler.Event
+	ObserveFinalizeKind(ctx context.Context, o *v1.Trigger) reconciler.Event
 }
 
-type doReconcile func(ctx context.Context, o *v1beta1.Trigger) reconciler.Event
+type doReconcile func(ctx context.Context, o *v1.Trigger) reconciler.Event
 
-// reconcilerImpl implements controller.Reconciler for v1beta1.Trigger resources.
+// reconcilerImpl implements controller.Reconciler for v1.Trigger resources.
 type reconcilerImpl struct {
 	// LeaderAwareFuncs is inlined to help us implement reconciler.LeaderAware
 	reconciler.LeaderAwareFuncs
@@ -95,7 +95,7 @@ type reconcilerImpl struct {
 	Client versioned.Interface
 
 	// Listers index properties about resources
-	Lister eventingv1beta1.TriggerLister
+	Lister eventingv1.TriggerLister
 
 	// Recorder is an event recorder for recording Event resources to the
 	// Kubernetes API.
@@ -122,7 +122,7 @@ var _ controller.Reconciler = (*reconcilerImpl)(nil)
 // Check that our generated Reconciler is always LeaderAware.
 var _ reconciler.LeaderAware = (*reconcilerImpl)(nil)
 
-func NewReconciler(ctx context.Context, logger *zap.SugaredLogger, client versioned.Interface, lister eventingv1beta1.TriggerLister, recorder record.EventRecorder, r Interface, options ...controller.Options) controller.Reconciler {
+func NewReconciler(ctx context.Context, logger *zap.SugaredLogger, client versioned.Interface, lister eventingv1.TriggerLister, recorder record.EventRecorder, r Interface, options ...controller.Options) controller.Reconciler {
 	// Check the options function input. It should be 0 or 1.
 	if len(options) > 1 {
 		logger.Fatalf("up to one options struct is supported, found %d", len(options))
@@ -275,7 +275,7 @@ func (r *reconcilerImpl) Reconcile(ctx context.Context, key string) error {
 	default:
 		if err = r.updateStatus(ctx, original, resource); err != nil {
 			logger.Warnw("Failed to update resource status", zap.Error(err))
-			r.Recorder.Eventf(resource, v1.EventTypeWarning, "UpdateFailed",
+			r.Recorder.Eventf(resource, corev1.EventTypeWarning, "UpdateFailed",
 				"Failed to update status for %q: %v", resource.Name, err)
 			return err
 		}
@@ -296,20 +296,20 @@ func (r *reconcilerImpl) Reconcile(ctx context.Context, key string) error {
 		}
 
 		logger.Errorw("Returned an error", zap.Error(reconcileEvent))
-		r.Recorder.Event(resource, v1.EventTypeWarning, "InternalError", reconcileEvent.Error())
+		r.Recorder.Event(resource, corev1.EventTypeWarning, "InternalError", reconcileEvent.Error())
 		return reconcileEvent
 	}
 
 	return nil
 }
 
-func (r *reconcilerImpl) updateStatus(ctx context.Context, existing *v1beta1.Trigger, desired *v1beta1.Trigger) error {
+func (r *reconcilerImpl) updateStatus(ctx context.Context, existing *v1.Trigger, desired *v1.Trigger) error {
 	existing = existing.DeepCopy()
 	return reconciler.RetryUpdateConflicts(func(attempts int) (err error) {
 		// The first iteration tries to use the injectionInformer's state, subsequent attempts fetch the latest state via API.
 		if attempts > 0 {
 
-			getter := r.Client.EventingV1beta1().Triggers(desired.Namespace)
+			getter := r.Client.EventingV1().Triggers(desired.Namespace)
 
 			existing, err = getter.Get(desired.Name, metav1.GetOptions{})
 			if err != nil {
@@ -328,7 +328,7 @@ func (r *reconcilerImpl) updateStatus(ctx context.Context, existing *v1beta1.Tri
 
 		existing.Status = desired.Status
 
-		updater := r.Client.EventingV1beta1().Triggers(existing.Namespace)
+		updater := r.Client.EventingV1().Triggers(existing.Namespace)
 
 		_, err = updater.UpdateStatus(existing)
 		return err
@@ -338,7 +338,7 @@ func (r *reconcilerImpl) updateStatus(ctx context.Context, existing *v1beta1.Tri
 // updateFinalizersFiltered will update the Finalizers of the resource.
 // TODO: this method could be generic and sync all finalizers. For now it only
 // updates defaultFinalizerName or its override.
-func (r *reconcilerImpl) updateFinalizersFiltered(ctx context.Context, resource *v1beta1.Trigger) (*v1beta1.Trigger, error) {
+func (r *reconcilerImpl) updateFinalizersFiltered(ctx context.Context, resource *v1.Trigger) (*v1.Trigger, error) {
 
 	getter := r.Lister.Triggers(resource.Namespace)
 
@@ -385,21 +385,21 @@ func (r *reconcilerImpl) updateFinalizersFiltered(ctx context.Context, resource
 		return resource, err
 	}
 
-	patcher := r.Client.EventingV1beta1().Triggers(resource.Namespace)
+	patcher := r.Client.EventingV1().Triggers(resource.Namespace)
 
 	resourceName := resource.Name
 	resource, err = patcher.Patch(resourceName, types.MergePatchType, patch)
 	if err != nil {
-		r.Recorder.Eventf(resource, v1.EventTypeWarning, "FinalizerUpdateFailed",
+		r.Recorder.Eventf(resource, corev1.EventTypeWarning, "FinalizerUpdateFailed",
 			"Failed to update finalizers for %q: %v", resourceName, err)
 	} else {
-		r.Recorder.Eventf(resource, v1.EventTypeNormal, "FinalizerUpdate",
+		r.Recorder.Eventf(resource, corev1.EventTypeNormal, "FinalizerUpdate",
 			"Updated %q finalizers", resource.GetName())
 	}
 	return resource, err
 }
 
-func (r *reconcilerImpl) setFinalizerIfFinalizer(ctx context.Context, resource *v1beta1.Trigger) (*v1beta1.Trigger, error) {
+func (r *reconcilerImpl) setFinalizerIfFinalizer(ctx context.Context, resource *v1.Trigger) (*v1.Trigger, error) {
 	if _, ok := r.reconciler.(Finalizer); !ok {
 		return resource, nil
 	}
@@ -417,7 +417,7 @@ func (r *reconcilerImpl) setFinalizerIfFinalizer(ctx context.Context, resource *
 	return r.updateFinalizersFiltered(ctx, resource)
 }
 
-func (r *reconcilerImpl) clearFinalizer(ctx context.Context, resource *v1beta1.Trigger, reconcileEvent reconciler.Event) (*v1beta1.Trigger, error) {
+func (r *reconcilerImpl) clearFinalizer(ctx context.Context, resource *v1.Trigger, reconcileEvent reconciler.Event) (*v1.Trigger, error) {
 	if _, ok := r.reconciler.(Finalizer); !ok {
 		return resource, nil
 	}
@@ -430,7 +430,7 @@ func (r *reconcilerImpl) clearFinalizer(ctx context.Context, resource *v1beta1.T
 	if reconcileEvent != nil {
 		var event *reconciler.ReconcilerEvent
 		if reconciler.EventAs(reconcileEvent, &event) {
-			if event.EventType == v1.EventTypeNormal {
+			if event.EventType == corev1.EventTypeNormal {
 				finalizers.Delete(r.finalizerName)
 			}
 		}
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/state.go b/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/state.go
similarity index 95%
rename from vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/state.go
rename to vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/state.go
index db3168cbc..89c3addda 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger/state.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger/state.go
@@ -23,7 +23,7 @@ import (
 
 	types "k8s.io/apimachinery/pkg/types"
 	cache "k8s.io/client-go/tools/cache"
-	v1beta1 "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	v1 "knative.dev/eventing/pkg/apis/eventing/v1"
 	reconciler "knative.dev/pkg/reconciler"
 )
 
@@ -90,7 +90,7 @@ func (s *state) isNotLeaderNorObserver() bool {
 	return false
 }
 
-func (s *state) reconcileMethodFor(o *v1beta1.Trigger) (string, doReconcile) {
+func (s *state) reconcileMethodFor(o *v1.Trigger) (string, doReconcile) {
 	if o.GetDeletionTimestamp().IsZero() {
 		if s.isLeader {
 			return reconciler.DoReconcileKind, s.reconciler.ReconcileKind
diff --git a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1alpha1/expansion_generated.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1alpha1/expansion_generated.go
index f30287719..666c2f005 100644
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1alpha1/expansion_generated.go
+++ b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1alpha1/expansion_generated.go
@@ -26,14 +26,6 @@ type ApiServerSourceListerExpansion interface{}
 // ApiServerSourceNamespaceLister.
 type ApiServerSourceNamespaceListerExpansion interface{}
 
-// PingSourceListerExpansion allows custom methods to be added to
-// PingSourceLister.
-type PingSourceListerExpansion interface{}
-
-// PingSourceNamespaceListerExpansion allows custom methods to be added to
-// PingSourceNamespaceLister.
-type PingSourceNamespaceListerExpansion interface{}
-
 // SinkBindingListerExpansion allows custom methods to be added to
 // SinkBindingLister.
 type SinkBindingListerExpansion interface{}
diff --git a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1alpha1/pingsource.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1alpha1/pingsource.go
deleted file mode 100644
index 751f08cc8..000000000
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1alpha1/pingsource.go
+++ /dev/null
@@ -1,94 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-// Code generated by lister-gen. DO NOT EDIT.
-
-package v1alpha1
-
-import (
-	"k8s.io/apimachinery/pkg/api/errors"
-	"k8s.io/apimachinery/pkg/labels"
-	"k8s.io/client-go/tools/cache"
-	v1alpha1 "knative.dev/eventing/pkg/apis/sources/v1alpha1"
-)
-
-// PingSourceLister helps list PingSources.
-type PingSourceLister interface {
-	// List lists all PingSources in the indexer.
-	List(selector labels.Selector) (ret []*v1alpha1.PingSource, err error)
-	// PingSources returns an object that can list and get PingSources.
-	PingSources(namespace string) PingSourceNamespaceLister
-	PingSourceListerExpansion
-}
-
-// pingSourceLister implements the PingSourceLister interface.
-type pingSourceLister struct {
-	indexer cache.Indexer
-}
-
-// NewPingSourceLister returns a new PingSourceLister.
-func NewPingSourceLister(indexer cache.Indexer) PingSourceLister {
-	return &pingSourceLister{indexer: indexer}
-}
-
-// List lists all PingSources in the indexer.
-func (s *pingSourceLister) List(selector labels.Selector) (ret []*v1alpha1.PingSource, err error) {
-	err = cache.ListAll(s.indexer, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1alpha1.PingSource))
-	})
-	return ret, err
-}
-
-// PingSources returns an object that can list and get PingSources.
-func (s *pingSourceLister) PingSources(namespace string) PingSourceNamespaceLister {
-	return pingSourceNamespaceLister{indexer: s.indexer, namespace: namespace}
-}
-
-// PingSourceNamespaceLister helps list and get PingSources.
-type PingSourceNamespaceLister interface {
-	// List lists all PingSources in the indexer for a given namespace.
-	List(selector labels.Selector) (ret []*v1alpha1.PingSource, err error)
-	// Get retrieves the PingSource from the indexer for a given namespace and name.
-	Get(name string) (*v1alpha1.PingSource, error)
-	PingSourceNamespaceListerExpansion
-}
-
-// pingSourceNamespaceLister implements the PingSourceNamespaceLister
-// interface.
-type pingSourceNamespaceLister struct {
-	indexer   cache.Indexer
-	namespace string
-}
-
-// List lists all PingSources in the indexer for a given namespace.
-func (s pingSourceNamespaceLister) List(selector labels.Selector) (ret []*v1alpha1.PingSource, err error) {
-	err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1alpha1.PingSource))
-	})
-	return ret, err
-}
-
-// Get retrieves the PingSource from the indexer for a given namespace and name.
-func (s pingSourceNamespaceLister) Get(name string) (*v1alpha1.PingSource, error) {
-	obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
-	if err != nil {
-		return nil, err
-	}
-	if !exists {
-		return nil, errors.NewNotFound(v1alpha1.Resource("pingsource"), name)
-	}
-	return obj.(*v1alpha1.PingSource), nil
-}
diff --git a/vendor/knative.dev/pkg/controller/controller.go b/vendor/knative.dev/pkg/controller/controller.go
index 121db8567..b88b4a20e 100644
--- a/vendor/knative.dev/pkg/controller/controller.go
+++ b/vendor/knative.dev/pkg/controller/controller.go
@@ -263,7 +263,7 @@ func (c *Impl) EnqueueAfter(obj interface{}, after time.Duration) {
 func (c *Impl) EnqueueSlowKey(key types.NamespacedName) {
 	c.workQueue.SlowLane().Add(key)
 	c.logger.With(zap.Object(logkey.Key, logging.NamespacedName(key))).
-		Debug("Adding to the slow queue %s (depth(total/slow): %d/%d)",
+		Debugf("Adding to the slow queue %s (depth(total/slow): %d/%d)",
 			safeKey(key), c.workQueue.Len(), c.workQueue.SlowLane().Len())
 }
 
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 185d6c176..12ae54fef 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -1046,7 +1046,7 @@ k8s.io/utils/buffer
 k8s.io/utils/integer
 k8s.io/utils/pointer
 k8s.io/utils/trace
-# knative.dev/eventing v0.16.1-0.20200812203106-45c93e360a11
+# knative.dev/eventing v0.16.1-0.20200818065713-9f3fb3ffde17
 ## explicit
 knative.dev/eventing/pkg/apis/config
 knative.dev/eventing/pkg/apis/configs
@@ -1113,15 +1113,15 @@ knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1
 knative.dev/eventing/pkg/client/injection/client
 knative.dev/eventing/pkg/client/injection/client/fake
 knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker
+knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/fake
+knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger
+knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/fake
 knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker
-knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker/fake
-knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger
-knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/fake
 knative.dev/eventing/pkg/client/injection/informers/factory
 knative.dev/eventing/pkg/client/injection/informers/factory/fake
 knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/broker
+knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger
 knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/broker
-knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger
 knative.dev/eventing/pkg/client/listers/configs/v1alpha1
 knative.dev/eventing/pkg/client/listers/eventing/v1
 knative.dev/eventing/pkg/client/listers/eventing/v1beta1
@@ -1169,7 +1169,7 @@ knative.dev/eventing/test/test_images/recordevents
 knative.dev/eventing/test/test_images/request-sender
 knative.dev/eventing/test/test_images/sequencestepper
 knative.dev/eventing/test/test_images/transformevents
-# knative.dev/pkg v0.0.0-20200811233205-6b7eccba3b9c
+# knative.dev/pkg v0.0.0-20200812224206-44c860147a87
 ## explicit
 knative.dev/pkg/apis
 knative.dev/pkg/apis/duck
@@ -1247,7 +1247,7 @@ knative.dev/pkg/tracker
 knative.dev/pkg/version
 knative.dev/pkg/webhook
 knative.dev/pkg/webhook/certificates/resources
-# knative.dev/test-infra v0.0.0-20200811195106-afcd1747545f
+# knative.dev/test-infra v0.0.0-20200813220834-388e55a496cf
 ## explicit
 knative.dev/test-infra/scripts
 # sigs.k8s.io/yaml v1.2.0


Test patch:
diff --git a/control-plane/pkg/reconciler/broker/broker_test.go b/control-plane/pkg/reconciler/broker/broker_test.go
index 4b85d443a..08d7949f3 100644
--- a/control-plane/pkg/reconciler/broker/broker_test.go
+++ b/control-plane/pkg/reconciler/broker/broker_test.go
@@ -31,7 +31,7 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/types"
 	clientgotesting "k8s.io/client-go/testing"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	"knative.dev/pkg/apis"
 	kubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	"knative.dev/pkg/controller"
@@ -39,10 +39,10 @@ import (
 	. "knative.dev/pkg/reconciler/testing"
 	"knative.dev/pkg/resolver"
 
-	eventingduck "knative.dev/eventing/pkg/apis/duck/v1beta1"
+	eventingduck "knative.dev/eventing/pkg/apis/duck/v1"
 	fakeeventingclient "knative.dev/eventing/pkg/client/injection/client/fake"
-	brokerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/broker"
-	reconcilertesting "knative.dev/eventing/pkg/reconciler/testing/v1beta1"
+	brokerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/broker"
+	reconcilertesting "knative.dev/eventing/pkg/reconciler/testing/v1"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 
 	coreconfig "knative.dev/eventing-kafka-broker/control-plane/pkg/core/config"
diff --git a/control-plane/pkg/reconciler/broker/controller_test.go b/control-plane/pkg/reconciler/broker/controller_test.go
index c72269d21..cd827ffbf 100644
--- a/control-plane/pkg/reconciler/broker/controller_test.go
+++ b/control-plane/pkg/reconciler/broker/controller_test.go
@@ -23,8 +23,8 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	fakekubeclientset "k8s.io/client-go/kubernetes/fake"
-	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker/fake"
-	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/fake"
+	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/fake"
+	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/fake"
 	_ "knative.dev/pkg/client/injection/ducks/duck/v1/addressable/fake"
 	fakekubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/configmap/fake"
diff --git a/control-plane/pkg/reconciler/broker/topic_test.go b/control-plane/pkg/reconciler/broker/topic_test.go
index c1e8d969b..51eea319e 100644
--- a/control-plane/pkg/reconciler/broker/topic_test.go
+++ b/control-plane/pkg/reconciler/broker/topic_test.go
@@ -23,7 +23,7 @@ import (
 	"github.com/stretchr/testify/assert"
 	"go.uber.org/zap"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/broker"
 	reconcilertesting "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/testing"
diff --git a/control-plane/pkg/reconciler/kafka/broker_class_test.go b/control-plane/pkg/reconciler/kafka/broker_class_test.go
index 013f387f5..d37da06d4 100644
--- a/control-plane/pkg/reconciler/kafka/broker_class_test.go
+++ b/control-plane/pkg/reconciler/kafka/broker_class_test.go
@@ -21,7 +21,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 )
 
 func TestBrokerClassFilter(t *testing.T) {
diff --git a/control-plane/pkg/reconciler/testing/listers.go b/control-plane/pkg/reconciler/testing/listers.go
index 94ea00187..e8e617c3b 100644
--- a/control-plane/pkg/reconciler/testing/listers.go
+++ b/control-plane/pkg/reconciler/testing/listers.go
@@ -23,9 +23,9 @@ import (
 	fakekubeclientset "k8s.io/client-go/kubernetes/fake"
 	corelisters "k8s.io/client-go/listers/core/v1"
 	"k8s.io/client-go/tools/cache"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	fakeeventingclientset "knative.dev/eventing/pkg/client/clientset/versioned/fake"
-	eventinglisters "knative.dev/eventing/pkg/client/listers/eventing/v1beta1"
+	eventinglisters "knative.dev/eventing/pkg/client/listers/eventing/v1"
 	"knative.dev/pkg/reconciler/testing"
 )
 
diff --git a/control-plane/pkg/reconciler/testing/objects.go b/control-plane/pkg/reconciler/testing/objects.go
index 5ff062372..8eb064bc1 100644
--- a/control-plane/pkg/reconciler/testing/objects.go
+++ b/control-plane/pkg/reconciler/testing/objects.go
@@ -27,10 +27,10 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	clientgotesting "k8s.io/client-go/testing"
-	eventingduck "knative.dev/eventing/pkg/apis/duck/v1beta1"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventingduck "knative.dev/eventing/pkg/apis/duck/v1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	"knative.dev/eventing/pkg/reconciler/names"
-	reconcilertesting "knative.dev/eventing/pkg/reconciler/testing/v1beta1"
+	reconcilertesting "knative.dev/eventing/pkg/reconciler/testing/v1"
 	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 
@@ -121,14 +121,16 @@ func ReceiverPodUpdate(namespace string, annotations map[string]string) clientgo
 }
 
 func NewService() *corev1.Service {
-	return reconcilertesting.NewService(
-		serviceName,
-		serviceNamespace,
-		func(service *corev1.Service) {
-			service.APIVersion = "v1"
-			service.Kind = "Service"
+	return &corev1.Service{
+		TypeMeta: metav1.TypeMeta{
+			Kind:       "Service",
+			APIVersion: "v1",
 		},
-	)
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      serviceName,
+			Namespace: serviceNamespace,
+		},
+	}
 }
 
 func NewConfigMap(configs *Configs, data []byte) runtime.Object {
diff --git a/control-plane/pkg/reconciler/trigger/controller_test.go b/control-plane/pkg/reconciler/trigger/controller_test.go
index bf5443f71..3c3c1f901 100644
--- a/control-plane/pkg/reconciler/trigger/controller_test.go
+++ b/control-plane/pkg/reconciler/trigger/controller_test.go
@@ -20,14 +20,14 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/assert"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
-	brokerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
+	brokerinformer "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker"
 	"knative.dev/pkg/configmap"
 
 	reconcilertesting "knative.dev/pkg/reconciler/testing"
 
-	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/broker/fake"
-	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1beta1/trigger/fake"
+	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/fake"
+	_ "knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/fake"
 	_ "knative.dev/pkg/client/injection/ducks/duck/v1/addressable/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/pod/fake"
 
diff --git a/control-plane/pkg/reconciler/trigger/trigger_test.go b/control-plane/pkg/reconciler/trigger/trigger_test.go
index 2db2ec320..7953b4b8a 100644
--- a/control-plane/pkg/reconciler/trigger/trigger_test.go
+++ b/control-plane/pkg/reconciler/trigger/trigger_test.go
@@ -26,12 +26,12 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/types"
 	clientgotesting "k8s.io/client-go/testing"
-	eventing "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	eventing "knative.dev/eventing/pkg/apis/eventing/v1"
 	eventingclient "knative.dev/eventing/pkg/client/injection/client/fake"
 	fakeeventingclient "knative.dev/eventing/pkg/client/injection/client/fake"
-	triggerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1beta1/trigger"
+	triggerreconciler "knative.dev/eventing/pkg/client/injection/reconciler/eventing/v1/trigger"
 	"knative.dev/eventing/pkg/logging"
-	reconcilertesting "knative.dev/eventing/pkg/reconciler/testing/v1beta1"
+	reconcilertesting "knative.dev/eventing/pkg/reconciler/testing/v1"
 	"knative.dev/pkg/apis"
 	kubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	"knative.dev/pkg/controller"
diff --git a/test/e2e/broker_trigger_test.go b/test/e2e/broker_trigger_test.go
index 47ca71e6e..85a769e62 100644
--- a/test/e2e/broker_trigger_test.go
+++ b/test/e2e/broker_trigger_test.go
@@ -67,9 +67,9 @@ func TestBrokerTrigger(t *testing.T) {
 		nonMatchingEventId := uuid.New().String()
 		eventId := uuid.New().String()
 
-		br := client.CreateBrokerV1Beta1OrFail(
+		br := client.CreateBrokerV1OrFail(
 			brokerName,
-			resources.WithBrokerClassForBrokerV1Beta1(kafka.BrokerClass),
+			resources.WithBrokerClassForBrokerV1(kafka.BrokerClass),
 		)
 
 		eventTracker, _ := recordevents.StartEventRecordOrFail(client, subscriber)
@@ -189,10 +189,10 @@ func TestBrokerWithConfig(t *testing.T) {
 			broker.BootstrapServersConfigMapKey:              bootstrapServers,
 		})
 
-		br := client.CreateBrokerV1Beta1OrFail(
+		br := client.CreateBrokerV1OrFail(
 			brokerName,
-			resources.WithBrokerClassForBrokerV1Beta1(kafka.BrokerClass),
-			resources.WithConfigForBrokerV1Beta1(&duckv1.KReference{
+			resources.WithBrokerClassForBrokerV1(kafka.BrokerClass),
+			resources.WithConfigForBrokerV1(&duckv1.KReference{
 				Kind:       "ConfigMap",
 				Namespace:  cm.Namespace,
 				Name:       cm.Name,
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go
index 2d5c3c6e4..22822b573 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go
@@ -160,10 +160,6 @@ func (l *Listers) GetApiServerSourceLister() sourcelisters.ApiServerSourceLister
 	return sourcelisters.NewApiServerSourceLister(l.indexerFor(&sourcesv1alpha1.ApiServerSource{}))
 }
 
-func (l *Listers) GetPingSourceLister() sourcelisters.PingSourceLister {
-	return sourcelisters.NewPingSourceLister(l.indexerFor(&sourcesv1alpha1.PingSource{}))
-}
-
 func (l *Listers) GetSinkBindingLister() sourcelisters.SinkBindingLister {
 	return sourcelisters.NewSinkBindingLister(l.indexerFor(&sourcesv1alpha1.SinkBinding{}))
 }
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/pingsource.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/pingsource.go
index 162aef1b3..ff2b2551e 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/pingsource.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/pingsource.go
@@ -26,35 +26,16 @@ import (
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 
 	"knative.dev/eventing/pkg/apis/eventing"
-	"knative.dev/eventing/pkg/apis/sources/v1alpha1"
 	"knative.dev/eventing/pkg/apis/sources/v1alpha2"
 	"knative.dev/eventing/pkg/apis/sources/v1beta1"
 )
 
-// PingSourceOption enables further configuration of a CronJob.
-type PingSourceOption func(*v1alpha1.PingSource)
-
 // PingSourceV1A2Option enables further configuration of a CronJob.
 type PingSourceV1A2Option func(*v1alpha2.PingSource)
 
 // PingSourceV1B1Option enables further configuration of a CronJob.
 type PingSourceV1B1Option func(*v1beta1.PingSource)
 
-// NewPingSourceV1Alpha1 creates a PingSource with PingSourceOption.
-func NewPingSourceV1Alpha1(name, namespace string, o ...PingSourceOption) *v1alpha1.PingSource {
-	c := &v1alpha1.PingSource{
-		ObjectMeta: metav1.ObjectMeta{
-			Name:      name,
-			Namespace: namespace,
-		},
-	}
-	for _, opt := range o {
-		opt(c)
-	}
-	c.SetDefaults(context.Background()) // TODO: We should add defaults and validation.
-	return c
-}
-
 // NewPingSourceV1Alpha2 creates a PingSource with PingSourceOption.
 func NewPingSourceV1Alpha2(name, namespace string, o ...PingSourceV1A2Option) *v1alpha2.PingSource {
 	c := &v1alpha2.PingSource{
@@ -85,25 +66,12 @@ func NewPingSourceV1Beta1(name, namespace string, o ...PingSourceV1B1Option) *v1
 	return c
 }
 
-func WithPingSourceUID(uid string) PingSourceOption {
-	return func(c *v1alpha1.PingSource) {
-		c.UID = types.UID(uid)
-	}
-}
-
 func WithPingSourceV1A2UID(uid string) PingSourceV1A2Option {
 	return func(c *v1alpha2.PingSource) {
 		c.UID = types.UID(uid)
 	}
 }
 
-func WithPingSourceResourceScopeAnnotation(c *v1alpha1.PingSource) {
-	if c.Annotations == nil {
-		c.Annotations = make(map[string]string)
-	}
-	c.Annotations[eventing.ScopeAnnotationKey] = eventing.ScopeResource
-}
-
 func WithPingSourceV1A2ResourceScopeAnnotation(c *v1alpha2.PingSource) {
 	if c.Annotations == nil {
 		c.Annotations = make(map[string]string)
@@ -111,13 +79,6 @@ func WithPingSourceV1A2ResourceScopeAnnotation(c *v1alpha2.PingSource) {
 	c.Annotations[eventing.ScopeAnnotationKey] = eventing.ScopeResource
 }
 
-func WithPingSourceClusterScopeAnnotation(c *v1alpha1.PingSource) {
-	if c.Annotations == nil {
-		c.Annotations = make(map[string]string)
-	}
-	c.Annotations[eventing.ScopeAnnotationKey] = eventing.ScopeCluster
-}
-
 func WithPingSourceV1A2ClusterScopeAnnotation(c *v1alpha2.PingSource) {
 	if c.Annotations == nil {
 		c.Annotations = make(map[string]string)
@@ -125,74 +86,34 @@ func WithPingSourceV1A2ClusterScopeAnnotation(c *v1alpha2.PingSource) {
 	c.Annotations[eventing.ScopeAnnotationKey] = eventing.ScopeCluster
 }
 
-// WithInitPingSourceConditions initializes the PingSource's conditions.
-func WithInitPingSourceConditions(s *v1alpha1.PingSource) {
-	s.Status.InitializeConditions()
-}
-
 func WithInitPingSourceV1A2Conditions(s *v1alpha2.PingSource) {
 	s.Status.InitializeConditions()
 }
 
-func WithValidPingSourceSchedule(s *v1alpha1.PingSource) {
-	s.Status.MarkSchedule()
-}
-
 func WithValidPingSourceV1A2Schedule(s *v1alpha2.PingSource) {
 	s.Status.MarkSchedule()
 }
 
-func WithInvalidPingSourceSchedule(s *v1alpha1.PingSource) {
-	s.Status.MarkInvalidSchedule("Invalid", "")
-}
-
-func WithPingSourceSinkNotFound(s *v1alpha1.PingSource) {
-	s.Status.MarkNoSink("NotFound", "")
-}
-
 func WithPingSourceV1A2SinkNotFound(s *v1alpha2.PingSource) {
 	s.Status.MarkNoSink("NotFound", "")
 }
 
-func WithPingSourceSink(uri *apis.URL) PingSourceOption {
-	return func(s *v1alpha1.PingSource) {
-		s.Status.MarkSink(uri)
-	}
-}
-
 func WithPingSourceV1A2Sink(uri *apis.URL) PingSourceV1A2Option {
 	return func(s *v1alpha2.PingSource) {
 		s.Status.MarkSink(uri)
 	}
 }
 
-func WithPingSourceNotDeployed(name string) PingSourceOption {
-	return func(s *v1alpha1.PingSource) {
-		s.Status.PropagateDeploymentAvailability(NewDeployment(name, "any"))
-	}
-}
-
 func WithPingSourceV1A2NotDeployed(name string) PingSourceV1A2Option {
 	return func(s *v1alpha2.PingSource) {
 		s.Status.PropagateDeploymentAvailability(NewDeployment(name, "any"))
 	}
 }
 
-func WithPingSourceDeployed(s *v1alpha1.PingSource) {
-	s.Status.PropagateDeploymentAvailability(NewDeployment("any", "any", WithDeploymentAvailable()))
-}
-
 func WithPingSourceV1A2Deployed(s *v1alpha2.PingSource) {
 	s.Status.PropagateDeploymentAvailability(NewDeployment("any", "any", WithDeploymentAvailable()))
 }
 
-func WithPingSourceEventType(s *v1alpha1.PingSource) {
-	s.Status.CloudEventAttributes = []duckv1.CloudEventAttributes{{
-		Type:   v1alpha1.PingSourceEventType,
-		Source: v1alpha1.PingSourceSource(s.Namespace, s.Name),
-	}}
-}
-
 func WithPingSourceV1A2CloudEventAttributes(s *v1alpha2.PingSource) {
 	s.Status.CloudEventAttributes = []duckv1.CloudEventAttributes{{
 		Type:   v1alpha2.PingSourceEventType,
@@ -200,25 +121,10 @@ func WithPingSourceV1A2CloudEventAttributes(s *v1alpha2.PingSource) {
 	}}
 }
 
-func WithValidPingSourceResources(s *v1alpha1.PingSource) {
-	s.Status.MarkResourcesCorrect()
-}
-
 func WithValidPingSourceV1A2Resources(s *v1alpha2.PingSource) {
 	s.Status.MarkResourcesCorrect()
 }
 
-func WithPingSourceDeleted(c *v1alpha1.PingSource) {
-	t := metav1.NewTime(time.Unix(1e9, 0))
-	c.ObjectMeta.SetDeletionTimestamp(&t)
-}
-
-func WithPingSourceSpec(spec v1alpha1.PingSourceSpec) PingSourceOption {
-	return func(c *v1alpha1.PingSource) {
-		c.Spec = spec
-	}
-}
-
 func WithPingSourceV1A2Spec(spec v1alpha2.PingSourceSpec) PingSourceV1A2Option {
 	return func(c *v1alpha2.PingSource) {
 		c.Spec = spec
@@ -231,30 +137,12 @@ func WithPingSourceV1B1Spec(spec v1beta1.PingSourceSpec) PingSourceV1B1Option {
 	}
 }
 
-func WithPingSourceApiVersion(apiVersion string) PingSourceOption {
-	return func(c *v1alpha1.PingSource) {
-		c.APIVersion = apiVersion
-	}
-}
-
-func WithPingSourceStatusObservedGeneration(generation int64) PingSourceOption {
-	return func(c *v1alpha1.PingSource) {
-		c.Status.ObservedGeneration = generation
-	}
-}
-
 func WithPingSourceV1A2StatusObservedGeneration(generation int64) PingSourceV1A2Option {
 	return func(c *v1alpha2.PingSource) {
 		c.Status.ObservedGeneration = generation
 	}
 }
 
-func WithPingSourceObjectMetaGeneration(generation int64) PingSourceOption {
-	return func(c *v1alpha1.PingSource) {
-		c.ObjectMeta.Generation = generation
-	}
-}
-
 func WithPingSourceV1A2ObjectMetaGeneration(generation int64) PingSourceV1A2Option {
 	return func(c *v1alpha2.PingSource) {
 		c.ObjectMeta.Generation = generation
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go
index 07fd0b0f7..32d2eca09 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go
@@ -148,10 +148,6 @@ func (l *Listers) GetApiServerSourceLister() sourcelisters.ApiServerSourceLister
 	return sourcelisters.NewApiServerSourceLister(l.indexerFor(&sourcesv1alpha1.ApiServerSource{}))
 }
 
-func (l *Listers) GetPingSourceLister() sourcelisters.PingSourceLister {
-	return sourcelisters.NewPingSourceLister(l.indexerFor(&sourcesv1alpha1.PingSource{}))
-}
-
 func (l *Listers) GetSinkBindingLister() sourcelisters.SinkBindingLister {
 	return sourcelisters.NewSinkBindingLister(l.indexerFor(&sourcesv1alpha1.SinkBinding{}))
 }
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go
index fb79144b2..9c046b0df 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go
@@ -158,10 +158,6 @@ func (l *Listers) GetApiServerSourceLister() sourcelisters.ApiServerSourceLister
 	return sourcelisters.NewApiServerSourceLister(l.indexerFor(&sourcesv1alpha1.ApiServerSource{}))
 }
 
-func (l *Listers) GetPingSourceLister() sourcelisters.PingSourceLister {
-	return sourcelisters.NewPingSourceLister(l.indexerFor(&sourcesv1alpha1.PingSource{}))
-}
-
 func (l *Listers) GetSinkBindingLister() sourcelisters.SinkBindingLister {
 	return sourcelisters.NewSinkBindingLister(l.indexerFor(&sourcesv1alpha1.SinkBinding{}))
 }
diff --git a/vendor/knative.dev/eventing/test/lib/client.go b/vendor/knative.dev/eventing/test/lib/client.go
index f338a9517..b26e04347 100644
--- a/vendor/knative.dev/eventing/test/lib/client.go
+++ b/vendor/knative.dev/eventing/test/lib/client.go
@@ -54,6 +54,8 @@ type Client struct {
 	podsCreated []string
 
 	tracingEnv corev1.EnvVar
+
+	cleanup func()
 }
 
 // NewClient instantiates and returns several clientsets required for making request to the
@@ -98,6 +100,31 @@ func NewClient(configPath string, clusterName string, namespace string, t *testi
 	return client, nil
 }
 
+// Cleanup acts similarly to testing.T, but it's tied to the client lifecycle
+func (c *Client) Cleanup(f func()) {
+	oldCleanup := c.cleanup
+	c.cleanup = func() {
+		if oldCleanup != nil {
+			defer oldCleanup()
+		}
+		f()
+	}
+}
+
+func (c *Client) runCleanup() (err error) {
+	if c.cleanup == nil {
+		return nil
+	}
+	defer func() {
+		if panicVal := recover(); panicVal != nil {
+			err = fmt.Errorf("panic in cleanup function: %+v", panicVal)
+		}
+	}()
+
+	c.cleanup()
+	return nil
+}
+
 func getTracingConfig(c *kubernetes.Clientset) (corev1.EnvVar, error) {
 	cm, err := c.CoreV1().ConfigMaps(resources.SystemNamespace).Get("config-tracing", metav1.GetOptions{})
 	if err != nil {
diff --git a/vendor/knative.dev/eventing/test/lib/creation.go b/vendor/knative.dev/eventing/test/lib/creation.go
index 81cdda254..45318bc1b 100644
--- a/vendor/knative.dev/eventing/test/lib/creation.go
+++ b/vendor/knative.dev/eventing/test/lib/creation.go
@@ -534,23 +534,6 @@ func (c *Client) CreateContainerSourceV1Beta1OrFail(containerSource *sourcesv1be
 	c.Tracker.AddObj(containerSource)
 }
 
-// CreatePingSourceV1Alpha1OrFail will create an PingSource
-func (c *Client) CreatePingSourceV1Alpha1OrFail(pingSource *sourcesv1alpha1.PingSource) {
-	c.T.Logf("Creating pingsource %+v", pingSource)
-	pingInterface := c.Eventing.SourcesV1alpha1().PingSources(c.Namespace)
-	err := c.RetryWebhookErrors(func(attempts int) (err error) {
-		_, e := pingInterface.Create(pingSource)
-		if e != nil {
-			c.T.Logf("Failed to create pingsource %q: %v", pingSource.Name, e)
-		}
-		return e
-	})
-	if err != nil && !errors.IsAlreadyExists(err) {
-		c.T.Fatalf("Failed to create pingsource %q: %v", pingSource.Name, err)
-	}
-	c.Tracker.AddObj(pingSource)
-}
-
 // CreatePingSourceV1Alpha2OrFail will create an PingSource
 func (c *Client) CreatePingSourceV1Alpha2OrFail(pingSource *sourcesv1alpha2.PingSource) {
 	c.T.Logf("Creating pingsource %+v", pingSource)
diff --git a/vendor/knative.dev/eventing/test/lib/recordevents/event_info_store.go b/vendor/knative.dev/eventing/test/lib/recordevents/event_info_store.go
index e8bde7889..3b0c46cf4 100644
--- a/vendor/knative.dev/eventing/test/lib/recordevents/event_info_store.go
+++ b/vendor/knative.dev/eventing/test/lib/recordevents/event_info_store.go
@@ -93,7 +93,7 @@ func NewEventInfoStore(client *testlib.Client, podName string) (*EventInfoStore,
 	ei := newTestableEventInfoStore(egi, -1, -1)
 	ei.podName = podName
 	ei.tb = client.T
-	client.T.Cleanup(ei.cleanup)
+	client.Cleanup(ei.cleanup)
 	return ei, nil
 }
 
diff --git a/vendor/knative.dev/eventing/test/lib/test_runner.go b/vendor/knative.dev/eventing/test/lib/test_runner.go
index c32f04a05..553ebeff0 100644
--- a/vendor/knative.dev/eventing/test/lib/test_runner.go
+++ b/vendor/knative.dev/eventing/test/lib/test_runner.go
@@ -28,11 +28,12 @@ import (
 	"k8s.io/apimachinery/pkg/util/wait"
 	"k8s.io/apiserver/pkg/storage/names"
 
-	"knative.dev/eventing/pkg/utils"
 	pkgTest "knative.dev/pkg/test"
 	"knative.dev/pkg/test/helpers"
 	"knative.dev/pkg/test/prow"
 
+	"knative.dev/eventing/pkg/utils"
+
 	// Mysteriously required to support GCP auth (required by k8s libs).
 	// Apparently just importing it is enough. @_@ side effects @_@.
 	// https://github.com/kubernetes/client-go/issues/242
@@ -179,6 +180,10 @@ func makeK8sNamespace(baseFuncName string) string {
 
 // TearDown will delete created names using clients.
 func TearDown(client *Client) {
+	if err := client.runCleanup(); err != nil {
+		client.T.Logf("Cleanup error: %+v", err)
+	}
+
 	// Dump the events in the namespace
 	el, err := client.Kube.Kube.CoreV1().Events(client.Namespace).List(metav1.ListOptions{})
 	if err != nil {
diff --git a/vendor/knative.dev/test-infra/scripts/e2e-tests.sh b/vendor/knative.dev/test-infra/scripts/e2e-tests.sh
index 87045064f..a788b6827 100644
--- a/vendor/knative.dev/test-infra/scripts/e2e-tests.sh
+++ b/vendor/knative.dev/test-infra/scripts/e2e-tests.sh
@@ -221,7 +221,7 @@ function create_test_cluster() {
 
   # Create cluster and run the tests
   create_test_cluster_with_retries "${E2E_SCRIPT} ${test_cmd_args}" \
-    "${CLUSTER_CREATION_ARGS[@]}" "${extra_flags[@]}"
+    "${CLUSTER_CREATION_ARGS[@]}" "${extra_flags[@]}" "${EXTRA_KUBETEST2_FLAGS[@]}"
   local result="$?"
   # Ignore any errors below, this is a best-effort cleanup and shouldn't affect the test result.
   set +o errexit
@@ -378,6 +378,7 @@ E2E_SCRIPT=""
 E2E_CLUSTER_VERSION="latest"
 GKE_ADDONS=""
 EXTRA_CLUSTER_CREATION_FLAGS=()
+EXTRA_KUBETEST2_FLAGS=()
 E2E_SCRIPT_CUSTOM_FLAGS=()
 
 # Parse flags and initialize the test cluster.
@@ -414,6 +415,7 @@ function initialize() {
           --gcp-project) GCP_PROJECT=$1 ;;
           --cluster-version) E2E_CLUSTER_VERSION=$1 ;;
           --cluster-creation-flag) EXTRA_CLUSTER_CREATION_FLAGS+=("$1") ;;
+          --kubetest2-flag) EXTRA_KUBETEST2_FLAGS+=("$1") ;;
           *) abort "unknown option ${parameter}" ;;
         esac
     esac
@@ -431,12 +433,17 @@ function initialize() {
 
   (( IS_PROW )) && [[ -z "${GCP_PROJECT}" ]] && IS_BOSKOS=1
 
-  (( SKIP_ISTIO_ADDON )) || GKE_ADDONS="--addons=Istio"
+  if (( SKIP_ISTIO_ADDON )); then
+    GKE_ADDONS="--addons=NodeLocalDNS"
+  else
+    GKE_ADDONS="--addons=Istio,NodeLocalDNS"
+  fi
 
   readonly RUN_TESTS
   readonly GCP_PROJECT
   readonly IS_BOSKOS
   readonly EXTRA_CLUSTER_CREATION_FLAGS
+  readonly EXTRA_KUBETEST2_FLAGS
   readonly SKIP_KNATIVE_SETUP
   readonly SKIP_TEARDOWNS
   readonly GKE_ADDONS
diff --git a/vendor/knative.dev/test-infra/scripts/library.sh b/vendor/knative.dev/test-infra/scripts/library.sh
index 251a9c89f..1267f7986 100644
--- a/vendor/knative.dev/test-infra/scripts/library.sh
+++ b/vendor/knative.dev/test-infra/scripts/library.sh
@@ -408,7 +408,7 @@ function report_go_test() {
   json="$(mktemp_with_extension "${ARTIFACTS}"/json_XXXXXXXX json)"
   echo "Running go test with args: ${go_test_args[*]}"
   # TODO(chizhg): change to `--format testname`?
-  capture_output "${report}" gotestsum --format standard-verbose \
+  capture_output "${report}" gotestsum --format "${GO_TEST_VERBOSITY:-standard-verbose}" \
     --junitfile "${xml}" --junitfile-testsuite-name relative --junitfile-testcase-classname relative \
     --jsonfile "${json}" \
     -- "${go_test_args[@]}"