Repository: knative-sandbox/eventing-kafka
Pull request #595 (2021-05-04 17:06:26)

upgrade deps
Manually run:

./hack/update-deps.sh --upgrade  
./hack/update-codegen.sh

 

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

This pull-request has been approved by:
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please ask for approval from **lionelvillard** after the PR has been reviewed.

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

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

- **[OWNERS](https://github.com/knative-sandbox/eventing-kafka/blob/main/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":["lionelvillard"]} -->
codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/595?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) Report
> Merging [#595](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/595?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (aaf2309) into [main](https://codecov.io/gh/knative-sandbox/eventing-kafka/commit/f31c3067c63843348669a8311e9e1bbf03f62457?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (f31c306) will **not change** coverage.
> The diff coverage is `n/a`.

[![Impacted file tree graph](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/595/graphs/tree.svg?width=650&height=150&src=pr&token=W765CT93QC&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/595?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)

```diff
@@           Coverage Diff           @@
##             main     #595   +/-   ##
=======================================
  Coverage   71.68%   71.68%           
=======================================
  Files         137      137           
  Lines        5643     5643           
=======================================
  Hits         4045     4045           
  Misses       1371     1371           
  Partials      227      227           
```



------

[Continue to review full report at Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/595?src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/595?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Last update [f31c306...aaf2309](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/595?src=pr&el=lastupdated&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox).

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

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka/pull/595#pullrequestreview-651502641" title="Approved">lberk</a>*

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

The pull request process is described [here](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process)

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

- ~~[OWNERS](https://github.com/knative-sandbox/eventing-kafka/blob/main/OWNERS)~~ [lberk]

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":[]} -->

Patch:
diff --git a/go.mod b/go.mod
index ca9215a48..94a1de4fc 100644
--- a/go.mod
+++ b/go.mod
@@ -33,8 +33,8 @@ require (
 	k8s.io/apimachinery v0.19.7
 	k8s.io/client-go v0.19.7
 	k8s.io/utils v0.0.0-20200729134348-d5654de09c73
-	knative.dev/control-protocol v0.0.0-20210428072553-79468156aad1
-	knative.dev/eventing v0.22.1-0.20210428222054-c2d6649ea36d
+	knative.dev/control-protocol v0.0.0-20210504094437-d6392770de44
+	knative.dev/eventing v0.22.1-0.20210504001137-8a094e6031f2
 	knative.dev/hack v0.0.0-20210428122153-93ad9129c268
 	knative.dev/networking v0.0.0-20210428161254-1ad047ce063f
 	knative.dev/pkg v0.0.0-20210428141353-878c85083565
diff --git a/go.sum b/go.sum
index 869f5a7ae..ebf0b5fc1 100644
--- a/go.sum
+++ b/go.sum
@@ -1307,28 +1307,23 @@ k8s.io/kube-openapi v0.0.0-20200805222855-6aeccd4b50c6 h1:+WnxoVtG8TMiudHBSEtrVL
 k8s.io/kube-openapi v0.0.0-20200805222855-6aeccd4b50c6/go.mod h1:UuqjUnNftUyPE5H64/qeyjQoUZhGpeFDVdxjTeEVN2o=
 k8s.io/utils v0.0.0-20200729134348-d5654de09c73 h1:uJmqzgNWG7XyClnU/mLPBWwfKKF1K8Hf8whTseBgJcg=
 k8s.io/utils v0.0.0-20200729134348-d5654de09c73/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
-knative.dev/control-protocol v0.0.0-20210428072553-79468156aad1 h1:VH4Gy/PtoVVvQIdkT4jn+upyBYVd3Msm1BTfgVBPosU=
-knative.dev/control-protocol v0.0.0-20210428072553-79468156aad1/go.mod h1:HFKVsvZvmEkyWOUdwu3OJiO9ovxV20YNi6o0UsxufSY=
-knative.dev/eventing v0.22.1-0.20210428222054-c2d6649ea36d h1:nSfksjHcDMXQEe7R9EMYTF5C2WFjMyrk0PEX6e3oVnE=
-knative.dev/eventing v0.22.1-0.20210428222054-c2d6649ea36d/go.mod h1:N6c9wtqdLEiaNNxAK6+WHqdAy/Uhh0/xWfsRGa1sznw=
+knative.dev/control-protocol v0.0.0-20210504094437-d6392770de44 h1:TCxTd2U4OUhcLDbwfvl03xHd3JVg+4lXp7QEYIqG4+g=
+knative.dev/control-protocol v0.0.0-20210504094437-d6392770de44/go.mod h1:HFKVsvZvmEkyWOUdwu3OJiO9ovxV20YNi6o0UsxufSY=
+knative.dev/eventing v0.22.1-0.20210504001137-8a094e6031f2 h1:m1Thy5RduRcPY60QRWXRHO5P2gZDex9uk7aF4rnvd4k=
+knative.dev/eventing v0.22.1-0.20210504001137-8a094e6031f2/go.mod h1:p7FKFj0dYMKI1Ji0GSKdRg2YzLMWVXABm0QHN2RtkSI=
 knative.dev/hack v0.0.0-20210325223819-b6ab329907d3/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
-knative.dev/hack v0.0.0-20210426064739-88c69cd1eca7 h1:Z5icQ2KNCDSzTcHWMGI3KzdK/BpmgkGYdTX0RRzZul0=
-knative.dev/hack v0.0.0-20210426064739-88c69cd1eca7/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
-knative.dev/hack v0.0.0-20210427190353-86f9adc0c8e2 h1:gWUzTKUjMzXBMpkadqWdxIHlkSOuczsP1fD2qtyjge4=
 knative.dev/hack v0.0.0-20210427190353-86f9adc0c8e2/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
 knative.dev/hack v0.0.0-20210428122153-93ad9129c268 h1:lBIj9Epd9UQ55NEaHzAdY/UZbuaegCdGPKVC2+Z68Q0=
 knative.dev/hack v0.0.0-20210428122153-93ad9129c268/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
-knative.dev/hack/schema v0.0.0-20210426064739-88c69cd1eca7/go.mod h1:ffjwmdcrH5vN3mPhO8RrF2KfNnbHeCE2C60A+2cv3U0=
+knative.dev/hack/schema v0.0.0-20210428122153-93ad9129c268/go.mod h1:ffjwmdcrH5vN3mPhO8RrF2KfNnbHeCE2C60A+2cv3U0=
 knative.dev/networking v0.0.0-20210428161254-1ad047ce063f h1:aobK9UEGzKYcLJMd50BhRLIWMqKQYXq9NuPsOOB3Nk8=
 knative.dev/networking v0.0.0-20210428161254-1ad047ce063f/go.mod h1:6sJKmUcFFSkhloA1mWii/DCqeg9mMHfRraB/ouRzuM0=
 knative.dev/pkg v0.0.0-20210420053235-1afd04993622/go.mod h1:UtcSLHy2XIz5blWoPTA40F87zk4O7erxkCwv+7Tsmws=
-knative.dev/pkg v0.0.0-20210426180040-cfc1eed82870 h1:22gVDwcYqqZDGJOEBTBCthJH88dyTSLokOWlz1E9GIg=
-knative.dev/pkg v0.0.0-20210426180040-cfc1eed82870/go.mod h1:UtcSLHy2XIz5blWoPTA40F87zk4O7erxkCwv+7Tsmws=
-knative.dev/pkg v0.0.0-20210428023153-5a308fa62139 h1:88XRR7sk9SxrFn/TFO1iYeW2uoTg34DrfEoKX5/RqAE=
 knative.dev/pkg v0.0.0-20210428023153-5a308fa62139/go.mod h1:7Xmwv60SD68lc4mpbKvU1J4WJLfZNNDNpHFA87T7/AM=
 knative.dev/pkg v0.0.0-20210428141353-878c85083565 h1:4I8Pm2IlSJbdJ1R9fC18kOlZlfCZkB59JraRGratgnY=
 knative.dev/pkg v0.0.0-20210428141353-878c85083565/go.mod h1:fIl4l4OmZodkElyaHoT0LCF5wT+3+P/kinawQ4XlLtE=
 knative.dev/reconciler-test v0.0.0-20210426151439-cd315b0f06aa/go.mod h1:yZihS1XoBt7oxU6Jq+U2hMKmUvfKFEaj3vMqOMBt/tI=
+knative.dev/reconciler-test v0.0.0-20210428195854-3db87491edb3/go.mod h1:yZihS1XoBt7oxU6Jq+U2hMKmUvfKFEaj3vMqOMBt/tI=
 pgregory.net/rapid v0.3.3 h1:jCjBsY4ln4Atz78QoBWxUEvAHaFyNDQg9+WU62aCn1U=
 pgregory.net/rapid v0.3.3/go.mod h1:UYpPVyjFHzYBGHIxLFoupi8vwk6rXNzRY9OMvVxFIOU=
 rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
diff --git a/vendor/knative.dev/control-protocol/pkg/connection.go b/vendor/knative.dev/control-protocol/pkg/connection.go
index fdab3f1fa..8d2bcef16 100644
--- a/vendor/knative.dev/control-protocol/pkg/connection.go
+++ b/vendor/knative.dev/control-protocol/pkg/connection.go
@@ -16,13 +16,19 @@ limitations under the License.
 
 package control
 
+import "context"
+
 // Connection handles the low level stuff, reading and writing to the wire
 type Connection interface {
-	// OutboundMessages returns a channel that accepts the messages that goes on the wire
-	OutboundMessages() chan<- *Message
+	// WriteMessage writes a message to the wire.
+	// This blocks until the message is written to the wire.
+	// Returns ctx.Error() if the provided context is closed.
+	WriteMessage(ctx context.Context, msg *Message) error
 
-	// InboundMessages returns a channel that returns the inbound messages from the wire
-	InboundMessages() <-chan *Message
+	// ReadMessage reads a message from the wire.
+	// This blocks until there's a message available to read.
+	// Returns ctx.Error() if the provided context is closed.
+	ReadMessage(ctx context.Context) (*Message, error)
 
 	// Errors returns a channel that signals very bad, usually fatal, errors
 	// (like cannot re-establish the connection after several attempts)
diff --git a/vendor/knative.dev/control-protocol/pkg/network/base_connection.go b/vendor/knative.dev/control-protocol/pkg/network/base_connection.go
index 2b5260006..ac339e966 100644
--- a/vendor/knative.dev/control-protocol/pkg/network/base_connection.go
+++ b/vendor/knative.dev/control-protocol/pkg/network/base_connection.go
@@ -39,12 +39,23 @@ type baseTcpConnection struct {
 	errors                 chan error
 }
 
-func (t *baseTcpConnection) OutboundMessages() chan<- *ctrl.Message {
-	return t.outboundMessageChannel
+var _ ctrl.Connection = (*baseTcpConnection)(nil)
+
+func (t *baseTcpConnection) WriteMessage(ctx context.Context, msg *ctrl.Message) error {
+	t.outboundMessageChannel <- msg
+	return nil
 }
 
-func (t *baseTcpConnection) InboundMessages() <-chan *ctrl.Message {
-	return t.inboundMessageChannel
+func (t *baseTcpConnection) ReadMessage(ctx context.Context) (*ctrl.Message, error) {
+	select {
+	case msg, ok := <-t.inboundMessageChannel:
+		if !ok {
+			return nil, ctx.Err()
+		}
+		return msg, nil
+	case <-ctx.Done():
+		return nil, ctx.Err()
+	}
 }
 
 func (t *baseTcpConnection) Errors() <-chan error {
@@ -118,7 +129,7 @@ func (t *baseTcpConnection) consumeConnection(conn net.Conn) {
 				}
 				err := t.write(conn, msg)
 				if err != nil {
-					t.outboundMessageChannel <- msg
+					t.WriteMessage(t.ctx, msg) // TODO
 
 					if isEOF(err) {
 						return // Closed conn
diff --git a/vendor/knative.dev/control-protocol/pkg/service/service.go b/vendor/knative.dev/control-protocol/pkg/service/service.go
index 08bd00779..5bff01384 100644
--- a/vendor/knative.dev/control-protocol/pkg/service/service.go
+++ b/vendor/knative.dev/control-protocol/pkg/service/service.go
@@ -93,7 +93,10 @@ func (c *service) sendBinaryAndWaitForAck(opcode ctrl.OpCode, payload []byte) er
 		c.waitingAcksMutex.Unlock()
 	}()
 
-	c.connection.OutboundMessages() <- &msg
+	err := c.connection.WriteMessage(c.ctx, &msg)
+	if err != nil {
+		return err
+	}
 
 	select {
 	case err := <-ackCh:
@@ -120,15 +123,21 @@ func (c *service) ErrorHandler(handler ctrl.ErrorHandler) {
 }
 
 func (c *service) startPolling() {
+	go func() {
+		for {
+			msg, err := c.connection.ReadMessage(c.ctx)
+			if err != nil && err == c.ctx.Err() {
+				// Context closed, service closed
+				return
+			} else if err != nil {
+				logging.FromContext(c.ctx).Debugf("Error while reading message from the connection")
+			}
+			go c.accept(msg)
+		}
+	}()
 	go func() {
 		for {
 			select {
-			case msg, ok := <-c.connection.InboundMessages():
-				if !ok {
-					logging.FromContext(c.ctx).Debugf("InboundMessages channel closed, closing the polling")
-					return
-				}
-				go c.accept(msg)
 			case err, ok := <-c.connection.Errors():
 				if !ok {
 					logging.FromContext(c.ctx).Debugf("Errors channel closed")
@@ -162,12 +171,8 @@ func (c *service) accept(msg *ctrl.Message) {
 	} else {
 		ackFunc := func(err error) {
 			ackMsg := newAckMessage(msg.UUID(), err)
-			// Before resending, check if context is not closed
-			select {
-			case <-c.ctx.Done():
-				return
-			default:
-				c.connection.OutboundMessages() <- &ackMsg
+			if err := c.connection.WriteMessage(c.ctx, &ackMsg); err != nil && err != c.ctx.Err() {
+				logging.FromContext(c.ctx).Warnf("Unexpected failure while acking back: %v", err)
 			}
 		}
 		c.handlerMutex.RLock()
diff --git a/vendor/knative.dev/eventing/pkg/apis/messaging/config/channel_template_types.go b/vendor/knative.dev/eventing/pkg/apis/messaging/config/channel_template_types.go
index 822334572..faf7d551f 100644
--- a/vendor/knative.dev/eventing/pkg/apis/messaging/config/channel_template_types.go
+++ b/vendor/knative.dev/eventing/pkg/apis/messaging/config/channel_template_types.go
@@ -21,7 +21,7 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 )
 
-// This is a verbatim copy from messaging/v1beta1/channel_template_types.go
+// This is a verbatim copy from messaging/v1/channel_template_types.go
 // but we can not import v1beta1 since we use this there as well, so
 // replicate it here.
 
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_defaults.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_conversion.go
similarity index 50%
rename from vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_defaults.go
rename to vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_conversion.go
index b04ced117..12afe722e 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_defaults.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_conversion.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+Copyright 2021 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.
@@ -14,21 +14,23 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package v1beta1
+package v1
 
 import (
 	"context"
+	"fmt"
 
 	"knative.dev/pkg/apis"
 )
 
-// SetDefaults implements apis.Defaultable
-func (fb *SinkBinding) SetDefaults(ctx context.Context) {
-	if fb.Spec.Subject.Namespace == "" {
-		// Default the subject's namespace to our namespace.
-		fb.Spec.Subject.Namespace = fb.Namespace
-	}
+// ConvertTo implements apis.Convertible
+// Converts source from v1.PingSource into a higher version.
+func (source *PingSource) ConvertTo(ctx context.Context, sink apis.Convertible) error {
+	return fmt.Errorf("v1 is the highest known version, got: %T", sink)
+}
 
-	withNS := apis.WithinParent(ctx, fb.ObjectMeta)
-	fb.Spec.Sink.SetDefaults(withNS)
+// ConvertFrom implements apis.Convertible
+// Converts source from a higher version into v1.PingSource
+func (sink *PingSource) ConvertFrom(ctx context.Context, source apis.Convertible) error {
+	return fmt.Errorf("v1 is the highest known version, got: %T", source)
 }
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_defaults.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_defaults.go
similarity index 94%
rename from vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_defaults.go
rename to vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_defaults.go
index 9fef43260..efe8db64f 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_defaults.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_defaults.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+Copyright 2021 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.
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package v1beta1
+package v1
 
 import (
 	"context"
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_lifecycle.go
similarity index 98%
rename from vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_lifecycle.go
rename to vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_lifecycle.go
index 454f492a4..a7a0bb908 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_lifecycle.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_lifecycle.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+Copyright 2021 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.
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package v1beta1
+package v1
 
 import (
 	"fmt"
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_types.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_types.go
similarity index 83%
rename from vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_types.go
rename to vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_types.go
index c421eeb91..5390fc288 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_types.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_types.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+Copyright 2021 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.
@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package v1beta1
+package v1
 
 import (
 	"knative.dev/pkg/apis"
@@ -58,7 +58,7 @@ type PingSourceSpec struct {
 	//   and modifications of the event sent to the sink.
 	duckv1.SourceSpec `json:",inline"`
 
-	// Schedule is the cronjob schedule. Defaults to `* * * * *`.
+	// Schedule is the cron schedule. Defaults to `* * * * *`.
 	// +optional
 	Schedule string `json:"schedule,omitempty"`
 
@@ -68,11 +68,19 @@ type PingSourceSpec struct {
 	// List of valid timezone values: https://en.wikipedia.org/wiki/List_of_tz_database_time_zones
 	Timezone string `json:"timezone,omitempty"`
 
-	// JsonData is json encoded data used as the body of the event posted to
-	// the sink. Default is empty. If set, datacontenttype will also be set
-	// to "application/json".
+	// ContentType is the media type of Data or DataBase64. Default is empty.
 	// +optional
-	JsonData string `json:"jsonData,omitempty"`
+	ContentType string `json:"contentType,omitempty"`
+
+	// Data is data used as the body of the event posted to the sink. Default is empty.
+	// Mutually exclusive with DataBase64.
+	// +optional
+	Data string `json:"data,omitempty"`
+
+	// DataBase64 is the base64-encoded string of the actual event's body posted to the sink. Default is empty.
+	// Mutually exclusive with Data.
+	// +optional
+	DataBase64 string `json:"dataBase64,omitempty"`
 }
 
 // PingSourceStatus defines the observed state of PingSource.
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_validation.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_validation.go
new file mode 100644
index 000000000..d86489747
--- /dev/null
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_validation.go
@@ -0,0 +1,100 @@
+/*
+Copyright 2021 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 v1
+
+import (
+	"context"
+	"encoding/base64"
+	"encoding/json"
+	"fmt"
+	"strings"
+
+	cloudevents "github.com/cloudevents/sdk-go/v2"
+
+	"github.com/robfig/cron/v3"
+	"knative.dev/pkg/apis"
+
+	"knative.dev/eventing/pkg/apis/sources/config"
+)
+
+func (c *PingSource) Validate(ctx context.Context) *apis.FieldError {
+	return c.Spec.Validate(ctx).ViaField("spec")
+}
+
+func (cs *PingSourceSpec) Validate(ctx context.Context) *apis.FieldError {
+	var errs *apis.FieldError
+
+	schedule := cs.Schedule
+	if cs.Timezone != "" {
+		schedule = "CRON_TZ=" + cs.Timezone + " " + schedule
+	}
+
+	if _, err := cron.ParseStandard(schedule); err != nil {
+		if strings.HasPrefix(err.Error(), "provided bad location") {
+			fe := apis.ErrInvalidValue(err, "timezone")
+			errs = errs.Also(fe)
+		} else {
+			fe := apis.ErrInvalidValue(err, "schedule")
+			errs = errs.Also(fe)
+		}
+	}
+
+	pingConfig := config.FromContextOrDefaults(ctx)
+	pingDefaults := pingConfig.PingDefaults.GetPingConfig()
+
+	if fe := cs.Sink.Validate(ctx); fe != nil {
+		errs = errs.Also(fe.ViaField("sink"))
+	}
+
+	if cs.Data != "" && cs.DataBase64 != "" {
+		errs = errs.Also(apis.ErrMultipleOneOf("data", "dataBase64"))
+	} else if cs.DataBase64 != "" {
+		if bsize := int64(len(cs.DataBase64)); pingDefaults.DataMaxSize > -1 && bsize > pingDefaults.DataMaxSize {
+			fe := apis.ErrInvalidValue(fmt.Sprintf("the dataBase64 length of %d bytes exceeds limit set at %d.", bsize, pingDefaults.DataMaxSize), "dataBase64")
+			errs = errs.Also(fe)
+		}
+		decoded, err := base64.StdEncoding.DecodeString(cs.DataBase64)
+		// invalid base64 string
+		if err != nil {
+			errs = errs.Also(apis.ErrInvalidValue(err, "dataBase64"))
+		} else {
+			// validate if the decoded base64 string is valid JSON
+			if cs.ContentType == cloudevents.ApplicationJSON {
+				if err := validateJSON(string(decoded)); err != nil {
+					errs = errs.Also(apis.ErrInvalidValue(err, "dataBase64"))
+				}
+			}
+		}
+	} else if cs.Data != "" {
+		if bsize := int64(len(cs.Data)); pingDefaults.DataMaxSize > -1 && bsize > pingDefaults.DataMaxSize {
+			fe := apis.ErrInvalidValue(fmt.Sprintf("the data length of %d bytes exceeds limit set at %d.", bsize, pingDefaults.DataMaxSize), "data")
+			errs = errs.Also(fe)
+		}
+		if cs.ContentType == cloudevents.ApplicationJSON {
+			// validate if data is valid JSON
+			if err := validateJSON(cs.Data); err != nil {
+				errs = errs.Also(apis.ErrInvalidValue(err, "data"))
+			}
+		}
+	}
+	return errs
+}
+
+func validateJSON(str string) error {
+	var objmap map[string]interface{}
+	return json.Unmarshal([]byte(str), &objmap)
+}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1/register.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/register.go
index f0e2c1986..45260f42c 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1/register.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/register.go
@@ -51,6 +51,8 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&SinkBindingList{},
 		&ContainerSource{},
 		&ContainerSourceList{},
+		&PingSource{},
+		&PingSourceList{},
 	)
 	metav1.AddToGroupVersion(scheme, SchemeGroupVersion)
 	return nil
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1/zz_generated.deepcopy.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/zz_generated.deepcopy.go
index 93a61b4cd..62c833778 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1/zz_generated.deepcopy.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/zz_generated.deepcopy.go
@@ -265,6 +265,101 @@ func (in *ContainerSourceStatus) DeepCopy() *ContainerSourceStatus {
 	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
+	in.SourceSpec.DeepCopyInto(&out.SourceSpec)
+	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/apis/sources/v1beta1/apiserver_conversion.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_conversion.go
deleted file mode 100644
index cc79c69be..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_conversion.go
+++ /dev/null
@@ -1,138 +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 v1beta1
-
-import (
-	"context"
-
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	v1 "knative.dev/eventing/pkg/apis/sources/v1"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-
-	"knative.dev/pkg/apis"
-)
-
-// ConvertTo implements apis.Convertible
-// Converts source (from v1beta1.ApiServerSource) into into a higher version.
-func (source *ApiServerSource) ConvertTo(ctx context.Context, obj apis.Convertible) error {
-	switch sink := obj.(type) {
-	case *v1.ApiServerSource:
-		// Meta
-		sink.ObjectMeta = source.ObjectMeta
-
-		// Spec
-
-		if len(source.Spec.Resources) > 0 {
-			sink.Spec.Resources = make([]v1.APIVersionKindSelector, len(source.Spec.Resources))
-		}
-		for i, v := range source.Spec.Resources {
-			sink.Spec.Resources[i] = v1.APIVersionKindSelector{
-				APIVersion: v.APIVersion,
-				Kind:       v.Kind,
-			}
-
-			if v.LabelSelector != nil {
-				sink.Spec.Resources[i].LabelSelector = &metav1.LabelSelector{}
-				v.LabelSelector.DeepCopyInto(sink.Spec.Resources[i].LabelSelector)
-			}
-		}
-
-		sink.Spec.EventMode = source.Spec.EventMode
-
-		// Optional Spec
-
-		if source.Spec.ResourceOwner != nil {
-			sink.Spec.ResourceOwner = &v1.APIVersionKind{
-				Kind:       source.Spec.ResourceOwner.Kind,
-				APIVersion: source.Spec.ResourceOwner.APIVersion,
-			}
-		}
-
-		var ref *duckv1.KReference
-		if source.Spec.Sink.Ref != nil {
-			ref = &duckv1.KReference{
-				Kind:       source.Spec.Sink.Ref.Kind,
-				Namespace:  source.Spec.Sink.Ref.Namespace,
-				Name:       source.Spec.Sink.Ref.Name,
-				APIVersion: source.Spec.Sink.Ref.APIVersion,
-			}
-		}
-		sink.Spec.Sink = duckv1.Destination{
-			Ref: ref,
-			URI: source.Spec.Sink.URI,
-		}
-
-		if source.Spec.CloudEventOverrides != nil {
-			sink.Spec.CloudEventOverrides = source.Spec.CloudEventOverrides.DeepCopy()
-		}
-
-		sink.Spec.ServiceAccountName = source.Spec.ServiceAccountName
-
-		// Status
-		source.Status.SourceStatus.DeepCopyInto(&sink.Status.SourceStatus)
-		return nil
-	default:
-		return apis.ConvertToViaProxy(ctx, source, &v1.ApiServerSource{}, sink)
-	}
-}
-
-// ConvertFrom implements apis.Convertible
-// Converts obj from a higher version into v1beta1.ApiServerSource.
-func (sink *ApiServerSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error {
-	switch source := obj.(type) {
-	case *v1.ApiServerSource:
-		// Meta
-		sink.ObjectMeta = source.ObjectMeta
-
-		// Spec
-		sink.Spec.EventMode = source.Spec.EventMode
-
-		sink.Spec.CloudEventOverrides = source.Spec.CloudEventOverrides
-
-		sink.Spec.Sink = source.Spec.Sink
-
-		if len(source.Spec.Resources) > 0 {
-			sink.Spec.Resources = make([]APIVersionKindSelector, len(source.Spec.Resources))
-		}
-		for i, v := range source.Spec.Resources {
-			sink.Spec.Resources[i] = APIVersionKindSelector{}
-			sink.Spec.Resources[i].APIVersion = v.APIVersion
-			sink.Spec.Resources[i].Kind = v.Kind
-			if v.LabelSelector != nil {
-				sink.Spec.Resources[i].LabelSelector = v.LabelSelector.DeepCopy()
-			}
-		}
-
-		// Spec Optionals
-
-		if source.Spec.ResourceOwner != nil {
-			sink.Spec.ResourceOwner = &APIVersionKind{
-				Kind:       source.Spec.ResourceOwner.Kind,
-				APIVersion: source.Spec.ResourceOwner.APIVersion,
-			}
-		}
-
-		sink.Spec.ServiceAccountName = source.Spec.ServiceAccountName
-
-		// Status
-		source.Status.SourceStatus.DeepCopyInto(&sink.Status.SourceStatus)
-
-		return nil
-	default:
-		return apis.ConvertFromViaProxy(ctx, source, &v1.ApiServerSource{}, sink)
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_defaults.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_defaults.go
deleted file mode 100644
index 31fcba4bc..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_defaults.go
+++ /dev/null
@@ -1,36 +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 v1beta1
-
-import (
-	"context"
-)
-
-func (s *ApiServerSource) SetDefaults(ctx context.Context) {
-	s.Spec.SetDefaults(ctx)
-}
-
-func (ss *ApiServerSourceSpec) SetDefaults(ctx context.Context) {
-
-	if ss.EventMode == "" {
-		ss.EventMode = ReferenceMode
-	}
-
-	if ss.ServiceAccountName == "" {
-		ss.ServiceAccountName = "default"
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_lifecycle.go
deleted file mode 100644
index 1990cabec..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_lifecycle.go
+++ /dev/null
@@ -1,126 +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 v1beta1
-
-import (
-	appsv1 "k8s.io/api/apps/v1"
-	corev1 "k8s.io/api/core/v1"
-	"k8s.io/apimachinery/pkg/runtime/schema"
-
-	"knative.dev/pkg/apis"
-)
-
-const (
-	// ApiServerConditionReady has status True when the ApiServerSource is ready to send events.
-	ApiServerConditionReady = apis.ConditionReady
-
-	// ApiServerConditionSinkProvided has status True when the ApiServerSource has been configured with a sink target.
-	ApiServerConditionSinkProvided apis.ConditionType = "SinkProvided"
-
-	// ApiServerConditionDeployed has status True when the ApiServerSource has had it's deployment created.
-	ApiServerConditionDeployed apis.ConditionType = "Deployed"
-
-	// ApiServerConditionSufficientPermissions has status True when the ApiServerSource has sufficient permissions to access resources.
-	ApiServerConditionSufficientPermissions apis.ConditionType = "SufficientPermissions"
-)
-
-var apiserverCondSet = apis.NewLivingConditionSet(
-	ApiServerConditionSinkProvided,
-	ApiServerConditionDeployed,
-	ApiServerConditionSufficientPermissions,
-)
-
-// GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
-func (*ApiServerSource) GetConditionSet() apis.ConditionSet {
-	return apiserverCondSet
-}
-
-// GetGroupVersionKind returns the GroupVersionKind.
-func (*ApiServerSource) GetGroupVersionKind() schema.GroupVersionKind {
-	return SchemeGroupVersion.WithKind("ApiServerSource")
-}
-
-// GetUntypedSpec returns the spec of the ApiServerSource.
-func (s *ApiServerSource) GetUntypedSpec() interface{} {
-	return s.Spec
-}
-
-// GetCondition returns the condition currently associated with the given type, or nil.
-func (s *ApiServerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition {
-	return apiserverCondSet.Manage(s).GetCondition(t)
-}
-
-// GetTopLevelCondition returns the top level condition.
-func (s *ApiServerSourceStatus) GetTopLevelCondition() *apis.Condition {
-	return apiserverCondSet.Manage(s).GetTopLevelCondition()
-}
-
-// InitializeConditions sets relevant unset conditions to Unknown state.
-func (s *ApiServerSourceStatus) InitializeConditions() {
-	apiserverCondSet.Manage(s).InitializeConditions()
-}
-
-// MarkSink sets the condition that the source has a sink configured.
-func (s *ApiServerSourceStatus) MarkSink(uri *apis.URL) {
-	s.SinkURI = uri
-	if uri != nil {
-		apiserverCondSet.Manage(s).MarkTrue(ApiServerConditionSinkProvided)
-	} else {
-		apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionSinkProvided, "SinkEmpty", "Sink has resolved to empty.%s", "")
-	}
-}
-
-// MarkNoSink sets the condition that the source does not have a sink configured.
-func (s *ApiServerSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{}) {
-	apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionSinkProvided, reason, messageFormat, messageA...)
-}
-
-// PropagateDeploymentAvailability uses the availability of the provided Deployment to determine if
-// ApiServerConditionDeployed should be marked as true or false.
-func (s *ApiServerSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment) {
-	deploymentAvailableFound := false
-	for _, cond := range d.Status.Conditions {
-		if cond.Type == appsv1.DeploymentAvailable {
-			deploymentAvailableFound = true
-			if cond.Status == corev1.ConditionTrue {
-				apiserverCondSet.Manage(s).MarkTrue(ApiServerConditionDeployed)
-			} else if cond.Status == corev1.ConditionFalse {
-				apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionDeployed, cond.Reason, cond.Message)
-			} else if cond.Status == corev1.ConditionUnknown {
-				apiserverCondSet.Manage(s).MarkUnknown(ApiServerConditionDeployed, cond.Reason, cond.Message)
-			}
-		}
-	}
-	if !deploymentAvailableFound {
-		apiserverCondSet.Manage(s).MarkUnknown(ApiServerConditionDeployed, "DeploymentUnavailable", "The Deployment '%s' is unavailable.", d.Name)
-	}
-}
-
-// MarkSufficientPermissions sets the condition that the source has enough permissions to access the resources.
-func (s *ApiServerSourceStatus) MarkSufficientPermissions() {
-	apiserverCondSet.Manage(s).MarkTrue(ApiServerConditionSufficientPermissions)
-}
-
-// MarkNoSufficientPermissions sets the condition that the source does not have enough permissions to access the resources
-func (s *ApiServerSourceStatus) MarkNoSufficientPermissions(reason, messageFormat string, messageA ...interface{}) {
-	apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionSufficientPermissions, reason, messageFormat, messageA...)
-}
-
-// IsReady returns true if the resource is ready overall.
-func (s *ApiServerSourceStatus) IsReady() bool {
-	return apiserverCondSet.Manage(s).IsHappy()
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_types.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_types.go
deleted file mode 100644
index 17728f8b5..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_types.go
+++ /dev/null
@@ -1,135 +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 v1beta1
-
-import (
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
-	"knative.dev/pkg/apis"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-	"knative.dev/pkg/kmeta"
-)
-
-// +genclient
-// +genreconciler
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-// +k8s:defaulter-gen=true
-
-// ApiServerSource is the Schema for the apiserversources API
-type ApiServerSource struct {
-	metav1.TypeMeta   `json:",inline"`
-	metav1.ObjectMeta `json:"metadata,omitempty"`
-
-	Spec   ApiServerSourceSpec   `json:"spec,omitempty"`
-	Status ApiServerSourceStatus `json:"status,omitempty"`
-}
-
-// Check the interfaces that ApiServerSource should be implementing.
-var (
-	_ runtime.Object     = (*ApiServerSource)(nil)
-	_ kmeta.OwnerRefable = (*ApiServerSource)(nil)
-	_ apis.Validatable   = (*ApiServerSource)(nil)
-	_ apis.Defaultable   = (*ApiServerSource)(nil)
-	_ apis.HasSpec       = (*ApiServerSource)(nil)
-	_ duckv1.KRShaped    = (*ApiServerSource)(nil)
-)
-
-// ApiServerSourceSpec defines the desired state of ApiServerSource
-type ApiServerSourceSpec struct {
-	// inherits duck/v1 SourceSpec, which currently provides:
-	// * Sink - a reference to an object that will resolve to a domain name or
-	//   a URI directly to use as the sink.
-	// * CloudEventOverrides - defines overrides to control the output format
-	//   and modifications of the event sent to the sink.
-	duckv1.SourceSpec `json:",inline"`
-
-	// Resource are the resources this source will track and send related
-	// lifecycle events from the Kubernetes ApiServer, with an optional label
-	// selector to help filter.
-	// +required
-	Resources []APIVersionKindSelector `json:"resources,omitempty"`
-
-	// ResourceOwner is an additional filter to only track resources that are
-	// owned by a specific resource type. If ResourceOwner matches Resources[n]
-	// then Resources[n] is allowed to pass the ResourceOwner filter.
-	// +optional
-	ResourceOwner *APIVersionKind `json:"owner,omitempty"`
-
-	// EventMode controls the format of the event.
-	// `Reference` sends a dataref event type for the resource under watch.
-	// `Resource` send the full resource lifecycle event.
-	// Defaults to `Reference`
-	// +optional
-	EventMode string `json:"mode,omitempty"`
-
-	// ServiceAccountName is the name of the ServiceAccount to use to run this
-	// source. Defaults to default if not set.
-	// +optional
-	ServiceAccountName string `json:"serviceAccountName,omitempty"`
-}
-
-// ApiServerSourceStatus defines the observed state of ApiServerSource
-type ApiServerSourceStatus 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"`
-}
-
-// APIVersionKind is an APIVersion and Kind tuple.
-type APIVersionKind struct {
-	// APIVersion - the API version of the resource to watch.
-	APIVersion string `json:"apiVersion"`
-
-	// Kind of the resource to watch.
-	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
-	Kind string `json:"kind"`
-}
-
-// APIVersionKindSelector is an APIVersion Kind tuple with a LabelSelector.
-type APIVersionKindSelector struct {
-	// APIVersion - the API version of the resource to watch.
-	APIVersion string `json:"apiVersion"`
-
-	// Kind of the resource to watch.
-	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
-	Kind string `json:"kind"`
-
-	// LabelSelector filters this source to objects to those resources pass the
-	// label selector.
-	// More info: http://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors
-	// +optional
-	LabelSelector *metav1.LabelSelector `json:"selector,omitempty"`
-}
-
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-
-// ApiServerSourceList contains a list of ApiServerSource
-type ApiServerSourceList struct {
-	metav1.TypeMeta `json:",inline"`
-	metav1.ListMeta `json:"metadata,omitempty"`
-	Items           []ApiServerSource `json:"items"`
-}
-
-// GetStatus retrieves the status of the ApiServerSource . Implements the KRShaped interface.
-func (a *ApiServerSource) GetStatus() *duckv1.Status {
-	return &a.Status.Status
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_validation.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_validation.go
deleted file mode 100644
index 97cb1d35d..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/apiserver_validation.go
+++ /dev/null
@@ -1,77 +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 v1beta1
-
-import (
-	"context"
-	"strings"
-
-	"k8s.io/apimachinery/pkg/runtime/schema"
-
-	"knative.dev/pkg/apis"
-)
-
-const (
-	// ReferenceMode produces payloads of ObjectReference
-	ReferenceMode = "Reference"
-	// ResourceMode produces payloads of ResourceEvent
-	ResourceMode = "Resource"
-)
-
-func (c *ApiServerSource) Validate(ctx context.Context) *apis.FieldError {
-	return c.Spec.Validate(ctx).ViaField("spec")
-}
-
-func (cs *ApiServerSourceSpec) Validate(ctx context.Context) *apis.FieldError {
-	var errs *apis.FieldError
-
-	// Validate mode, if can be empty or set as certain value
-	switch cs.EventMode {
-	case ReferenceMode, ResourceMode:
-	// EventMode is valid.
-	default:
-		errs = errs.Also(apis.ErrInvalidValue(cs.EventMode, "mode"))
-	}
-
-	// Validate sink
-	errs = errs.Also(cs.Sink.Validate(ctx).ViaField("sink"))
-
-	if len(cs.Resources) == 0 {
-		errs = errs.Also(apis.ErrMissingField("resources"))
-	}
-	for i, res := range cs.Resources {
-		_, err := schema.ParseGroupVersion(res.APIVersion)
-		if err != nil {
-			errs = errs.Also(apis.ErrInvalidValue(res.APIVersion, "apiVersion").ViaFieldIndex("resources", i))
-		}
-		if strings.TrimSpace(res.Kind) == "" {
-			errs = errs.Also(apis.ErrMissingField("kind").ViaFieldIndex("resources", i))
-		}
-	}
-
-	if cs.ResourceOwner != nil {
-		_, err := schema.ParseGroupVersion(cs.ResourceOwner.APIVersion)
-		if err != nil {
-			errs = errs.Also(apis.ErrInvalidValue(cs.ResourceOwner.APIVersion, "apiVersion").ViaField("owner"))
-		}
-		if strings.TrimSpace(cs.ResourceOwner.Kind) == "" {
-			errs = errs.Also(apis.ErrMissingField("kind").ViaField("owner"))
-		}
-	}
-
-	return errs
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_conversion.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_conversion.go
deleted file mode 100644
index 0588f83a5..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_conversion.go
+++ /dev/null
@@ -1,54 +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 v1beta1
-
-import (
-	"context"
-
-	v1 "knative.dev/eventing/pkg/apis/sources/v1"
-	"knative.dev/pkg/apis"
-)
-
-// ConvertTo implements apis.Convertible.
-// Converts source from v1beta1.ContainerSource into a higher version.
-func (source *ContainerSource) ConvertTo(ctx context.Context, obj apis.Convertible) error {
-	switch sink := obj.(type) {
-	case *v1.ContainerSource:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Spec.SourceSpec = source.Spec.SourceSpec
-		sink.Spec.Template = source.Spec.Template
-		sink.Status.SourceStatus = source.Status.SourceStatus
-		return nil
-	default:
-		return apis.ConvertToViaProxy(ctx, source, &v1.ContainerSource{}, sink)
-	}
-}
-
-// ConvertFrom implements apis.Convertible.
-// Converts obj from a higher version into v1beta1.ContainerSource.
-func (sink *ContainerSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error {
-	switch source := obj.(type) {
-	case *v1.ContainerSource:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Spec.SourceSpec = source.Spec.SourceSpec
-		sink.Spec.Template = source.Spec.Template
-		sink.Status.SourceStatus = source.Status.SourceStatus
-		return nil
-	default:
-		return apis.ConvertFromViaProxy(ctx, source, &v1.ContainerSource{}, sink)
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_defaults.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_defaults.go
deleted file mode 100644
index 624976a19..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_defaults.go
+++ /dev/null
@@ -1,42 +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 v1beta1
-
-import (
-	"context"
-	"fmt"
-
-	corev1 "k8s.io/api/core/v1"
-	"knative.dev/pkg/apis"
-)
-
-func (s *ContainerSource) SetDefaults(ctx context.Context) {
-	withName := apis.WithinParent(ctx, s.ObjectMeta)
-	s.Spec.SetDefaults(withName)
-}
-
-func (ss *ContainerSourceSpec) SetDefaults(ctx context.Context) {
-	containers := make([]corev1.Container, 0, len(ss.Template.Spec.Containers))
-	for i, c := range ss.Template.Spec.Containers {
-		// If the Container specified has no name, then default to "<source_name>_<i>".
-		if c.Name == "" {
-			c.Name = fmt.Sprintf("%s-%d", apis.ParentMeta(ctx).Name, i)
-		}
-		containers = append(containers, c)
-	}
-	ss.Template.Spec.Containers = containers
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_lifecycle.go
deleted file mode 100644
index fff83cba7..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_lifecycle.go
+++ /dev/null
@@ -1,110 +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 v1beta1
-
-import (
-	appsv1 "k8s.io/api/apps/v1"
-	corev1 "k8s.io/api/core/v1"
-	"knative.dev/pkg/apis"
-)
-
-const (
-	// ContainerSourceConditionReady has status True when the ContainerSource is ready to send events.
-	ContainerSourceConditionReady = apis.ConditionReady
-
-	// ContainerSourceConditionSinkBindingReady has status True when the ContainerSource's SinkBinding is ready.
-	ContainerSourceConditionSinkBindingReady apis.ConditionType = "SinkBindingReady"
-
-	// ContainerSourceConditionReceiveAdapterReady has status True when the ContainerSource's ReceiveAdapter is ready.
-	ContainerSourceConditionReceiveAdapterReady apis.ConditionType = "ReceiveAdapterReady"
-)
-
-var containerCondSet = apis.NewLivingConditionSet(
-	ContainerSourceConditionSinkBindingReady,
-	ContainerSourceConditionReceiveAdapterReady,
-)
-
-// GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
-func (*ContainerSource) GetConditionSet() apis.ConditionSet {
-	return containerCondSet
-}
-
-// GetCondition returns the condition currently associated with the given type, or nil.
-func (s *ContainerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition {
-	return containerCondSet.Manage(s).GetCondition(t)
-}
-
-// GetTopLevelCondition returns the top level condition.
-func (s *ContainerSourceStatus) GetTopLevelCondition() *apis.Condition {
-	return containerCondSet.Manage(s).GetTopLevelCondition()
-}
-
-// IsReady returns true if the resource is ready overall.
-func (s *ContainerSourceStatus) IsReady() bool {
-	return containerCondSet.Manage(s).IsHappy()
-}
-
-// InitializeConditions sets relevant unset conditions to Unknown state.
-func (s *ContainerSourceStatus) InitializeConditions() {
-	containerCondSet.Manage(s).InitializeConditions()
-}
-
-// PropagateSinkBindingStatus uses the availability of the provided Deployment to determine if
-// ContainerSourceConditionSinkBindingReady should be marked as true, false or unknown.
-func (s *ContainerSourceStatus) PropagateSinkBindingStatus(status *SinkBindingStatus) {
-	// Do not copy conditions nor observedGeneration
-	conditions := s.Conditions
-	observedGeneration := s.ObservedGeneration
-	s.SourceStatus = status.SourceStatus
-	s.Conditions = conditions
-	s.ObservedGeneration = observedGeneration
-
-	cond := status.GetCondition(apis.ConditionReady)
-	switch {
-	case cond == nil:
-		containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionSinkBindingReady, "", "")
-	case cond.Status == corev1.ConditionTrue:
-		containerCondSet.Manage(s).MarkTrue(ContainerSourceConditionSinkBindingReady)
-	case cond.Status == corev1.ConditionFalse:
-		containerCondSet.Manage(s).MarkFalse(ContainerSourceConditionSinkBindingReady, cond.Reason, cond.Message)
-	case cond.Status == corev1.ConditionUnknown:
-		containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionSinkBindingReady, cond.Reason, cond.Message)
-	default:
-		containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionSinkBindingReady, cond.Reason, cond.Message)
-	}
-}
-
-// PropagateReceiveAdapterStatus uses the availability of the provided Deployment to determine if
-// ContainerSourceConditionReceiveAdapterReady should be marked as true or false.
-func (s *ContainerSourceStatus) PropagateReceiveAdapterStatus(d *appsv1.Deployment) {
-	deploymentAvailableFound := false
-	for _, cond := range d.Status.Conditions {
-		if cond.Type == appsv1.DeploymentAvailable {
-			deploymentAvailableFound = true
-			if cond.Status == corev1.ConditionTrue {
-				containerCondSet.Manage(s).MarkTrue(ContainerSourceConditionReceiveAdapterReady)
-			} else if cond.Status == corev1.ConditionFalse {
-				containerCondSet.Manage(s).MarkFalse(ContainerSourceConditionReceiveAdapterReady, cond.Reason, cond.Message)
-			} else if cond.Status == corev1.ConditionUnknown {
-				containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionReceiveAdapterReady, cond.Reason, cond.Message)
-			}
-		}
-	}
-	if !deploymentAvailableFound {
-		containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionReceiveAdapterReady, "DeploymentUnavailable", "The Deployment '%s' is unavailable.", d.Name)
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_types.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_types.go
deleted file mode 100644
index 444ae6b50..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_types.go
+++ /dev/null
@@ -1,98 +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 v1beta1
-
-import (
-	corev1 "k8s.io/api/core/v1"
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
-	"k8s.io/apimachinery/pkg/runtime/schema"
-	"knative.dev/pkg/apis"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-	"knative.dev/pkg/kmeta"
-)
-
-// +genclient
-// +genreconciler
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-
-// ContainerSource is the Schema for the containersources API
-type ContainerSource struct {
-	metav1.TypeMeta   `json:",inline"`
-	metav1.ObjectMeta `json:"metadata,omitempty"`
-
-	Spec   ContainerSourceSpec   `json:"spec,omitempty"`
-	Status ContainerSourceStatus `json:"status,omitempty"`
-}
-
-var (
-	_ runtime.Object     = (*ContainerSource)(nil)
-	_ kmeta.OwnerRefable = (*ContainerSource)(nil)
-	_ apis.Validatable   = (*ContainerSource)(nil)
-	_ apis.Defaultable   = (*ContainerSource)(nil)
-	_ apis.HasSpec       = (*ContainerSource)(nil)
-	_ duckv1.KRShaped    = (*ContainerSource)(nil)
-)
-
-// ContainerSourceSpec defines the desired state of ContainerSource
-type ContainerSourceSpec struct {
-	// inherits duck/v1 SourceSpec, which currently provides:
-	// * Sink - a reference to an object that will resolve to a domain name or
-	//   a URI directly to use as the sink.
-	// * CloudEventOverrides - defines overrides to control the output format
-	//   and modifications of the event sent to the sink.
-	duckv1.SourceSpec `json:",inline"`
-
-	// Template describes the pods that will be created
-	Template corev1.PodTemplateSpec `json:"template"`
-}
-
-// GetGroupVersionKind returns the GroupVersionKind.
-func (*ContainerSource) GetGroupVersionKind() schema.GroupVersionKind {
-	return SchemeGroupVersion.WithKind("ContainerSource")
-}
-
-// ContainerSourceStatus defines the observed state of ContainerSource
-type ContainerSourceStatus 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
-
-// ContainerSourceList contains a list of ContainerSource
-type ContainerSourceList struct {
-	metav1.TypeMeta `json:",inline"`
-	metav1.ListMeta `json:"metadata,omitempty"`
-	Items           []ContainerSource `json:"items"`
-}
-
-// GetUntypedSpec returns the spec of the ContainerSource.
-func (c *ContainerSource) GetUntypedSpec() interface{} {
-	return c.Spec
-}
-
-// GetStatus retrieves the status of the ContainerSource. Implements the KRShaped interface.
-func (c *ContainerSource) GetStatus() *duckv1.Status {
-	return &c.Status.Status
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_validation.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_validation.go
deleted file mode 100644
index 5d6f9d184..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/container_validation.go
+++ /dev/null
@@ -1,59 +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 v1beta1
-
-import (
-	"context"
-
-	corev1 "k8s.io/api/core/v1"
-	"knative.dev/pkg/apis"
-)
-
-func (c *ContainerSource) Validate(ctx context.Context) *apis.FieldError {
-	return c.Spec.Validate(ctx).ViaField("spec")
-}
-
-func (cs *ContainerSourceSpec) Validate(ctx context.Context) *apis.FieldError {
-	var errs *apis.FieldError
-	if fe := cs.Sink.Validate(ctx); fe != nil {
-		errs = errs.Also(fe.ViaField("sink"))
-	}
-
-	// Validate there is at least a container
-	if cs.Template.Spec.Containers == nil || len(cs.Template.Spec.Containers) == 0 {
-		fe := apis.ErrMissingField("containers")
-		errs = errs.Also(fe)
-	} else {
-		for i := range cs.Template.Spec.Containers {
-			if ce := isValidContainer(&cs.Template.Spec.Containers[i]); ce != nil {
-				errs = errs.Also(ce.ViaFieldIndex("containers", i))
-			}
-		}
-	}
-	return errs
-}
-
-func isValidContainer(c *corev1.Container) *apis.FieldError {
-	var errs *apis.FieldError
-	if c.Name == "" {
-		errs = errs.Also(apis.ErrMissingField("name"))
-	}
-	if c.Image == "" {
-		errs = errs.Also(apis.ErrMissingField("image"))
-	}
-	return errs
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/doc.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/doc.go
deleted file mode 100644
index c49210a40..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/doc.go
+++ /dev/null
@@ -1,20 +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 v1beta1 contains API Schema definitions for the sources v1beta1 API group.
-// +k8s:deepcopy-gen=package
-// +groupName=sources.knative.dev
-package v1beta1
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_conversion.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_conversion.go
deleted file mode 100644
index 44bd379e9..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_conversion.go
+++ /dev/null
@@ -1,98 +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 v1beta1
-
-import (
-	"context"
-	"encoding/json"
-	"fmt"
-
-	cloudevents "github.com/cloudevents/sdk-go/v2"
-
-	"knative.dev/eventing/pkg/apis/sources/v1beta2"
-	"knative.dev/pkg/apis"
-)
-
-type message struct {
-	Body string `json:"body"`
-}
-
-func makeMessage(body string) ([]byte, error) {
-	// try to marshal the body into an interface.
-	var objmap map[string]*json.RawMessage
-	if err := json.Unmarshal([]byte(body), &objmap); err != nil {
-		// Default to a wrapped message.
-		return json.Marshal(message{Body: body})
-	}
-	return json.Marshal(objmap)
-}
-
-// ConvertTo implements apis.Convertible
-// Converts source from v1beta1.PingSource into a higher version.
-func (source *PingSource) ConvertTo(ctx context.Context, obj apis.Convertible) error {
-	switch sink := obj.(type) {
-	case *v1beta2.PingSource:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Status = v1beta2.PingSourceStatus{
-			SourceStatus: source.Status.SourceStatus,
-		}
-		sink.Spec = v1beta2.PingSourceSpec{
-			SourceSpec: source.Spec.SourceSpec,
-			Schedule:   source.Spec.Schedule,
-			Timezone:   source.Spec.Timezone,
-		}
-
-		if source.Spec.JsonData != "" {
-			msg, err := makeMessage(source.Spec.JsonData)
-			if err != nil {
-				return fmt.Errorf("error converting jsonData to a higher version: %v", err)
-			}
-			sink.Spec.ContentType = cloudevents.ApplicationJSON
-			sink.Spec.Data = string(msg)
-		}
-
-		return nil
-	default:
-		return apis.ConvertToViaProxy(ctx, source, &v1beta2.PingSource{}, sink)
-	}
-}
-
-// ConvertFrom implements apis.Convertible
-// Converts obj from a higher version into v1beta1.PingSource.
-func (sink *PingSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error {
-	switch source := obj.(type) {
-	case *v1beta2.PingSource:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Status = PingSourceStatus{
-			SourceStatus: source.Status.SourceStatus,
-		}
-
-		sink.Spec = PingSourceSpec{
-			SourceSpec: source.Spec.SourceSpec,
-			Schedule:   source.Spec.Schedule,
-			Timezone:   source.Spec.Timezone,
-		}
-
-		if source.Spec.ContentType == cloudevents.ApplicationJSON {
-			sink.Spec.JsonData = source.Spec.Data
-		}
-
-		return nil
-	default:
-		return apis.ConvertFromViaProxy(ctx, source, &v1beta2.PingSource{}, sink)
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_validation.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_validation.go
deleted file mode 100644
index b4ca07f4b..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/ping_validation.go
+++ /dev/null
@@ -1,65 +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 v1beta1
-
-import (
-	"context"
-	"fmt"
-	"strings"
-
-	"github.com/robfig/cron/v3"
-	"knative.dev/pkg/apis"
-
-	"knative.dev/eventing/pkg/apis/sources/config"
-)
-
-func (c *PingSource) Validate(ctx context.Context) *apis.FieldError {
-	return c.Spec.Validate(ctx).ViaField("spec")
-}
-
-func (cs *PingSourceSpec) Validate(ctx context.Context) *apis.FieldError {
-	var errs *apis.FieldError
-
-	schedule := cs.Schedule
-	if cs.Timezone != "" {
-		schedule = "CRON_TZ=" + cs.Timezone + " " + schedule
-	}
-
-	if _, err := cron.ParseStandard(schedule); err != nil {
-		if strings.HasPrefix(err.Error(), "provided bad location") {
-			fe := apis.ErrInvalidValue(err, "timezone")
-			errs = errs.Also(fe)
-		} else {
-			fe := apis.ErrInvalidValue(err, "schedule")
-			errs = errs.Also(fe)
-		}
-	}
-
-	pingConfig := config.FromContextOrDefaults(ctx)
-
-	pingDefaults := pingConfig.PingDefaults.GetPingConfig()
-
-	if bsize := int64(len(cs.JsonData)); pingDefaults.DataMaxSize > -1 && bsize > pingDefaults.DataMaxSize {
-		fe := apis.ErrInvalidValue(fmt.Sprintf("the jsonData length of %d bytes exceeds limit set at %d.", bsize, pingDefaults.DataMaxSize), "jsonData")
-		errs = errs.Also(fe)
-	}
-
-	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/v1beta1/register.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/register.go
deleted file mode 100644
index b577a1953..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/register.go
+++ /dev/null
@@ -1,59 +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 v1beta1
-
-import (
-	"knative.dev/eventing/pkg/apis/sources"
-
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
-	"k8s.io/apimachinery/pkg/runtime/schema"
-)
-
-// SchemeGroupVersion is group version used to register these objects
-var SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1beta1"}
-
-// Kind takes an unqualified kind and returns back a Group qualified GroupKind
-func Kind(kind string) schema.GroupKind {
-	return SchemeGroupVersion.WithKind(kind).GroupKind()
-}
-
-// Resource takes an unqualified resource and returns a Group qualified GroupResource
-func Resource(resource string) schema.GroupResource {
-	return SchemeGroupVersion.WithResource(resource).GroupResource()
-}
-
-var (
-	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
-	AddToScheme   = SchemeBuilder.AddToScheme
-)
-
-// Adds the list of known types to Scheme.
-func addKnownTypes(scheme *runtime.Scheme) error {
-	scheme.AddKnownTypes(SchemeGroupVersion,
-		&ApiServerSource{},
-		&ApiServerSourceList{},
-		&PingSource{},
-		&PingSourceList{},
-		&SinkBinding{},
-		&SinkBindingList{},
-		&ContainerSource{},
-		&ContainerSourceList{},
-	)
-	metav1.AddToGroupVersion(scheme, SchemeGroupVersion)
-	return nil
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_context.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_context.go
deleted file mode 100644
index 8f4f7672c..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_context.go
+++ /dev/null
@@ -1,57 +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 v1beta1
-
-import (
-	"context"
-
-	"knative.dev/pkg/apis"
-	"knative.dev/pkg/resolver"
-)
-
-// sinkURIKey is used as the key for associating information
-// with a context.Context.
-type sinkURIKey struct{}
-type resolverKey struct{}
-
-// WithSinkURI notes on the context for binding that the resolved SinkURI
-// is the provided apis.URL.
-func WithSinkURI(ctx context.Context, uri *apis.URL) context.Context {
-	return context.WithValue(ctx, sinkURIKey{}, uri)
-}
-
-func WithURIResolver(ctx context.Context, resolver *resolver.URIResolver) context.Context {
-	return context.WithValue(ctx, resolverKey{}, resolver)
-}
-
-// GetSinkURI accesses the apis.URL for the Sink URI that has been associated
-// with this context.
-func GetSinkURI(ctx context.Context) *apis.URL {
-	value := ctx.Value(sinkURIKey{})
-	if value == nil {
-		return nil
-	}
-	return value.(*apis.URL)
-}
-
-func GetURIResolver(ctx context.Context) *resolver.URIResolver {
-	value := ctx.Value(resolverKey{})
-	if value == nil {
-		return nil
-	}
-	return value.(*resolver.URIResolver)
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_conversion.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_conversion.go
deleted file mode 100644
index ed196e250..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_conversion.go
+++ /dev/null
@@ -1,60 +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 v1beta1
-
-import (
-	"context"
-
-	v1 "knative.dev/eventing/pkg/apis/sources/v1"
-	"knative.dev/pkg/apis"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-	duckv1beta1 "knative.dev/pkg/apis/duck/v1beta1"
-)
-
-// ConvertTo implements apis.Convertible.
-// Converts source from v1beta1.SinkBinding into a higher version.
-func (source *SinkBinding) ConvertTo(ctx context.Context, obj apis.Convertible) error {
-	switch sink := obj.(type) {
-	case *v1.SinkBinding:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Spec.SourceSpec = source.Spec.SourceSpec
-		sink.Spec.BindingSpec = duckv1.BindingSpec{
-			Subject: source.Spec.BindingSpec.Subject,
-		}
-		sink.Status.SourceStatus = source.Status.SourceStatus
-		return nil
-	default:
-		return apis.ConvertToViaProxy(ctx, source, &v1.SinkBinding{}, sink)
-	}
-}
-
-// ConvertFrom implements apis.Convertible.
-// Converts obj from a higher version into v1beta1.SinkBinding.
-func (sink *SinkBinding) ConvertFrom(ctx context.Context, obj apis.Convertible) error {
-	switch source := obj.(type) {
-	case *v1.SinkBinding:
-		sink.ObjectMeta = source.ObjectMeta
-		sink.Spec.SourceSpec = source.Spec.SourceSpec
-		sink.Spec.BindingSpec = duckv1beta1.BindingSpec{
-			Subject: source.Spec.BindingSpec.Subject,
-		}
-		sink.Status.SourceStatus = source.Status.SourceStatus
-		return nil
-	default:
-		return apis.ConvertFromViaProxy(ctx, source, &v1.SinkBinding{}, sink)
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_lifecycle.go
deleted file mode 100644
index d62830777..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_lifecycle.go
+++ /dev/null
@@ -1,175 +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 v1beta1
-
-import (
-	"context"
-	"encoding/json"
-	"fmt"
-
-	"go.uber.org/zap"
-
-	corev1 "k8s.io/api/core/v1"
-	"k8s.io/apimachinery/pkg/runtime/schema"
-
-	"knative.dev/pkg/apis"
-	"knative.dev/pkg/apis/duck"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-	"knative.dev/pkg/logging"
-	"knative.dev/pkg/tracker"
-)
-
-var sbCondSet = apis.NewLivingConditionSet(
-	SinkBindingConditionSinkProvided,
-)
-
-// GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
-func (*SinkBinding) GetConditionSet() apis.ConditionSet {
-	return sbCondSet
-}
-
-// GetGroupVersionKind returns the GroupVersionKind.
-func (*SinkBinding) GetGroupVersionKind() schema.GroupVersionKind {
-	return SchemeGroupVersion.WithKind("SinkBinding")
-}
-
-// GetUntypedSpec implements apis.HasSpec
-func (s *SinkBinding) GetUntypedSpec() interface{} {
-	return s.Spec
-}
-
-// GetSubject implements psbinding.Bindable
-func (sb *SinkBinding) GetSubject() tracker.Reference {
-	return sb.Spec.Subject
-}
-
-// GetBindingStatus implements psbinding.Bindable
-func (sb *SinkBinding) GetBindingStatus() duck.BindableStatus {
-	return &sb.Status
-}
-
-// SetObservedGeneration implements psbinding.BindableStatus
-func (sbs *SinkBindingStatus) SetObservedGeneration(gen int64) {
-	sbs.ObservedGeneration = gen
-}
-
-// InitializeConditions populates the SinkBindingStatus's conditions field
-// with all of its conditions configured to Unknown.
-func (sbs *SinkBindingStatus) InitializeConditions() {
-	sbCondSet.Manage(sbs).InitializeConditions()
-}
-
-// MarkBindingUnavailable marks the SinkBinding's Ready condition to False with
-// the provided reason and message.
-func (sbs *SinkBindingStatus) MarkBindingUnavailable(reason, message string) {
-	sbCondSet.Manage(sbs).MarkFalse(SinkBindingConditionReady, reason, message)
-}
-
-// MarkBindingAvailable marks the SinkBinding's Ready condition to True.
-func (sbs *SinkBindingStatus) MarkBindingAvailable() {
-	sbCondSet.Manage(sbs).MarkTrue(SinkBindingConditionReady)
-}
-
-// MarkSink sets the condition that the source has a sink configured.
-func (sbs *SinkBindingStatus) MarkSink(uri *apis.URL) {
-	sbs.SinkURI = uri
-	if uri != nil {
-		sbCondSet.Manage(sbs).MarkTrue(SinkBindingConditionSinkProvided)
-	} else {
-		sbCondSet.Manage(sbs).MarkFalse(SinkBindingConditionSinkProvided, "SinkEmpty", "Sink has resolved to empty.%s", "")
-	}
-}
-
-// Do implements psbinding.Bindable
-func (sb *SinkBinding) Do(ctx context.Context, ps *duckv1.WithPod) {
-	// First undo so that we can just unconditionally append below.
-	sb.Undo(ctx, ps)
-
-	resolver := GetURIResolver(ctx)
-	if resolver == nil {
-		logging.FromContext(ctx).Errorf("No Resolver associated with context for sink: %+v", sb)
-	}
-	uri, err := resolver.URIFromDestinationV1(ctx, sb.Spec.Sink, sb)
-	if err != nil {
-		logging.FromContext(ctx).Errorw("URI could not be extracted from destination: ", zap.Error(err))
-		return
-	}
-	sb.Status.MarkSink(uri)
-
-	var ceOverrides string
-	if sb.Spec.CloudEventOverrides != nil {
-		if co, err := json.Marshal(sb.Spec.SourceSpec.CloudEventOverrides); err != nil {
-			logging.FromContext(ctx).Errorw(fmt.Sprintf("Failed to marshal CloudEventOverrides into JSON for %+v", sb), zap.Error(err))
-		} else if len(co) > 0 {
-			ceOverrides = string(co)
-		}
-	}
-
-	spec := ps.Spec.Template.Spec
-	for i := range spec.InitContainers {
-		spec.InitContainers[i].Env = append(spec.InitContainers[i].Env, corev1.EnvVar{
-			Name:  "K_SINK",
-			Value: uri.String(),
-		}, corev1.EnvVar{
-			Name:  "K_CE_OVERRIDES",
-			Value: ceOverrides,
-		})
-	}
-	for i := range spec.Containers {
-		spec.Containers[i].Env = append(spec.Containers[i].Env, corev1.EnvVar{
-			Name:  "K_SINK",
-			Value: uri.String(),
-		}, corev1.EnvVar{
-			Name:  "K_CE_OVERRIDES",
-			Value: ceOverrides,
-		})
-	}
-}
-
-func (sb *SinkBinding) Undo(ctx context.Context, ps *duckv1.WithPod) {
-	spec := ps.Spec.Template.Spec
-	for i, c := range spec.InitContainers {
-		if len(c.Env) == 0 {
-			continue
-		}
-		env := make([]corev1.EnvVar, 0, len(spec.InitContainers[i].Env))
-		for j, ev := range c.Env {
-			switch ev.Name {
-			case "K_SINK", "K_CE_OVERRIDES":
-				continue
-			default:
-				env = append(env, spec.InitContainers[i].Env[j])
-			}
-		}
-		spec.InitContainers[i].Env = env
-	}
-	for i, c := range spec.Containers {
-		if len(c.Env) == 0 {
-			continue
-		}
-		env := make([]corev1.EnvVar, 0, len(spec.Containers[i].Env))
-		for j, ev := range c.Env {
-			switch ev.Name {
-			case "K_SINK", "K_CE_OVERRIDES":
-				continue
-			default:
-				env = append(env, spec.Containers[i].Env[j])
-			}
-		}
-		spec.Containers[i].Env = env
-	}
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_types.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_types.go
deleted file mode 100644
index 9e5c2c2c4..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_types.go
+++ /dev/null
@@ -1,105 +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 v1beta1
-
-import (
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
-	"knative.dev/pkg/apis"
-	duckv1 "knative.dev/pkg/apis/duck/v1"
-	duckv1beta1 "knative.dev/pkg/apis/duck/v1beta1"
-	"knative.dev/pkg/kmeta"
-)
-
-// +genclient
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-// +k8s:defaulter-gen=true
-
-// SinkBinding describes a Binding that is also a Source.
-// The `sink` (from the Source duck) is resolved to a URL and
-// then projected into the `subject` by augmenting the runtime
-// contract of the referenced containers to have a `K_SINK`
-// environment variable holding the endpoint to which to send
-// cloud events.
-type SinkBinding struct {
-	metav1.TypeMeta   `json:",inline"`
-	metav1.ObjectMeta `json:"metadata,omitempty"`
-
-	Spec   SinkBindingSpec   `json:"spec"`
-	Status SinkBindingStatus `json:"status"`
-}
-
-// Check the interfaces that SinkBinding should be implementing.
-var (
-	_ runtime.Object     = (*SinkBinding)(nil)
-	_ kmeta.OwnerRefable = (*SinkBinding)(nil)
-	_ apis.Validatable   = (*SinkBinding)(nil)
-	_ apis.Defaultable   = (*SinkBinding)(nil)
-	_ apis.HasSpec       = (*SinkBinding)(nil)
-	_ duckv1.KRShaped    = (*SinkBinding)(nil)
-)
-
-// SinkBindingSpec holds the desired state of the SinkBinding (from the client).
-type SinkBindingSpec struct {
-	// inherits duck/v1 SourceSpec, which currently provides:
-	// * Sink - a reference to an object that will resolve to a domain name or
-	//   a URI directly to use as the sink.
-	// * CloudEventOverrides - defines overrides to control the output format
-	//   and modifications of the event sent to the sink.
-	duckv1.SourceSpec `json:",inline"`
-
-	// inherits duck/v1beta1 BindingSpec, which currently provides:
-	// * Subject - Subject references the resource(s) whose "runtime contract"
-	//   should be augmented by Binding implementations.
-	duckv1beta1.BindingSpec `json:",inline"`
-}
-
-const (
-	// SinkBindingConditionReady is configured to indicate whether the Binding
-	// has been configured for resources subject to its runtime contract.
-	SinkBindingConditionReady = apis.ConditionReady
-
-	// SinkBindingConditionSinkProvided is configured to indicate whether the
-	// sink has been properly extracted from the resolver.
-	SinkBindingConditionSinkProvided apis.ConditionType = "SinkProvided"
-)
-
-// SinkBindingStatus communicates the observed state of the SinkBinding (from the controller).
-type SinkBindingStatus 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
-
-// SinkBindingList contains a list of SinkBinding
-type SinkBindingList struct {
-	metav1.TypeMeta `json:",inline"`
-	metav1.ListMeta `json:"metadata,omitempty"`
-	Items           []SinkBinding `json:"items"`
-}
-
-// GetStatus retrieves the status of the SinkBinding. Implements the KRShaped interface.
-func (s *SinkBinding) GetStatus() *duckv1.Status {
-	return &s.Status.Status
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_validation.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_validation.go
deleted file mode 100644
index a8447905c..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/sinkbinding_validation.go
+++ /dev/null
@@ -1,38 +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 v1beta1
-
-import (
-	"context"
-
-	"knative.dev/pkg/apis"
-)
-
-// Validate implements apis.Validatable
-func (fb *SinkBinding) Validate(ctx context.Context) *apis.FieldError {
-	err := fb.Spec.Validate(ctx).ViaField("spec")
-	if fb.Spec.Subject.Namespace != "" && fb.Namespace != fb.Spec.Subject.Namespace {
-		err = err.Also(apis.ErrInvalidValue(fb.Spec.Subject.Namespace, "spec.subject.namespace"))
-	}
-	return err
-}
-
-// Validate implements apis.Validatable
-func (fbs *SinkBindingSpec) Validate(ctx context.Context) *apis.FieldError {
-	return fbs.Subject.Validate(ctx).ViaField("subject").Also(
-		fbs.Sink.Validate(ctx).ViaField("sink"))
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/zz_generated.deepcopy.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/zz_generated.deepcopy.go
deleted file mode 100644
index 8d20cb3ec..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta1/zz_generated.deepcopy.go
+++ /dev/null
@@ -1,457 +0,0 @@
-// +build !ignore_autogenerated
-
-/*
-Copyright 2021 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 deepcopy-gen. DO NOT EDIT.
-
-package v1beta1
-
-import (
-	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	runtime "k8s.io/apimachinery/pkg/runtime"
-)
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *APIVersionKind) DeepCopyInto(out *APIVersionKind) {
-	*out = *in
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new APIVersionKind.
-func (in *APIVersionKind) DeepCopy() *APIVersionKind {
-	if in == nil {
-		return nil
-	}
-	out := new(APIVersionKind)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *APIVersionKindSelector) DeepCopyInto(out *APIVersionKindSelector) {
-	*out = *in
-	if in.LabelSelector != nil {
-		in, out := &in.LabelSelector, &out.LabelSelector
-		*out = new(v1.LabelSelector)
-		(*in).DeepCopyInto(*out)
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new APIVersionKindSelector.
-func (in *APIVersionKindSelector) DeepCopy() *APIVersionKindSelector {
-	if in == nil {
-		return nil
-	}
-	out := new(APIVersionKindSelector)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ApiServerSource) DeepCopyInto(out *ApiServerSource) {
-	*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 ApiServerSource.
-func (in *ApiServerSource) DeepCopy() *ApiServerSource {
-	if in == nil {
-		return nil
-	}
-	out := new(ApiServerSource)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ApiServerSource) 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 *ApiServerSourceList) DeepCopyInto(out *ApiServerSourceList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]ApiServerSource, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerSourceList.
-func (in *ApiServerSourceList) DeepCopy() *ApiServerSourceList {
-	if in == nil {
-		return nil
-	}
-	out := new(ApiServerSourceList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ApiServerSourceList) 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 *ApiServerSourceSpec) DeepCopyInto(out *ApiServerSourceSpec) {
-	*out = *in
-	in.SourceSpec.DeepCopyInto(&out.SourceSpec)
-	if in.Resources != nil {
-		in, out := &in.Resources, &out.Resources
-		*out = make([]APIVersionKindSelector, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	if in.ResourceOwner != nil {
-		in, out := &in.ResourceOwner, &out.ResourceOwner
-		*out = new(APIVersionKind)
-		**out = **in
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerSourceSpec.
-func (in *ApiServerSourceSpec) DeepCopy() *ApiServerSourceSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(ApiServerSourceSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ApiServerSourceStatus) DeepCopyInto(out *ApiServerSourceStatus) {
-	*out = *in
-	in.SourceStatus.DeepCopyInto(&out.SourceStatus)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerSourceStatus.
-func (in *ApiServerSourceStatus) DeepCopy() *ApiServerSourceStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(ApiServerSourceStatus)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ContainerSource) DeepCopyInto(out *ContainerSource) {
-	*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 ContainerSource.
-func (in *ContainerSource) DeepCopy() *ContainerSource {
-	if in == nil {
-		return nil
-	}
-	out := new(ContainerSource)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ContainerSource) 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 *ContainerSourceList) DeepCopyInto(out *ContainerSourceList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]ContainerSource, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerSourceList.
-func (in *ContainerSourceList) DeepCopy() *ContainerSourceList {
-	if in == nil {
-		return nil
-	}
-	out := new(ContainerSourceList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ContainerSourceList) 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 *ContainerSourceSpec) DeepCopyInto(out *ContainerSourceSpec) {
-	*out = *in
-	in.SourceSpec.DeepCopyInto(&out.SourceSpec)
-	in.Template.DeepCopyInto(&out.Template)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerSourceSpec.
-func (in *ContainerSourceSpec) DeepCopy() *ContainerSourceSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(ContainerSourceSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ContainerSourceStatus) DeepCopyInto(out *ContainerSourceStatus) {
-	*out = *in
-	in.SourceStatus.DeepCopyInto(&out.SourceStatus)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerSourceStatus.
-func (in *ContainerSourceStatus) DeepCopy() *ContainerSourceStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(ContainerSourceStatus)
-	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
-	in.SourceSpec.DeepCopyInto(&out.SourceSpec)
-	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
-	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 SinkBinding.
-func (in *SinkBinding) DeepCopy() *SinkBinding {
-	if in == nil {
-		return nil
-	}
-	out := new(SinkBinding)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *SinkBinding) 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 *SinkBindingList) DeepCopyInto(out *SinkBindingList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]SinkBinding, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkBindingList.
-func (in *SinkBindingList) DeepCopy() *SinkBindingList {
-	if in == nil {
-		return nil
-	}
-	out := new(SinkBindingList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *SinkBindingList) 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 *SinkBindingSpec) DeepCopyInto(out *SinkBindingSpec) {
-	*out = *in
-	in.SourceSpec.DeepCopyInto(&out.SourceSpec)
-	in.BindingSpec.DeepCopyInto(&out.BindingSpec)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkBindingSpec.
-func (in *SinkBindingSpec) DeepCopy() *SinkBindingSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(SinkBindingSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *SinkBindingStatus) DeepCopyInto(out *SinkBindingStatus) {
-	*out = *in
-	in.SourceStatus.DeepCopyInto(&out.SourceStatus)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkBindingStatus.
-func (in *SinkBindingStatus) DeepCopy() *SinkBindingStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(SinkBindingStatus)
-	in.DeepCopyInto(out)
-	return out
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_conversion.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_conversion.go
index 17fb38b62..fd0ece828 100644
--- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_conversion.go
+++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_conversion.go
@@ -18,19 +18,57 @@ package v1beta2
 
 import (
 	"context"
-	"fmt"
 
 	"knative.dev/pkg/apis"
+
+	v1 "knative.dev/eventing/pkg/apis/sources/v1"
 )
 
 // ConvertTo implements apis.Convertible
 // Converts source from v1beta2.PingSource into a higher version.
-func (source *PingSource) ConvertTo(ctx context.Context, sink apis.Convertible) error {
-	return fmt.Errorf("v1beta2 is the highest known version, got: %T", sink)
+func (source *PingSource) ConvertTo(ctx context.Context, obj apis.Convertible) error {
+	switch sink := obj.(type) {
+	case *v1.PingSource:
+		sink.ObjectMeta = source.ObjectMeta
+		sink.Status = v1.PingSourceStatus{
+			SourceStatus: source.Status.SourceStatus,
+		}
+		sink.Spec = v1.PingSourceSpec{
+			SourceSpec:  source.Spec.SourceSpec,
+			Schedule:    source.Spec.Schedule,
+			Timezone:    source.Spec.Timezone,
+			ContentType: source.Spec.ContentType,
+			Data:        source.Spec.Data,
+			DataBase64:  source.Spec.DataBase64,
+		}
+
+		return nil
+	default:
+		return apis.ConvertToViaProxy(ctx, source, &v1.PingSource{}, sink)
+	}
 }
 
 // ConvertFrom implements apis.Convertible
 // Converts source from a higher version into v1beta2.PingSource
-func (sink *PingSource) ConvertFrom(ctx context.Context, source apis.Convertible) error {
-	return fmt.Errorf("v1beta2 is the highest known version, got: %T", source)
+func (sink *PingSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error {
+	switch source := obj.(type) {
+	case *v1.PingSource:
+		sink.ObjectMeta = source.ObjectMeta
+		sink.Status = PingSourceStatus{
+			SourceStatus: source.Status.SourceStatus,
+		}
+
+		sink.Spec = PingSourceSpec{
+			SourceSpec:  source.Spec.SourceSpec,
+			Schedule:    source.Spec.Schedule,
+			Timezone:    source.Spec.Timezone,
+			ContentType: source.Spec.ContentType,
+			Data:        source.Spec.Data,
+			DataBase64:  source.Spec.DataBase64,
+		}
+
+		return nil
+	default:
+		return apis.ConvertFromViaProxy(ctx, source, &v1.PingSource{}, sink)
+	}
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/clientset.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/clientset.go
index 82af05079..dfdaf91fa 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/clientset.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/clientset.go
@@ -29,7 +29,6 @@ import (
 	flowsv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/flows/v1"
 	messagingv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/messaging/v1"
 	sourcesv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1"
-	sourcesv1beta1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1"
 	sourcesv1beta2 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta2"
 )
 
@@ -39,7 +38,6 @@ type Interface interface {
 	EventingV1() eventingv1.EventingV1Interface
 	FlowsV1() flowsv1.FlowsV1Interface
 	MessagingV1() messagingv1.MessagingV1Interface
-	SourcesV1beta1() sourcesv1beta1.SourcesV1beta1Interface
 	SourcesV1beta2() sourcesv1beta2.SourcesV1beta2Interface
 	SourcesV1() sourcesv1.SourcesV1Interface
 }
@@ -52,7 +50,6 @@ type Clientset struct {
 	eventingV1      *eventingv1.EventingV1Client
 	flowsV1         *flowsv1.FlowsV1Client
 	messagingV1     *messagingv1.MessagingV1Client
-	sourcesV1beta1  *sourcesv1beta1.SourcesV1beta1Client
 	sourcesV1beta2  *sourcesv1beta2.SourcesV1beta2Client
 	sourcesV1       *sourcesv1.SourcesV1Client
 }
@@ -77,11 +74,6 @@ func (c *Clientset) MessagingV1() messagingv1.MessagingV1Interface {
 	return c.messagingV1
 }
 
-// SourcesV1beta1 retrieves the SourcesV1beta1Client
-func (c *Clientset) SourcesV1beta1() sourcesv1beta1.SourcesV1beta1Interface {
-	return c.sourcesV1beta1
-}
-
 // SourcesV1beta2 retrieves the SourcesV1beta2Client
 func (c *Clientset) SourcesV1beta2() sourcesv1beta2.SourcesV1beta2Interface {
 	return c.sourcesV1beta2
@@ -129,10 +121,6 @@ func NewForConfig(c *rest.Config) (*Clientset, error) {
 	if err != nil {
 		return nil, err
 	}
-	cs.sourcesV1beta1, err = sourcesv1beta1.NewForConfig(&configShallowCopy)
-	if err != nil {
-		return nil, err
-	}
 	cs.sourcesV1beta2, err = sourcesv1beta2.NewForConfig(&configShallowCopy)
 	if err != nil {
 		return nil, err
@@ -157,7 +145,6 @@ func NewForConfigOrDie(c *rest.Config) *Clientset {
 	cs.eventingV1 = eventingv1.NewForConfigOrDie(c)
 	cs.flowsV1 = flowsv1.NewForConfigOrDie(c)
 	cs.messagingV1 = messagingv1.NewForConfigOrDie(c)
-	cs.sourcesV1beta1 = sourcesv1beta1.NewForConfigOrDie(c)
 	cs.sourcesV1beta2 = sourcesv1beta2.NewForConfigOrDie(c)
 	cs.sourcesV1 = sourcesv1.NewForConfigOrDie(c)
 
@@ -172,7 +159,6 @@ func New(c rest.Interface) *Clientset {
 	cs.eventingV1 = eventingv1.New(c)
 	cs.flowsV1 = flowsv1.New(c)
 	cs.messagingV1 = messagingv1.New(c)
-	cs.sourcesV1beta1 = sourcesv1beta1.New(c)
 	cs.sourcesV1beta2 = sourcesv1beta2.New(c)
 	cs.sourcesV1 = sourcesv1.New(c)
 
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/clientset_generated.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/clientset_generated.go
index d9125db11..72ba5e0dc 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/clientset_generated.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/clientset_generated.go
@@ -35,8 +35,6 @@ import (
 	fakemessagingv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/messaging/v1/fake"
 	sourcesv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1"
 	fakesourcesv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake"
-	sourcesv1beta1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1"
-	fakesourcesv1beta1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake"
 	sourcesv1beta2 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta2"
 	fakesourcesv1beta2 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta2/fake"
 )
@@ -108,11 +106,6 @@ func (c *Clientset) MessagingV1() messagingv1.MessagingV1Interface {
 	return &fakemessagingv1.FakeMessagingV1{Fake: &c.Fake}
 }
 
-// SourcesV1beta1 retrieves the SourcesV1beta1Client
-func (c *Clientset) SourcesV1beta1() sourcesv1beta1.SourcesV1beta1Interface {
-	return &fakesourcesv1beta1.FakeSourcesV1beta1{Fake: &c.Fake}
-}
-
 // SourcesV1beta2 retrieves the SourcesV1beta2Client
 func (c *Clientset) SourcesV1beta2() sourcesv1beta2.SourcesV1beta2Interface {
 	return &fakesourcesv1beta2.FakeSourcesV1beta2{Fake: &c.Fake}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/register.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/register.go
index f4575dc2c..b8d42a169 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/register.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/fake/register.go
@@ -29,7 +29,6 @@ import (
 	flowsv1 "knative.dev/eventing/pkg/apis/flows/v1"
 	messagingv1 "knative.dev/eventing/pkg/apis/messaging/v1"
 	sourcesv1 "knative.dev/eventing/pkg/apis/sources/v1"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
 	sourcesv1beta2 "knative.dev/eventing/pkg/apis/sources/v1beta2"
 )
 
@@ -41,7 +40,6 @@ var localSchemeBuilder = runtime.SchemeBuilder{
 	eventingv1.AddToScheme,
 	flowsv1.AddToScheme,
 	messagingv1.AddToScheme,
-	sourcesv1beta1.AddToScheme,
 	sourcesv1beta2.AddToScheme,
 	sourcesv1.AddToScheme,
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/scheme/register.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/scheme/register.go
index 729ad51c6..7cade4928 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/scheme/register.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/scheme/register.go
@@ -29,7 +29,6 @@ import (
 	flowsv1 "knative.dev/eventing/pkg/apis/flows/v1"
 	messagingv1 "knative.dev/eventing/pkg/apis/messaging/v1"
 	sourcesv1 "knative.dev/eventing/pkg/apis/sources/v1"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
 	sourcesv1beta2 "knative.dev/eventing/pkg/apis/sources/v1beta2"
 )
 
@@ -41,7 +40,6 @@ var localSchemeBuilder = runtime.SchemeBuilder{
 	eventingv1.AddToScheme,
 	flowsv1.AddToScheme,
 	messagingv1.AddToScheme,
-	sourcesv1beta1.AddToScheme,
 	sourcesv1beta2.AddToScheme,
 	sourcesv1.AddToScheme,
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_pingsource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake/fake_pingsource.go
similarity index 75%
rename from vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_pingsource.go
rename to vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake/fake_pingsource.go
index 30b61c056..a6e9ea274 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_pingsource.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake/fake_pingsource.go
@@ -27,34 +27,34 @@ import (
 	types "k8s.io/apimachinery/pkg/types"
 	watch "k8s.io/apimachinery/pkg/watch"
 	testing "k8s.io/client-go/testing"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
+	sourcesv1 "knative.dev/eventing/pkg/apis/sources/v1"
 )
 
 // FakePingSources implements PingSourceInterface
 type FakePingSources struct {
-	Fake *FakeSourcesV1beta1
+	Fake *FakeSourcesV1
 	ns   string
 }
 
-var pingsourcesResource = schema.GroupVersionResource{Group: "sources.knative.dev", Version: "v1beta1", Resource: "pingsources"}
+var pingsourcesResource = schema.GroupVersionResource{Group: "sources.knative.dev", Version: "v1", Resource: "pingsources"}
 
-var pingsourcesKind = schema.GroupVersionKind{Group: "sources.knative.dev", Version: "v1beta1", Kind: "PingSource"}
+var pingsourcesKind = schema.GroupVersionKind{Group: "sources.knative.dev", Version: "v1", 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(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.PingSource, err error) {
+func (c *FakePingSources) Get(ctx context.Context, name string, options v1.GetOptions) (result *sourcesv1.PingSource, err error) {
 	obj, err := c.Fake.
-		Invokes(testing.NewGetAction(pingsourcesResource, c.ns, name), &v1beta1.PingSource{})
+		Invokes(testing.NewGetAction(pingsourcesResource, c.ns, name), &sourcesv1.PingSource{})
 
 	if obj == nil {
 		return nil, err
 	}
-	return obj.(*v1beta1.PingSource), err
+	return obj.(*sourcesv1.PingSource), err
 }
 
 // List takes label and field selectors, and returns the list of PingSources that match those selectors.
-func (c *FakePingSources) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.PingSourceList, err error) {
+func (c *FakePingSources) List(ctx context.Context, opts v1.ListOptions) (result *sourcesv1.PingSourceList, err error) {
 	obj, err := c.Fake.
-		Invokes(testing.NewListAction(pingsourcesResource, pingsourcesKind, c.ns, opts), &v1beta1.PingSourceList{})
+		Invokes(testing.NewListAction(pingsourcesResource, pingsourcesKind, c.ns, opts), &sourcesv1.PingSourceList{})
 
 	if obj == nil {
 		return nil, err
@@ -64,8 +64,8 @@ func (c *FakePingSources) List(ctx context.Context, opts v1.ListOptions) (result
 	if label == nil {
 		label = labels.Everything()
 	}
-	list := &v1beta1.PingSourceList{ListMeta: obj.(*v1beta1.PingSourceList).ListMeta}
-	for _, item := range obj.(*v1beta1.PingSourceList).Items {
+	list := &sourcesv1.PingSourceList{ListMeta: obj.(*sourcesv1.PingSourceList).ListMeta}
+	for _, item := range obj.(*sourcesv1.PingSourceList).Items {
 		if label.Matches(labels.Set(item.Labels)) {
 			list.Items = append(list.Items, item)
 		}
@@ -81,43 +81,43 @@ func (c *FakePingSources) Watch(ctx context.Context, opts v1.ListOptions) (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 *FakePingSources) Create(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.CreateOptions) (result *v1beta1.PingSource, err error) {
+func (c *FakePingSources) Create(ctx context.Context, pingSource *sourcesv1.PingSource, opts v1.CreateOptions) (result *sourcesv1.PingSource, err error) {
 	obj, err := c.Fake.
-		Invokes(testing.NewCreateAction(pingsourcesResource, c.ns, pingSource), &v1beta1.PingSource{})
+		Invokes(testing.NewCreateAction(pingsourcesResource, c.ns, pingSource), &sourcesv1.PingSource{})
 
 	if obj == nil {
 		return nil, err
 	}
-	return obj.(*v1beta1.PingSource), err
+	return obj.(*sourcesv1.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(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.UpdateOptions) (result *v1beta1.PingSource, err error) {
+func (c *FakePingSources) Update(ctx context.Context, pingSource *sourcesv1.PingSource, opts v1.UpdateOptions) (result *sourcesv1.PingSource, err error) {
 	obj, err := c.Fake.
-		Invokes(testing.NewUpdateAction(pingsourcesResource, c.ns, pingSource), &v1beta1.PingSource{})
+		Invokes(testing.NewUpdateAction(pingsourcesResource, c.ns, pingSource), &sourcesv1.PingSource{})
 
 	if obj == nil {
 		return nil, err
 	}
-	return obj.(*v1beta1.PingSource), err
+	return obj.(*sourcesv1.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(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.UpdateOptions) (*v1beta1.PingSource, error) {
+func (c *FakePingSources) UpdateStatus(ctx context.Context, pingSource *sourcesv1.PingSource, opts v1.UpdateOptions) (*sourcesv1.PingSource, error) {
 	obj, err := c.Fake.
-		Invokes(testing.NewUpdateSubresourceAction(pingsourcesResource, "status", c.ns, pingSource), &v1beta1.PingSource{})
+		Invokes(testing.NewUpdateSubresourceAction(pingsourcesResource, "status", c.ns, pingSource), &sourcesv1.PingSource{})
 
 	if obj == nil {
 		return nil, err
 	}
-	return obj.(*v1beta1.PingSource), err
+	return obj.(*sourcesv1.PingSource), err
 }
 
 // Delete takes name of the pingSource and deletes it. Returns an error if one occurs.
 func (c *FakePingSources) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
 	_, err := c.Fake.
-		Invokes(testing.NewDeleteAction(pingsourcesResource, c.ns, name), &v1beta1.PingSource{})
+		Invokes(testing.NewDeleteAction(pingsourcesResource, c.ns, name), &sourcesv1.PingSource{})
 
 	return err
 }
@@ -126,17 +126,17 @@ func (c *FakePingSources) Delete(ctx context.Context, name string, opts v1.Delet
 func (c *FakePingSources) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
 	action := testing.NewDeleteCollectionAction(pingsourcesResource, c.ns, listOpts)
 
-	_, err := c.Fake.Invokes(action, &v1beta1.PingSourceList{})
+	_, err := c.Fake.Invokes(action, &sourcesv1.PingSourceList{})
 	return err
 }
 
 // Patch applies the patch and returns the patched pingSource.
-func (c *FakePingSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.PingSource, err error) {
+func (c *FakePingSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *sourcesv1.PingSource, err error) {
 	obj, err := c.Fake.
-		Invokes(testing.NewPatchSubresourceAction(pingsourcesResource, c.ns, name, pt, data, subresources...), &v1beta1.PingSource{})
+		Invokes(testing.NewPatchSubresourceAction(pingsourcesResource, c.ns, name, pt, data, subresources...), &sourcesv1.PingSource{})
 
 	if obj == nil {
 		return nil, err
 	}
-	return obj.(*v1beta1.PingSource), err
+	return obj.(*sourcesv1.PingSource), err
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake/fake_sources_client.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake/fake_sources_client.go
index 74abcb9f6..f53e0758d 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake/fake_sources_client.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake/fake_sources_client.go
@@ -36,6 +36,10 @@ func (c *FakeSourcesV1) ContainerSources(namespace string) v1.ContainerSourceInt
 	return &FakeContainerSources{c, namespace}
 }
 
+func (c *FakeSourcesV1) PingSources(namespace string) v1.PingSourceInterface {
+	return &FakePingSources{c, namespace}
+}
+
 func (c *FakeSourcesV1) SinkBindings(namespace string) v1.SinkBindingInterface {
 	return &FakeSinkBindings{c, namespace}
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/generated_expansion.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/generated_expansion.go
index f328e512b..22bdb65a5 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/generated_expansion.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/generated_expansion.go
@@ -22,4 +22,6 @@ type ApiServerSourceExpansion interface{}
 
 type ContainerSourceExpansion interface{}
 
+type PingSourceExpansion interface{}
+
 type SinkBindingExpansion interface{}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/pingsource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/pingsource.go
similarity index 71%
rename from vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/pingsource.go
rename to vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/pingsource.go
index f11e78af1..489b463c2 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/pingsource.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/pingsource.go
@@ -16,17 +16,17 @@ limitations under the License.
 
 // Code generated by client-gen. DO NOT EDIT.
 
-package v1beta1
+package v1
 
 import (
 	"context"
 	"time"
 
-	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	metav1 "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"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
+	v1 "knative.dev/eventing/pkg/apis/sources/v1"
 	scheme "knative.dev/eventing/pkg/client/clientset/versioned/scheme"
 )
 
@@ -38,15 +38,15 @@ type PingSourcesGetter interface {
 
 // PingSourceInterface has methods to work with PingSource resources.
 type PingSourceInterface interface {
-	Create(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.CreateOptions) (*v1beta1.PingSource, error)
-	Update(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.UpdateOptions) (*v1beta1.PingSource, error)
-	UpdateStatus(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.UpdateOptions) (*v1beta1.PingSource, error)
-	Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
-	DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error
-	Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta1.PingSource, error)
-	List(ctx context.Context, opts v1.ListOptions) (*v1beta1.PingSourceList, error)
-	Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
-	Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.PingSource, err error)
+	Create(ctx context.Context, pingSource *v1.PingSource, opts metav1.CreateOptions) (*v1.PingSource, error)
+	Update(ctx context.Context, pingSource *v1.PingSource, opts metav1.UpdateOptions) (*v1.PingSource, error)
+	UpdateStatus(ctx context.Context, pingSource *v1.PingSource, opts metav1.UpdateOptions) (*v1.PingSource, error)
+	Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
+	DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error
+	Get(ctx context.Context, name string, opts metav1.GetOptions) (*v1.PingSource, error)
+	List(ctx context.Context, opts metav1.ListOptions) (*v1.PingSourceList, error)
+	Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
+	Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.PingSource, err error)
 	PingSourceExpansion
 }
 
@@ -57,7 +57,7 @@ type pingSources struct {
 }
 
 // newPingSources returns a PingSources
-func newPingSources(c *SourcesV1beta1Client, namespace string) *pingSources {
+func newPingSources(c *SourcesV1Client, namespace string) *pingSources {
 	return &pingSources{
 		client: c.RESTClient(),
 		ns:     namespace,
@@ -65,8 +65,8 @@ func newPingSources(c *SourcesV1beta1Client, namespace string) *pingSources {
 }
 
 // Get takes name of the pingSource, and returns the corresponding pingSource object, and an error if there is any.
-func (c *pingSources) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.PingSource, err error) {
-	result = &v1beta1.PingSource{}
+func (c *pingSources) Get(ctx context.Context, name string, options metav1.GetOptions) (result *v1.PingSource, err error) {
+	result = &v1.PingSource{}
 	err = c.client.Get().
 		Namespace(c.ns).
 		Resource("pingsources").
@@ -78,12 +78,12 @@ func (c *pingSources) Get(ctx context.Context, name string, options v1.GetOption
 }
 
 // List takes label and field selectors, and returns the list of PingSources that match those selectors.
-func (c *pingSources) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.PingSourceList, err error) {
+func (c *pingSources) List(ctx context.Context, opts metav1.ListOptions) (result *v1.PingSourceList, err error) {
 	var timeout time.Duration
 	if opts.TimeoutSeconds != nil {
 		timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
 	}
-	result = &v1beta1.PingSourceList{}
+	result = &v1.PingSourceList{}
 	err = c.client.Get().
 		Namespace(c.ns).
 		Resource("pingsources").
@@ -95,7 +95,7 @@ func (c *pingSources) List(ctx context.Context, opts v1.ListOptions) (result *v1
 }
 
 // Watch returns a watch.Interface that watches the requested pingSources.
-func (c *pingSources) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+func (c *pingSources) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) {
 	var timeout time.Duration
 	if opts.TimeoutSeconds != nil {
 		timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
@@ -110,8 +110,8 @@ func (c *pingSources) Watch(ctx context.Context, opts v1.ListOptions) (watch.Int
 }
 
 // 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(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.CreateOptions) (result *v1beta1.PingSource, err error) {
-	result = &v1beta1.PingSource{}
+func (c *pingSources) Create(ctx context.Context, pingSource *v1.PingSource, opts metav1.CreateOptions) (result *v1.PingSource, err error) {
+	result = &v1.PingSource{}
 	err = c.client.Post().
 		Namespace(c.ns).
 		Resource("pingsources").
@@ -123,8 +123,8 @@ func (c *pingSources) Create(ctx context.Context, pingSource *v1beta1.PingSource
 }
 
 // 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(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.UpdateOptions) (result *v1beta1.PingSource, err error) {
-	result = &v1beta1.PingSource{}
+func (c *pingSources) Update(ctx context.Context, pingSource *v1.PingSource, opts metav1.UpdateOptions) (result *v1.PingSource, err error) {
+	result = &v1.PingSource{}
 	err = c.client.Put().
 		Namespace(c.ns).
 		Resource("pingsources").
@@ -138,8 +138,8 @@ func (c *pingSources) Update(ctx context.Context, pingSource *v1beta1.PingSource
 
 // 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(ctx context.Context, pingSource *v1beta1.PingSource, opts v1.UpdateOptions) (result *v1beta1.PingSource, err error) {
-	result = &v1beta1.PingSource{}
+func (c *pingSources) UpdateStatus(ctx context.Context, pingSource *v1.PingSource, opts metav1.UpdateOptions) (result *v1.PingSource, err error) {
+	result = &v1.PingSource{}
 	err = c.client.Put().
 		Namespace(c.ns).
 		Resource("pingsources").
@@ -153,7 +153,7 @@ func (c *pingSources) UpdateStatus(ctx context.Context, pingSource *v1beta1.Ping
 }
 
 // Delete takes name of the pingSource and deletes it. Returns an error if one occurs.
-func (c *pingSources) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+func (c *pingSources) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
 	return c.client.Delete().
 		Namespace(c.ns).
 		Resource("pingsources").
@@ -164,7 +164,7 @@ func (c *pingSources) Delete(ctx context.Context, name string, opts v1.DeleteOpt
 }
 
 // DeleteCollection deletes a collection of objects.
-func (c *pingSources) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+func (c *pingSources) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error {
 	var timeout time.Duration
 	if listOpts.TimeoutSeconds != nil {
 		timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second
@@ -180,8 +180,8 @@ func (c *pingSources) DeleteCollection(ctx context.Context, opts v1.DeleteOption
 }
 
 // Patch applies the patch and returns the patched pingSource.
-func (c *pingSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.PingSource, err error) {
-	result = &v1beta1.PingSource{}
+func (c *pingSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...string) (result *v1.PingSource, err error) {
+	result = &v1.PingSource{}
 	err = c.client.Patch(pt).
 		Namespace(c.ns).
 		Resource("pingsources").
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/sources_client.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/sources_client.go
index 4860b0db3..54ee28b29 100644
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/sources_client.go
+++ b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/sources_client.go
@@ -28,6 +28,7 @@ type SourcesV1Interface interface {
 	RESTClient() rest.Interface
 	ApiServerSourcesGetter
 	ContainerSourcesGetter
+	PingSourcesGetter
 	SinkBindingsGetter
 }
 
@@ -44,6 +45,10 @@ func (c *SourcesV1Client) ContainerSources(namespace string) ContainerSourceInte
 	return newContainerSources(c, namespace)
 }
 
+func (c *SourcesV1Client) PingSources(namespace string) PingSourceInterface {
+	return newPingSources(c, namespace)
+}
+
 func (c *SourcesV1Client) SinkBindings(namespace string) SinkBindingInterface {
 	return newSinkBindings(c, namespace)
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/apiserversource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/apiserversource.go
deleted file mode 100644
index 2e0cad0f2..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/apiserversource.go
+++ /dev/null
@@ -1,195 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"context"
-	"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"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-	scheme "knative.dev/eventing/pkg/client/clientset/versioned/scheme"
-)
-
-// ApiServerSourcesGetter has a method to return a ApiServerSourceInterface.
-// A group's client should implement this interface.
-type ApiServerSourcesGetter interface {
-	ApiServerSources(namespace string) ApiServerSourceInterface
-}
-
-// ApiServerSourceInterface has methods to work with ApiServerSource resources.
-type ApiServerSourceInterface interface {
-	Create(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.CreateOptions) (*v1beta1.ApiServerSource, error)
-	Update(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.UpdateOptions) (*v1beta1.ApiServerSource, error)
-	UpdateStatus(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.UpdateOptions) (*v1beta1.ApiServerSource, error)
-	Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
-	DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error
-	Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta1.ApiServerSource, error)
-	List(ctx context.Context, opts v1.ListOptions) (*v1beta1.ApiServerSourceList, error)
-	Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
-	Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.ApiServerSource, err error)
-	ApiServerSourceExpansion
-}
-
-// apiServerSources implements ApiServerSourceInterface
-type apiServerSources struct {
-	client rest.Interface
-	ns     string
-}
-
-// newApiServerSources returns a ApiServerSources
-func newApiServerSources(c *SourcesV1beta1Client, namespace string) *apiServerSources {
-	return &apiServerSources{
-		client: c.RESTClient(),
-		ns:     namespace,
-	}
-}
-
-// Get takes name of the apiServerSource, and returns the corresponding apiServerSource object, and an error if there is any.
-func (c *apiServerSources) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.ApiServerSource, err error) {
-	result = &v1beta1.ApiServerSource{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("apiserversources").
-		Name(name).
-		VersionedParams(&options, scheme.ParameterCodec).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// List takes label and field selectors, and returns the list of ApiServerSources that match those selectors.
-func (c *apiServerSources) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.ApiServerSourceList, err error) {
-	var timeout time.Duration
-	if opts.TimeoutSeconds != nil {
-		timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
-	}
-	result = &v1beta1.ApiServerSourceList{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("apiserversources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Watch returns a watch.Interface that watches the requested apiServerSources.
-func (c *apiServerSources) Watch(ctx context.Context, 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("apiserversources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Watch(ctx)
-}
-
-// Create takes the representation of a apiServerSource and creates it.  Returns the server's representation of the apiServerSource, and an error, if there is any.
-func (c *apiServerSources) Create(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.CreateOptions) (result *v1beta1.ApiServerSource, err error) {
-	result = &v1beta1.ApiServerSource{}
-	err = c.client.Post().
-		Namespace(c.ns).
-		Resource("apiserversources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(apiServerSource).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Update takes the representation of a apiServerSource and updates it. Returns the server's representation of the apiServerSource, and an error, if there is any.
-func (c *apiServerSources) Update(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.UpdateOptions) (result *v1beta1.ApiServerSource, err error) {
-	result = &v1beta1.ApiServerSource{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("apiserversources").
-		Name(apiServerSource.Name).
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(apiServerSource).
-		Do(ctx).
-		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 *apiServerSources) UpdateStatus(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.UpdateOptions) (result *v1beta1.ApiServerSource, err error) {
-	result = &v1beta1.ApiServerSource{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("apiserversources").
-		Name(apiServerSource.Name).
-		SubResource("status").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(apiServerSource).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Delete takes name of the apiServerSource and deletes it. Returns an error if one occurs.
-func (c *apiServerSources) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("apiserversources").
-		Name(name).
-		Body(&opts).
-		Do(ctx).
-		Error()
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *apiServerSources) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
-	var timeout time.Duration
-	if listOpts.TimeoutSeconds != nil {
-		timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second
-	}
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("apiserversources").
-		VersionedParams(&listOpts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Body(&opts).
-		Do(ctx).
-		Error()
-}
-
-// Patch applies the patch and returns the patched apiServerSource.
-func (c *apiServerSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.ApiServerSource, err error) {
-	result = &v1beta1.ApiServerSource{}
-	err = c.client.Patch(pt).
-		Namespace(c.ns).
-		Resource("apiserversources").
-		Name(name).
-		SubResource(subresources...).
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(data).
-		Do(ctx).
-		Into(result)
-	return
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/containersource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/containersource.go
deleted file mode 100644
index 4e5a42ec9..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/containersource.go
+++ /dev/null
@@ -1,195 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"context"
-	"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"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-	scheme "knative.dev/eventing/pkg/client/clientset/versioned/scheme"
-)
-
-// ContainerSourcesGetter has a method to return a ContainerSourceInterface.
-// A group's client should implement this interface.
-type ContainerSourcesGetter interface {
-	ContainerSources(namespace string) ContainerSourceInterface
-}
-
-// ContainerSourceInterface has methods to work with ContainerSource resources.
-type ContainerSourceInterface interface {
-	Create(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.CreateOptions) (*v1beta1.ContainerSource, error)
-	Update(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.UpdateOptions) (*v1beta1.ContainerSource, error)
-	UpdateStatus(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.UpdateOptions) (*v1beta1.ContainerSource, error)
-	Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
-	DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error
-	Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta1.ContainerSource, error)
-	List(ctx context.Context, opts v1.ListOptions) (*v1beta1.ContainerSourceList, error)
-	Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
-	Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.ContainerSource, err error)
-	ContainerSourceExpansion
-}
-
-// containerSources implements ContainerSourceInterface
-type containerSources struct {
-	client rest.Interface
-	ns     string
-}
-
-// newContainerSources returns a ContainerSources
-func newContainerSources(c *SourcesV1beta1Client, namespace string) *containerSources {
-	return &containerSources{
-		client: c.RESTClient(),
-		ns:     namespace,
-	}
-}
-
-// Get takes name of the containerSource, and returns the corresponding containerSource object, and an error if there is any.
-func (c *containerSources) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.ContainerSource, err error) {
-	result = &v1beta1.ContainerSource{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("containersources").
-		Name(name).
-		VersionedParams(&options, scheme.ParameterCodec).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// List takes label and field selectors, and returns the list of ContainerSources that match those selectors.
-func (c *containerSources) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.ContainerSourceList, err error) {
-	var timeout time.Duration
-	if opts.TimeoutSeconds != nil {
-		timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
-	}
-	result = &v1beta1.ContainerSourceList{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("containersources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Watch returns a watch.Interface that watches the requested containerSources.
-func (c *containerSources) Watch(ctx context.Context, 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("containersources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Watch(ctx)
-}
-
-// Create takes the representation of a containerSource and creates it.  Returns the server's representation of the containerSource, and an error, if there is any.
-func (c *containerSources) Create(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.CreateOptions) (result *v1beta1.ContainerSource, err error) {
-	result = &v1beta1.ContainerSource{}
-	err = c.client.Post().
-		Namespace(c.ns).
-		Resource("containersources").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(containerSource).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Update takes the representation of a containerSource and updates it. Returns the server's representation of the containerSource, and an error, if there is any.
-func (c *containerSources) Update(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.UpdateOptions) (result *v1beta1.ContainerSource, err error) {
-	result = &v1beta1.ContainerSource{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("containersources").
-		Name(containerSource.Name).
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(containerSource).
-		Do(ctx).
-		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 *containerSources) UpdateStatus(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.UpdateOptions) (result *v1beta1.ContainerSource, err error) {
-	result = &v1beta1.ContainerSource{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("containersources").
-		Name(containerSource.Name).
-		SubResource("status").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(containerSource).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Delete takes name of the containerSource and deletes it. Returns an error if one occurs.
-func (c *containerSources) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("containersources").
-		Name(name).
-		Body(&opts).
-		Do(ctx).
-		Error()
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *containerSources) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
-	var timeout time.Duration
-	if listOpts.TimeoutSeconds != nil {
-		timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second
-	}
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("containersources").
-		VersionedParams(&listOpts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Body(&opts).
-		Do(ctx).
-		Error()
-}
-
-// Patch applies the patch and returns the patched containerSource.
-func (c *containerSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.ContainerSource, err error) {
-	result = &v1beta1.ContainerSource{}
-	err = c.client.Patch(pt).
-		Namespace(c.ns).
-		Resource("containersources").
-		Name(name).
-		SubResource(subresources...).
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(data).
-		Do(ctx).
-		Into(result)
-	return
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/doc.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/doc.go
deleted file mode 100644
index 8d5037f07..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/doc.go
+++ /dev/null
@@ -1,20 +0,0 @@
-/*
-Copyright 2021 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.
-
-// This package has the automatically generated typed clients.
-package v1beta1
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/doc.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/doc.go
deleted file mode 100644
index d5a46ef55..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/doc.go
+++ /dev/null
@@ -1,20 +0,0 @@
-/*
-Copyright 2021 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 has the automatically generated clients.
-package fake
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_apiserversource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_apiserversource.go
deleted file mode 100644
index 31c87f2e6..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_apiserversource.go
+++ /dev/null
@@ -1,142 +0,0 @@
-/*
-Copyright 2021 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 (
-	"context"
-
-	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"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-)
-
-// FakeApiServerSources implements ApiServerSourceInterface
-type FakeApiServerSources struct {
-	Fake *FakeSourcesV1beta1
-	ns   string
-}
-
-var apiserversourcesResource = schema.GroupVersionResource{Group: "sources.knative.dev", Version: "v1beta1", Resource: "apiserversources"}
-
-var apiserversourcesKind = schema.GroupVersionKind{Group: "sources.knative.dev", Version: "v1beta1", Kind: "ApiServerSource"}
-
-// Get takes name of the apiServerSource, and returns the corresponding apiServerSource object, and an error if there is any.
-func (c *FakeApiServerSources) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.ApiServerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewGetAction(apiserversourcesResource, c.ns, name), &v1beta1.ApiServerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ApiServerSource), err
-}
-
-// List takes label and field selectors, and returns the list of ApiServerSources that match those selectors.
-func (c *FakeApiServerSources) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.ApiServerSourceList, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewListAction(apiserversourcesResource, apiserversourcesKind, c.ns, opts), &v1beta1.ApiServerSourceList{})
-
-	if obj == nil {
-		return nil, err
-	}
-
-	label, _, _ := testing.ExtractFromListOptions(opts)
-	if label == nil {
-		label = labels.Everything()
-	}
-	list := &v1beta1.ApiServerSourceList{ListMeta: obj.(*v1beta1.ApiServerSourceList).ListMeta}
-	for _, item := range obj.(*v1beta1.ApiServerSourceList).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 apiServerSources.
-func (c *FakeApiServerSources) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
-	return c.Fake.
-		InvokesWatch(testing.NewWatchAction(apiserversourcesResource, c.ns, opts))
-
-}
-
-// Create takes the representation of a apiServerSource and creates it.  Returns the server's representation of the apiServerSource, and an error, if there is any.
-func (c *FakeApiServerSources) Create(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.CreateOptions) (result *v1beta1.ApiServerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewCreateAction(apiserversourcesResource, c.ns, apiServerSource), &v1beta1.ApiServerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ApiServerSource), err
-}
-
-// Update takes the representation of a apiServerSource and updates it. Returns the server's representation of the apiServerSource, and an error, if there is any.
-func (c *FakeApiServerSources) Update(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.UpdateOptions) (result *v1beta1.ApiServerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateAction(apiserversourcesResource, c.ns, apiServerSource), &v1beta1.ApiServerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ApiServerSource), 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 *FakeApiServerSources) UpdateStatus(ctx context.Context, apiServerSource *v1beta1.ApiServerSource, opts v1.UpdateOptions) (*v1beta1.ApiServerSource, error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateSubresourceAction(apiserversourcesResource, "status", c.ns, apiServerSource), &v1beta1.ApiServerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ApiServerSource), err
-}
-
-// Delete takes name of the apiServerSource and deletes it. Returns an error if one occurs.
-func (c *FakeApiServerSources) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
-	_, err := c.Fake.
-		Invokes(testing.NewDeleteAction(apiserversourcesResource, c.ns, name), &v1beta1.ApiServerSource{})
-
-	return err
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *FakeApiServerSources) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
-	action := testing.NewDeleteCollectionAction(apiserversourcesResource, c.ns, listOpts)
-
-	_, err := c.Fake.Invokes(action, &v1beta1.ApiServerSourceList{})
-	return err
-}
-
-// Patch applies the patch and returns the patched apiServerSource.
-func (c *FakeApiServerSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.ApiServerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewPatchSubresourceAction(apiserversourcesResource, c.ns, name, pt, data, subresources...), &v1beta1.ApiServerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ApiServerSource), err
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_containersource.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_containersource.go
deleted file mode 100644
index 849e6d365..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_containersource.go
+++ /dev/null
@@ -1,142 +0,0 @@
-/*
-Copyright 2021 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 (
-	"context"
-
-	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"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-)
-
-// FakeContainerSources implements ContainerSourceInterface
-type FakeContainerSources struct {
-	Fake *FakeSourcesV1beta1
-	ns   string
-}
-
-var containersourcesResource = schema.GroupVersionResource{Group: "sources.knative.dev", Version: "v1beta1", Resource: "containersources"}
-
-var containersourcesKind = schema.GroupVersionKind{Group: "sources.knative.dev", Version: "v1beta1", Kind: "ContainerSource"}
-
-// Get takes name of the containerSource, and returns the corresponding containerSource object, and an error if there is any.
-func (c *FakeContainerSources) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.ContainerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewGetAction(containersourcesResource, c.ns, name), &v1beta1.ContainerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ContainerSource), err
-}
-
-// List takes label and field selectors, and returns the list of ContainerSources that match those selectors.
-func (c *FakeContainerSources) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.ContainerSourceList, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewListAction(containersourcesResource, containersourcesKind, c.ns, opts), &v1beta1.ContainerSourceList{})
-
-	if obj == nil {
-		return nil, err
-	}
-
-	label, _, _ := testing.ExtractFromListOptions(opts)
-	if label == nil {
-		label = labels.Everything()
-	}
-	list := &v1beta1.ContainerSourceList{ListMeta: obj.(*v1beta1.ContainerSourceList).ListMeta}
-	for _, item := range obj.(*v1beta1.ContainerSourceList).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 containerSources.
-func (c *FakeContainerSources) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
-	return c.Fake.
-		InvokesWatch(testing.NewWatchAction(containersourcesResource, c.ns, opts))
-
-}
-
-// Create takes the representation of a containerSource and creates it.  Returns the server's representation of the containerSource, and an error, if there is any.
-func (c *FakeContainerSources) Create(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.CreateOptions) (result *v1beta1.ContainerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewCreateAction(containersourcesResource, c.ns, containerSource), &v1beta1.ContainerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ContainerSource), err
-}
-
-// Update takes the representation of a containerSource and updates it. Returns the server's representation of the containerSource, and an error, if there is any.
-func (c *FakeContainerSources) Update(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.UpdateOptions) (result *v1beta1.ContainerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateAction(containersourcesResource, c.ns, containerSource), &v1beta1.ContainerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ContainerSource), 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 *FakeContainerSources) UpdateStatus(ctx context.Context, containerSource *v1beta1.ContainerSource, opts v1.UpdateOptions) (*v1beta1.ContainerSource, error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateSubresourceAction(containersourcesResource, "status", c.ns, containerSource), &v1beta1.ContainerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ContainerSource), err
-}
-
-// Delete takes name of the containerSource and deletes it. Returns an error if one occurs.
-func (c *FakeContainerSources) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
-	_, err := c.Fake.
-		Invokes(testing.NewDeleteAction(containersourcesResource, c.ns, name), &v1beta1.ContainerSource{})
-
-	return err
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *FakeContainerSources) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
-	action := testing.NewDeleteCollectionAction(containersourcesResource, c.ns, listOpts)
-
-	_, err := c.Fake.Invokes(action, &v1beta1.ContainerSourceList{})
-	return err
-}
-
-// Patch applies the patch and returns the patched containerSource.
-func (c *FakeContainerSources) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.ContainerSource, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewPatchSubresourceAction(containersourcesResource, c.ns, name, pt, data, subresources...), &v1beta1.ContainerSource{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.ContainerSource), err
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sinkbinding.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sinkbinding.go
deleted file mode 100644
index 3c52de761..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sinkbinding.go
+++ /dev/null
@@ -1,142 +0,0 @@
-/*
-Copyright 2021 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 (
-	"context"
-
-	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"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-)
-
-// FakeSinkBindings implements SinkBindingInterface
-type FakeSinkBindings struct {
-	Fake *FakeSourcesV1beta1
-	ns   string
-}
-
-var sinkbindingsResource = schema.GroupVersionResource{Group: "sources.knative.dev", Version: "v1beta1", Resource: "sinkbindings"}
-
-var sinkbindingsKind = schema.GroupVersionKind{Group: "sources.knative.dev", Version: "v1beta1", Kind: "SinkBinding"}
-
-// Get takes name of the sinkBinding, and returns the corresponding sinkBinding object, and an error if there is any.
-func (c *FakeSinkBindings) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.SinkBinding, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewGetAction(sinkbindingsResource, c.ns, name), &v1beta1.SinkBinding{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.SinkBinding), err
-}
-
-// List takes label and field selectors, and returns the list of SinkBindings that match those selectors.
-func (c *FakeSinkBindings) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.SinkBindingList, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewListAction(sinkbindingsResource, sinkbindingsKind, c.ns, opts), &v1beta1.SinkBindingList{})
-
-	if obj == nil {
-		return nil, err
-	}
-
-	label, _, _ := testing.ExtractFromListOptions(opts)
-	if label == nil {
-		label = labels.Everything()
-	}
-	list := &v1beta1.SinkBindingList{ListMeta: obj.(*v1beta1.SinkBindingList).ListMeta}
-	for _, item := range obj.(*v1beta1.SinkBindingList).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 sinkBindings.
-func (c *FakeSinkBindings) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
-	return c.Fake.
-		InvokesWatch(testing.NewWatchAction(sinkbindingsResource, c.ns, opts))
-
-}
-
-// Create takes the representation of a sinkBinding and creates it.  Returns the server's representation of the sinkBinding, and an error, if there is any.
-func (c *FakeSinkBindings) Create(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.CreateOptions) (result *v1beta1.SinkBinding, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewCreateAction(sinkbindingsResource, c.ns, sinkBinding), &v1beta1.SinkBinding{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.SinkBinding), err
-}
-
-// Update takes the representation of a sinkBinding and updates it. Returns the server's representation of the sinkBinding, and an error, if there is any.
-func (c *FakeSinkBindings) Update(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.UpdateOptions) (result *v1beta1.SinkBinding, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateAction(sinkbindingsResource, c.ns, sinkBinding), &v1beta1.SinkBinding{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.SinkBinding), 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 *FakeSinkBindings) UpdateStatus(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.UpdateOptions) (*v1beta1.SinkBinding, error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewUpdateSubresourceAction(sinkbindingsResource, "status", c.ns, sinkBinding), &v1beta1.SinkBinding{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.SinkBinding), err
-}
-
-// Delete takes name of the sinkBinding and deletes it. Returns an error if one occurs.
-func (c *FakeSinkBindings) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
-	_, err := c.Fake.
-		Invokes(testing.NewDeleteAction(sinkbindingsResource, c.ns, name), &v1beta1.SinkBinding{})
-
-	return err
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *FakeSinkBindings) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
-	action := testing.NewDeleteCollectionAction(sinkbindingsResource, c.ns, listOpts)
-
-	_, err := c.Fake.Invokes(action, &v1beta1.SinkBindingList{})
-	return err
-}
-
-// Patch applies the patch and returns the patched sinkBinding.
-func (c *FakeSinkBindings) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.SinkBinding, err error) {
-	obj, err := c.Fake.
-		Invokes(testing.NewPatchSubresourceAction(sinkbindingsResource, c.ns, name, pt, data, subresources...), &v1beta1.SinkBinding{})
-
-	if obj == nil {
-		return nil, err
-	}
-	return obj.(*v1beta1.SinkBinding), err
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sources_client.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sources_client.go
deleted file mode 100644
index 54e6b3619..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sources_client.go
+++ /dev/null
@@ -1,52 +0,0 @@
-/*
-Copyright 2021 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 (
-	rest "k8s.io/client-go/rest"
-	testing "k8s.io/client-go/testing"
-	v1beta1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1"
-)
-
-type FakeSourcesV1beta1 struct {
-	*testing.Fake
-}
-
-func (c *FakeSourcesV1beta1) ApiServerSources(namespace string) v1beta1.ApiServerSourceInterface {
-	return &FakeApiServerSources{c, namespace}
-}
-
-func (c *FakeSourcesV1beta1) ContainerSources(namespace string) v1beta1.ContainerSourceInterface {
-	return &FakeContainerSources{c, namespace}
-}
-
-func (c *FakeSourcesV1beta1) PingSources(namespace string) v1beta1.PingSourceInterface {
-	return &FakePingSources{c, namespace}
-}
-
-func (c *FakeSourcesV1beta1) SinkBindings(namespace string) v1beta1.SinkBindingInterface {
-	return &FakeSinkBindings{c, namespace}
-}
-
-// RESTClient returns a RESTClient that is used to communicate
-// with API server by this client implementation.
-func (c *FakeSourcesV1beta1) RESTClient() rest.Interface {
-	var ret *rest.RESTClient
-	return ret
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/generated_expansion.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/generated_expansion.go
deleted file mode 100644
index 10c4bf7ac..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/generated_expansion.go
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-type ApiServerSourceExpansion interface{}
-
-type ContainerSourceExpansion interface{}
-
-type PingSourceExpansion interface{}
-
-type SinkBindingExpansion interface{}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/sinkbinding.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/sinkbinding.go
deleted file mode 100644
index 6384caf0d..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/sinkbinding.go
+++ /dev/null
@@ -1,195 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"context"
-	"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"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-	scheme "knative.dev/eventing/pkg/client/clientset/versioned/scheme"
-)
-
-// SinkBindingsGetter has a method to return a SinkBindingInterface.
-// A group's client should implement this interface.
-type SinkBindingsGetter interface {
-	SinkBindings(namespace string) SinkBindingInterface
-}
-
-// SinkBindingInterface has methods to work with SinkBinding resources.
-type SinkBindingInterface interface {
-	Create(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.CreateOptions) (*v1beta1.SinkBinding, error)
-	Update(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.UpdateOptions) (*v1beta1.SinkBinding, error)
-	UpdateStatus(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.UpdateOptions) (*v1beta1.SinkBinding, error)
-	Delete(ctx context.Context, name string, opts v1.DeleteOptions) error
-	DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error
-	Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta1.SinkBinding, error)
-	List(ctx context.Context, opts v1.ListOptions) (*v1beta1.SinkBindingList, error)
-	Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)
-	Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.SinkBinding, err error)
-	SinkBindingExpansion
-}
-
-// sinkBindings implements SinkBindingInterface
-type sinkBindings struct {
-	client rest.Interface
-	ns     string
-}
-
-// newSinkBindings returns a SinkBindings
-func newSinkBindings(c *SourcesV1beta1Client, namespace string) *sinkBindings {
-	return &sinkBindings{
-		client: c.RESTClient(),
-		ns:     namespace,
-	}
-}
-
-// Get takes name of the sinkBinding, and returns the corresponding sinkBinding object, and an error if there is any.
-func (c *sinkBindings) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta1.SinkBinding, err error) {
-	result = &v1beta1.SinkBinding{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		Name(name).
-		VersionedParams(&options, scheme.ParameterCodec).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// List takes label and field selectors, and returns the list of SinkBindings that match those selectors.
-func (c *sinkBindings) List(ctx context.Context, opts v1.ListOptions) (result *v1beta1.SinkBindingList, err error) {
-	var timeout time.Duration
-	if opts.TimeoutSeconds != nil {
-		timeout = time.Duration(*opts.TimeoutSeconds) * time.Second
-	}
-	result = &v1beta1.SinkBindingList{}
-	err = c.client.Get().
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Watch returns a watch.Interface that watches the requested sinkBindings.
-func (c *sinkBindings) Watch(ctx context.Context, 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("sinkbindings").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Watch(ctx)
-}
-
-// Create takes the representation of a sinkBinding and creates it.  Returns the server's representation of the sinkBinding, and an error, if there is any.
-func (c *sinkBindings) Create(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.CreateOptions) (result *v1beta1.SinkBinding, err error) {
-	result = &v1beta1.SinkBinding{}
-	err = c.client.Post().
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(sinkBinding).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Update takes the representation of a sinkBinding and updates it. Returns the server's representation of the sinkBinding, and an error, if there is any.
-func (c *sinkBindings) Update(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.UpdateOptions) (result *v1beta1.SinkBinding, err error) {
-	result = &v1beta1.SinkBinding{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		Name(sinkBinding.Name).
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(sinkBinding).
-		Do(ctx).
-		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 *sinkBindings) UpdateStatus(ctx context.Context, sinkBinding *v1beta1.SinkBinding, opts v1.UpdateOptions) (result *v1beta1.SinkBinding, err error) {
-	result = &v1beta1.SinkBinding{}
-	err = c.client.Put().
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		Name(sinkBinding.Name).
-		SubResource("status").
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(sinkBinding).
-		Do(ctx).
-		Into(result)
-	return
-}
-
-// Delete takes name of the sinkBinding and deletes it. Returns an error if one occurs.
-func (c *sinkBindings) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		Name(name).
-		Body(&opts).
-		Do(ctx).
-		Error()
-}
-
-// DeleteCollection deletes a collection of objects.
-func (c *sinkBindings) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
-	var timeout time.Duration
-	if listOpts.TimeoutSeconds != nil {
-		timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second
-	}
-	return c.client.Delete().
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		VersionedParams(&listOpts, scheme.ParameterCodec).
-		Timeout(timeout).
-		Body(&opts).
-		Do(ctx).
-		Error()
-}
-
-// Patch applies the patch and returns the patched sinkBinding.
-func (c *sinkBindings) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.SinkBinding, err error) {
-	result = &v1beta1.SinkBinding{}
-	err = c.client.Patch(pt).
-		Namespace(c.ns).
-		Resource("sinkbindings").
-		Name(name).
-		SubResource(subresources...).
-		VersionedParams(&opts, scheme.ParameterCodec).
-		Body(data).
-		Do(ctx).
-		Into(result)
-	return
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/sources_client.go b/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/sources_client.go
deleted file mode 100644
index 1b2a8cc83..000000000
--- a/vendor/knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/sources_client.go
+++ /dev/null
@@ -1,104 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	rest "k8s.io/client-go/rest"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-	"knative.dev/eventing/pkg/client/clientset/versioned/scheme"
-)
-
-type SourcesV1beta1Interface interface {
-	RESTClient() rest.Interface
-	ApiServerSourcesGetter
-	ContainerSourcesGetter
-	PingSourcesGetter
-	SinkBindingsGetter
-}
-
-// SourcesV1beta1Client is used to interact with features provided by the sources.knative.dev group.
-type SourcesV1beta1Client struct {
-	restClient rest.Interface
-}
-
-func (c *SourcesV1beta1Client) ApiServerSources(namespace string) ApiServerSourceInterface {
-	return newApiServerSources(c, namespace)
-}
-
-func (c *SourcesV1beta1Client) ContainerSources(namespace string) ContainerSourceInterface {
-	return newContainerSources(c, namespace)
-}
-
-func (c *SourcesV1beta1Client) PingSources(namespace string) PingSourceInterface {
-	return newPingSources(c, namespace)
-}
-
-func (c *SourcesV1beta1Client) SinkBindings(namespace string) SinkBindingInterface {
-	return newSinkBindings(c, namespace)
-}
-
-// NewForConfig creates a new SourcesV1beta1Client for the given config.
-func NewForConfig(c *rest.Config) (*SourcesV1beta1Client, error) {
-	config := *c
-	if err := setConfigDefaults(&config); err != nil {
-		return nil, err
-	}
-	client, err := rest.RESTClientFor(&config)
-	if err != nil {
-		return nil, err
-	}
-	return &SourcesV1beta1Client{client}, nil
-}
-
-// NewForConfigOrDie creates a new SourcesV1beta1Client for the given config and
-// panics if there is an error in the config.
-func NewForConfigOrDie(c *rest.Config) *SourcesV1beta1Client {
-	client, err := NewForConfig(c)
-	if err != nil {
-		panic(err)
-	}
-	return client
-}
-
-// New creates a new SourcesV1beta1Client for the given RESTClient.
-func New(c rest.Interface) *SourcesV1beta1Client {
-	return &SourcesV1beta1Client{c}
-}
-
-func setConfigDefaults(config *rest.Config) error {
-	gv := v1beta1.SchemeGroupVersion
-	config.GroupVersion = &gv
-	config.APIPath = "/apis"
-	config.NegotiatedSerializer = scheme.Codecs.WithoutConversion()
-
-	if config.UserAgent == "" {
-		config.UserAgent = rest.DefaultKubernetesUserAgent()
-	}
-
-	return nil
-}
-
-// RESTClient returns a RESTClient that is used to communicate
-// with API server by this client implementation.
-func (c *SourcesV1beta1Client) RESTClient() rest.Interface {
-	if c == nil {
-		return nil
-	}
-	return c.restClient
-}
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 9ec9792a9..94b412121 100644
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/generic.go
+++ b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/generic.go
@@ -28,7 +28,6 @@ import (
 	flowsv1 "knative.dev/eventing/pkg/apis/flows/v1"
 	messagingv1 "knative.dev/eventing/pkg/apis/messaging/v1"
 	sourcesv1 "knative.dev/eventing/pkg/apis/sources/v1"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
 	v1beta2 "knative.dev/eventing/pkg/apis/sources/v1beta2"
 )
 
@@ -87,19 +86,11 @@ func (f *sharedInformerFactory) ForResource(resource schema.GroupVersionResource
 		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1().ApiServerSources().Informer()}, nil
 	case sourcesv1.SchemeGroupVersion.WithResource("containersources"):
 		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1().ContainerSources().Informer()}, nil
+	case sourcesv1.SchemeGroupVersion.WithResource("pingsources"):
+		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1().PingSources().Informer()}, nil
 	case sourcesv1.SchemeGroupVersion.WithResource("sinkbindings"):
 		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1().SinkBindings().Informer()}, nil
 
-		// Group=sources.knative.dev, Version=v1beta1
-	case sourcesv1beta1.SchemeGroupVersion.WithResource("apiserversources"):
-		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1beta1().ApiServerSources().Informer()}, nil
-	case sourcesv1beta1.SchemeGroupVersion.WithResource("containersources"):
-		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1beta1().ContainerSources().Informer()}, nil
-	case sourcesv1beta1.SchemeGroupVersion.WithResource("pingsources"):
-		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1beta1().PingSources().Informer()}, nil
-	case sourcesv1beta1.SchemeGroupVersion.WithResource("sinkbindings"):
-		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1beta1().SinkBindings().Informer()}, nil
-
 		// Group=sources.knative.dev, Version=v1beta2
 	case v1beta2.SchemeGroupVersion.WithResource("pingsources"):
 		return &genericInformer{resource: resource.GroupResource(), informer: f.Sources().V1beta2().PingSources().Informer()}, nil
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/interface.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/interface.go
index a0ba25cce..4e96b791b 100644
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/interface.go
+++ b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/interface.go
@@ -21,14 +21,11 @@ package sources
 import (
 	internalinterfaces "knative.dev/eventing/pkg/client/informers/externalversions/internalinterfaces"
 	v1 "knative.dev/eventing/pkg/client/informers/externalversions/sources/v1"
-	v1beta1 "knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1"
 	v1beta2 "knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta2"
 )
 
 // Interface provides access to each of this group's versions.
 type Interface interface {
-	// V1beta1 provides access to shared informers for resources in V1beta1.
-	V1beta1() v1beta1.Interface
 	// V1beta2 provides access to shared informers for resources in V1beta2.
 	V1beta2() v1beta2.Interface
 	// V1 provides access to shared informers for resources in V1.
@@ -46,11 +43,6 @@ func New(f internalinterfaces.SharedInformerFactory, namespace string, tweakList
 	return &group{factory: f, namespace: namespace, tweakListOptions: tweakListOptions}
 }
 
-// V1beta1 returns a new v1beta1.Interface.
-func (g *group) V1beta1() v1beta1.Interface {
-	return v1beta1.New(g.factory, g.namespace, g.tweakListOptions)
-}
-
 // V1beta2 returns a new v1beta2.Interface.
 func (g *group) V1beta2() v1beta2.Interface {
 	return v1beta2.New(g.factory, g.namespace, g.tweakListOptions)
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1/interface.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1/interface.go
index baf6916fb..490ec63d1 100644
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1/interface.go
+++ b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1/interface.go
@@ -28,6 +28,8 @@ type Interface interface {
 	ApiServerSources() ApiServerSourceInformer
 	// ContainerSources returns a ContainerSourceInformer.
 	ContainerSources() ContainerSourceInformer
+	// PingSources returns a PingSourceInformer.
+	PingSources() PingSourceInformer
 	// SinkBindings returns a SinkBindingInformer.
 	SinkBindings() SinkBindingInformer
 }
@@ -53,6 +55,11 @@ func (v *version) ContainerSources() ContainerSourceInformer {
 	return &containerSourceInformer{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/v1beta1/pingsource.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1/pingsource.go
similarity index 78%
rename from vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/pingsource.go
rename to vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1/pingsource.go
index d4b5ca048..f741f06d3 100644
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/pingsource.go
+++ b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1/pingsource.go
@@ -16,27 +16,27 @@ limitations under the License.
 
 // Code generated by informer-gen. DO NOT EDIT.
 
-package v1beta1
+package v1
 
 import (
 	"context"
 	time "time"
 
-	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	metav1 "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"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
+	sourcesv1 "knative.dev/eventing/pkg/apis/sources/v1"
 	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
 	internalinterfaces "knative.dev/eventing/pkg/client/informers/externalversions/internalinterfaces"
-	v1beta1 "knative.dev/eventing/pkg/client/listers/sources/v1beta1"
+	v1 "knative.dev/eventing/pkg/client/listers/sources/v1"
 )
 
 // PingSourceInformer provides access to a shared informer and lister for
 // PingSources.
 type PingSourceInformer interface {
 	Informer() cache.SharedIndexInformer
-	Lister() v1beta1.PingSourceLister
+	Lister() v1.PingSourceLister
 }
 
 type pingSourceInformer struct {
@@ -58,20 +58,20 @@ func NewPingSourceInformer(client versioned.Interface, namespace string, resyncP
 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) {
+			ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
 				if tweakListOptions != nil {
 					tweakListOptions(&options)
 				}
-				return client.SourcesV1beta1().PingSources(namespace).List(context.TODO(), options)
+				return client.SourcesV1().PingSources(namespace).List(context.TODO(), options)
 			},
-			WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
+			WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
 				if tweakListOptions != nil {
 					tweakListOptions(&options)
 				}
-				return client.SourcesV1beta1().PingSources(namespace).Watch(context.TODO(), options)
+				return client.SourcesV1().PingSources(namespace).Watch(context.TODO(), options)
 			},
 		},
-		&sourcesv1beta1.PingSource{},
+		&sourcesv1.PingSource{},
 		resyncPeriod,
 		indexers,
 	)
@@ -82,9 +82,9 @@ func (f *pingSourceInformer) defaultInformer(client versioned.Interface, resyncP
 }
 
 func (f *pingSourceInformer) Informer() cache.SharedIndexInformer {
-	return f.factory.InformerFor(&sourcesv1beta1.PingSource{}, f.defaultInformer)
+	return f.factory.InformerFor(&sourcesv1.PingSource{}, f.defaultInformer)
 }
 
-func (f *pingSourceInformer) Lister() v1beta1.PingSourceLister {
-	return v1beta1.NewPingSourceLister(f.Informer().GetIndexer())
+func (f *pingSourceInformer) Lister() v1.PingSourceLister {
+	return v1.NewPingSourceLister(f.Informer().GetIndexer())
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/apiserversource.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/apiserversource.go
deleted file mode 100644
index 341dda398..000000000
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/apiserversource.go
+++ /dev/null
@@ -1,90 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"context"
-	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"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
-	internalinterfaces "knative.dev/eventing/pkg/client/informers/externalversions/internalinterfaces"
-	v1beta1 "knative.dev/eventing/pkg/client/listers/sources/v1beta1"
-)
-
-// ApiServerSourceInformer provides access to a shared informer and lister for
-// ApiServerSources.
-type ApiServerSourceInformer interface {
-	Informer() cache.SharedIndexInformer
-	Lister() v1beta1.ApiServerSourceLister
-}
-
-type apiServerSourceInformer struct {
-	factory          internalinterfaces.SharedInformerFactory
-	tweakListOptions internalinterfaces.TweakListOptionsFunc
-	namespace        string
-}
-
-// NewApiServerSourceInformer constructs a new informer for ApiServerSource 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 NewApiServerSourceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
-	return NewFilteredApiServerSourceInformer(client, namespace, resyncPeriod, indexers, nil)
-}
-
-// NewFilteredApiServerSourceInformer constructs a new informer for ApiServerSource 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 NewFilteredApiServerSourceInformer(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.SourcesV1beta1().ApiServerSources(namespace).List(context.TODO(), options)
-			},
-			WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
-				if tweakListOptions != nil {
-					tweakListOptions(&options)
-				}
-				return client.SourcesV1beta1().ApiServerSources(namespace).Watch(context.TODO(), options)
-			},
-		},
-		&sourcesv1beta1.ApiServerSource{},
-		resyncPeriod,
-		indexers,
-	)
-}
-
-func (f *apiServerSourceInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
-	return NewFilteredApiServerSourceInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
-}
-
-func (f *apiServerSourceInformer) Informer() cache.SharedIndexInformer {
-	return f.factory.InformerFor(&sourcesv1beta1.ApiServerSource{}, f.defaultInformer)
-}
-
-func (f *apiServerSourceInformer) Lister() v1beta1.ApiServerSourceLister {
-	return v1beta1.NewApiServerSourceLister(f.Informer().GetIndexer())
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/containersource.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/containersource.go
deleted file mode 100644
index 6484ac735..000000000
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/containersource.go
+++ /dev/null
@@ -1,90 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"context"
-	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"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
-	internalinterfaces "knative.dev/eventing/pkg/client/informers/externalversions/internalinterfaces"
-	v1beta1 "knative.dev/eventing/pkg/client/listers/sources/v1beta1"
-)
-
-// ContainerSourceInformer provides access to a shared informer and lister for
-// ContainerSources.
-type ContainerSourceInformer interface {
-	Informer() cache.SharedIndexInformer
-	Lister() v1beta1.ContainerSourceLister
-}
-
-type containerSourceInformer struct {
-	factory          internalinterfaces.SharedInformerFactory
-	tweakListOptions internalinterfaces.TweakListOptionsFunc
-	namespace        string
-}
-
-// NewContainerSourceInformer constructs a new informer for ContainerSource 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 NewContainerSourceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
-	return NewFilteredContainerSourceInformer(client, namespace, resyncPeriod, indexers, nil)
-}
-
-// NewFilteredContainerSourceInformer constructs a new informer for ContainerSource 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 NewFilteredContainerSourceInformer(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.SourcesV1beta1().ContainerSources(namespace).List(context.TODO(), options)
-			},
-			WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
-				if tweakListOptions != nil {
-					tweakListOptions(&options)
-				}
-				return client.SourcesV1beta1().ContainerSources(namespace).Watch(context.TODO(), options)
-			},
-		},
-		&sourcesv1beta1.ContainerSource{},
-		resyncPeriod,
-		indexers,
-	)
-}
-
-func (f *containerSourceInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
-	return NewFilteredContainerSourceInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
-}
-
-func (f *containerSourceInformer) Informer() cache.SharedIndexInformer {
-	return f.factory.InformerFor(&sourcesv1beta1.ContainerSource{}, f.defaultInformer)
-}
-
-func (f *containerSourceInformer) Lister() v1beta1.ContainerSourceLister {
-	return v1beta1.NewContainerSourceLister(f.Informer().GetIndexer())
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/interface.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/interface.go
deleted file mode 100644
index 6eff4bf4a..000000000
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/interface.go
+++ /dev/null
@@ -1,66 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	internalinterfaces "knative.dev/eventing/pkg/client/informers/externalversions/internalinterfaces"
-)
-
-// Interface provides access to all the informers in this group version.
-type Interface interface {
-	// ApiServerSources returns a ApiServerSourceInformer.
-	ApiServerSources() ApiServerSourceInformer
-	// ContainerSources returns a ContainerSourceInformer.
-	ContainerSources() ContainerSourceInformer
-	// PingSources returns a PingSourceInformer.
-	PingSources() PingSourceInformer
-	// SinkBindings returns a SinkBindingInformer.
-	SinkBindings() SinkBindingInformer
-}
-
-type version struct {
-	factory          internalinterfaces.SharedInformerFactory
-	namespace        string
-	tweakListOptions internalinterfaces.TweakListOptionsFunc
-}
-
-// New returns a new Interface.
-func New(f internalinterfaces.SharedInformerFactory, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) Interface {
-	return &version{factory: f, namespace: namespace, tweakListOptions: tweakListOptions}
-}
-
-// ApiServerSources returns a ApiServerSourceInformer.
-func (v *version) ApiServerSources() ApiServerSourceInformer {
-	return &apiServerSourceInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions}
-}
-
-// ContainerSources returns a ContainerSourceInformer.
-func (v *version) ContainerSources() ContainerSourceInformer {
-	return &containerSourceInformer{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/v1beta1/sinkbinding.go b/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/sinkbinding.go
deleted file mode 100644
index 0a05e66b0..000000000
--- a/vendor/knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1/sinkbinding.go
+++ /dev/null
@@ -1,90 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"context"
-	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"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
-	internalinterfaces "knative.dev/eventing/pkg/client/informers/externalversions/internalinterfaces"
-	v1beta1 "knative.dev/eventing/pkg/client/listers/sources/v1beta1"
-)
-
-// SinkBindingInformer provides access to a shared informer and lister for
-// SinkBindings.
-type SinkBindingInformer interface {
-	Informer() cache.SharedIndexInformer
-	Lister() v1beta1.SinkBindingLister
-}
-
-type sinkBindingInformer struct {
-	factory          internalinterfaces.SharedInformerFactory
-	tweakListOptions internalinterfaces.TweakListOptionsFunc
-	namespace        string
-}
-
-// NewSinkBindingInformer constructs a new informer for SinkBinding 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 NewSinkBindingInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
-	return NewFilteredSinkBindingInformer(client, namespace, resyncPeriod, indexers, nil)
-}
-
-// NewFilteredSinkBindingInformer constructs a new informer for SinkBinding 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 NewFilteredSinkBindingInformer(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.SourcesV1beta1().SinkBindings(namespace).List(context.TODO(), options)
-			},
-			WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
-				if tweakListOptions != nil {
-					tweakListOptions(&options)
-				}
-				return client.SourcesV1beta1().SinkBindings(namespace).Watch(context.TODO(), options)
-			},
-		},
-		&sourcesv1beta1.SinkBinding{},
-		resyncPeriod,
-		indexers,
-	)
-}
-
-func (f *sinkBindingInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer {
-	return NewFilteredSinkBindingInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions)
-}
-
-func (f *sinkBindingInformer) Informer() cache.SharedIndexInformer {
-	return f.factory.InformerFor(&sourcesv1beta1.SinkBinding{}, f.defaultInformer)
-}
-
-func (f *sinkBindingInformer) Lister() v1beta1.SinkBindingLister {
-	return v1beta1.NewSinkBindingLister(f.Informer().GetIndexer())
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1/expansion_generated.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1/expansion_generated.go
index 4f3d7a813..cfa0aaae7 100644
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1/expansion_generated.go
+++ b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1/expansion_generated.go
@@ -34,6 +34,14 @@ type ContainerSourceListerExpansion interface{}
 // ContainerSourceNamespaceLister.
 type ContainerSourceNamespaceListerExpansion 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/v1beta1/pingsource.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1/pingsource.go
similarity index 82%
rename from vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/pingsource.go
rename to vendor/knative.dev/eventing/pkg/client/listers/sources/v1/pingsource.go
index df16ff6ee..15be67add 100644
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/pingsource.go
+++ b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1/pingsource.go
@@ -16,13 +16,13 @@ limitations under the License.
 
 // Code generated by lister-gen. DO NOT EDIT.
 
-package v1beta1
+package v1
 
 import (
 	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/labels"
 	"k8s.io/client-go/tools/cache"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
+	v1 "knative.dev/eventing/pkg/apis/sources/v1"
 )
 
 // PingSourceLister helps list PingSources.
@@ -30,7 +30,7 @@ import (
 type PingSourceLister interface {
 	// List lists all PingSources in the indexer.
 	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.PingSource, err error)
+	List(selector labels.Selector) (ret []*v1.PingSource, err error)
 	// PingSources returns an object that can list and get PingSources.
 	PingSources(namespace string) PingSourceNamespaceLister
 	PingSourceListerExpansion
@@ -47,9 +47,9 @@ func NewPingSourceLister(indexer cache.Indexer) PingSourceLister {
 }
 
 // List lists all PingSources in the indexer.
-func (s *pingSourceLister) List(selector labels.Selector) (ret []*v1beta1.PingSource, err error) {
+func (s *pingSourceLister) List(selector labels.Selector) (ret []*v1.PingSource, err error) {
 	err = cache.ListAll(s.indexer, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.PingSource))
+		ret = append(ret, m.(*v1.PingSource))
 	})
 	return ret, err
 }
@@ -64,10 +64,10 @@ func (s *pingSourceLister) PingSources(namespace string) PingSourceNamespaceList
 type PingSourceNamespaceLister interface {
 	// List lists all PingSources in the indexer for a given namespace.
 	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.PingSource, err error)
+	List(selector labels.Selector) (ret []*v1.PingSource, err error)
 	// Get retrieves the PingSource from the indexer for a given namespace and name.
 	// Objects returned here must be treated as read-only.
-	Get(name string) (*v1beta1.PingSource, error)
+	Get(name string) (*v1.PingSource, error)
 	PingSourceNamespaceListerExpansion
 }
 
@@ -79,21 +79,21 @@ type pingSourceNamespaceLister struct {
 }
 
 // List lists all PingSources in the indexer for a given namespace.
-func (s pingSourceNamespaceLister) List(selector labels.Selector) (ret []*v1beta1.PingSource, err error) {
+func (s pingSourceNamespaceLister) List(selector labels.Selector) (ret []*v1.PingSource, err error) {
 	err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.PingSource))
+		ret = append(ret, m.(*v1.PingSource))
 	})
 	return ret, err
 }
 
 // Get retrieves the PingSource from the indexer for a given namespace and name.
-func (s pingSourceNamespaceLister) Get(name string) (*v1beta1.PingSource, error) {
+func (s pingSourceNamespaceLister) Get(name string) (*v1.PingSource, error) {
 	obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
 	if err != nil {
 		return nil, err
 	}
 	if !exists {
-		return nil, errors.NewNotFound(v1beta1.Resource("pingsource"), name)
+		return nil, errors.NewNotFound(v1.Resource("pingsource"), name)
 	}
-	return obj.(*v1beta1.PingSource), nil
+	return obj.(*v1.PingSource), nil
 }
diff --git a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/apiserversource.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/apiserversource.go
deleted file mode 100644
index 9f41e3fae..000000000
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/apiserversource.go
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"k8s.io/apimachinery/pkg/api/errors"
-	"k8s.io/apimachinery/pkg/labels"
-	"k8s.io/client-go/tools/cache"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-)
-
-// ApiServerSourceLister helps list ApiServerSources.
-// All objects returned here must be treated as read-only.
-type ApiServerSourceLister interface {
-	// List lists all ApiServerSources in the indexer.
-	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.ApiServerSource, err error)
-	// ApiServerSources returns an object that can list and get ApiServerSources.
-	ApiServerSources(namespace string) ApiServerSourceNamespaceLister
-	ApiServerSourceListerExpansion
-}
-
-// apiServerSourceLister implements the ApiServerSourceLister interface.
-type apiServerSourceLister struct {
-	indexer cache.Indexer
-}
-
-// NewApiServerSourceLister returns a new ApiServerSourceLister.
-func NewApiServerSourceLister(indexer cache.Indexer) ApiServerSourceLister {
-	return &apiServerSourceLister{indexer: indexer}
-}
-
-// List lists all ApiServerSources in the indexer.
-func (s *apiServerSourceLister) List(selector labels.Selector) (ret []*v1beta1.ApiServerSource, err error) {
-	err = cache.ListAll(s.indexer, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.ApiServerSource))
-	})
-	return ret, err
-}
-
-// ApiServerSources returns an object that can list and get ApiServerSources.
-func (s *apiServerSourceLister) ApiServerSources(namespace string) ApiServerSourceNamespaceLister {
-	return apiServerSourceNamespaceLister{indexer: s.indexer, namespace: namespace}
-}
-
-// ApiServerSourceNamespaceLister helps list and get ApiServerSources.
-// All objects returned here must be treated as read-only.
-type ApiServerSourceNamespaceLister interface {
-	// List lists all ApiServerSources in the indexer for a given namespace.
-	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.ApiServerSource, err error)
-	// Get retrieves the ApiServerSource from the indexer for a given namespace and name.
-	// Objects returned here must be treated as read-only.
-	Get(name string) (*v1beta1.ApiServerSource, error)
-	ApiServerSourceNamespaceListerExpansion
-}
-
-// apiServerSourceNamespaceLister implements the ApiServerSourceNamespaceLister
-// interface.
-type apiServerSourceNamespaceLister struct {
-	indexer   cache.Indexer
-	namespace string
-}
-
-// List lists all ApiServerSources in the indexer for a given namespace.
-func (s apiServerSourceNamespaceLister) List(selector labels.Selector) (ret []*v1beta1.ApiServerSource, err error) {
-	err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.ApiServerSource))
-	})
-	return ret, err
-}
-
-// Get retrieves the ApiServerSource from the indexer for a given namespace and name.
-func (s apiServerSourceNamespaceLister) Get(name string) (*v1beta1.ApiServerSource, error) {
-	obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
-	if err != nil {
-		return nil, err
-	}
-	if !exists {
-		return nil, errors.NewNotFound(v1beta1.Resource("apiserversource"), name)
-	}
-	return obj.(*v1beta1.ApiServerSource), nil
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/containersource.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/containersource.go
deleted file mode 100644
index f1fb31484..000000000
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/containersource.go
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"k8s.io/apimachinery/pkg/api/errors"
-	"k8s.io/apimachinery/pkg/labels"
-	"k8s.io/client-go/tools/cache"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-)
-
-// ContainerSourceLister helps list ContainerSources.
-// All objects returned here must be treated as read-only.
-type ContainerSourceLister interface {
-	// List lists all ContainerSources in the indexer.
-	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.ContainerSource, err error)
-	// ContainerSources returns an object that can list and get ContainerSources.
-	ContainerSources(namespace string) ContainerSourceNamespaceLister
-	ContainerSourceListerExpansion
-}
-
-// containerSourceLister implements the ContainerSourceLister interface.
-type containerSourceLister struct {
-	indexer cache.Indexer
-}
-
-// NewContainerSourceLister returns a new ContainerSourceLister.
-func NewContainerSourceLister(indexer cache.Indexer) ContainerSourceLister {
-	return &containerSourceLister{indexer: indexer}
-}
-
-// List lists all ContainerSources in the indexer.
-func (s *containerSourceLister) List(selector labels.Selector) (ret []*v1beta1.ContainerSource, err error) {
-	err = cache.ListAll(s.indexer, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.ContainerSource))
-	})
-	return ret, err
-}
-
-// ContainerSources returns an object that can list and get ContainerSources.
-func (s *containerSourceLister) ContainerSources(namespace string) ContainerSourceNamespaceLister {
-	return containerSourceNamespaceLister{indexer: s.indexer, namespace: namespace}
-}
-
-// ContainerSourceNamespaceLister helps list and get ContainerSources.
-// All objects returned here must be treated as read-only.
-type ContainerSourceNamespaceLister interface {
-	// List lists all ContainerSources in the indexer for a given namespace.
-	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.ContainerSource, err error)
-	// Get retrieves the ContainerSource from the indexer for a given namespace and name.
-	// Objects returned here must be treated as read-only.
-	Get(name string) (*v1beta1.ContainerSource, error)
-	ContainerSourceNamespaceListerExpansion
-}
-
-// containerSourceNamespaceLister implements the ContainerSourceNamespaceLister
-// interface.
-type containerSourceNamespaceLister struct {
-	indexer   cache.Indexer
-	namespace string
-}
-
-// List lists all ContainerSources in the indexer for a given namespace.
-func (s containerSourceNamespaceLister) List(selector labels.Selector) (ret []*v1beta1.ContainerSource, err error) {
-	err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.ContainerSource))
-	})
-	return ret, err
-}
-
-// Get retrieves the ContainerSource from the indexer for a given namespace and name.
-func (s containerSourceNamespaceLister) Get(name string) (*v1beta1.ContainerSource, error) {
-	obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
-	if err != nil {
-		return nil, err
-	}
-	if !exists {
-		return nil, errors.NewNotFound(v1beta1.Resource("containersource"), name)
-	}
-	return obj.(*v1beta1.ContainerSource), nil
-}
diff --git a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/expansion_generated.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/expansion_generated.go
deleted file mode 100644
index b4fd2dee1..000000000
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/expansion_generated.go
+++ /dev/null
@@ -1,51 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-// ApiServerSourceListerExpansion allows custom methods to be added to
-// ApiServerSourceLister.
-type ApiServerSourceListerExpansion interface{}
-
-// ApiServerSourceNamespaceListerExpansion allows custom methods to be added to
-// ApiServerSourceNamespaceLister.
-type ApiServerSourceNamespaceListerExpansion interface{}
-
-// ContainerSourceListerExpansion allows custom methods to be added to
-// ContainerSourceLister.
-type ContainerSourceListerExpansion interface{}
-
-// ContainerSourceNamespaceListerExpansion allows custom methods to be added to
-// ContainerSourceNamespaceLister.
-type ContainerSourceNamespaceListerExpansion 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{}
-
-// SinkBindingNamespaceListerExpansion allows custom methods to be added to
-// SinkBindingNamespaceLister.
-type SinkBindingNamespaceListerExpansion interface{}
diff --git a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/sinkbinding.go b/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/sinkbinding.go
deleted file mode 100644
index 1aaa0ead8..000000000
--- a/vendor/knative.dev/eventing/pkg/client/listers/sources/v1beta1/sinkbinding.go
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
-Copyright 2021 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 v1beta1
-
-import (
-	"k8s.io/apimachinery/pkg/api/errors"
-	"k8s.io/apimachinery/pkg/labels"
-	"k8s.io/client-go/tools/cache"
-	v1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
-)
-
-// SinkBindingLister helps list SinkBindings.
-// All objects returned here must be treated as read-only.
-type SinkBindingLister interface {
-	// List lists all SinkBindings in the indexer.
-	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.SinkBinding, err error)
-	// SinkBindings returns an object that can list and get SinkBindings.
-	SinkBindings(namespace string) SinkBindingNamespaceLister
-	SinkBindingListerExpansion
-}
-
-// sinkBindingLister implements the SinkBindingLister interface.
-type sinkBindingLister struct {
-	indexer cache.Indexer
-}
-
-// NewSinkBindingLister returns a new SinkBindingLister.
-func NewSinkBindingLister(indexer cache.Indexer) SinkBindingLister {
-	return &sinkBindingLister{indexer: indexer}
-}
-
-// List lists all SinkBindings in the indexer.
-func (s *sinkBindingLister) List(selector labels.Selector) (ret []*v1beta1.SinkBinding, err error) {
-	err = cache.ListAll(s.indexer, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.SinkBinding))
-	})
-	return ret, err
-}
-
-// SinkBindings returns an object that can list and get SinkBindings.
-func (s *sinkBindingLister) SinkBindings(namespace string) SinkBindingNamespaceLister {
-	return sinkBindingNamespaceLister{indexer: s.indexer, namespace: namespace}
-}
-
-// SinkBindingNamespaceLister helps list and get SinkBindings.
-// All objects returned here must be treated as read-only.
-type SinkBindingNamespaceLister interface {
-	// List lists all SinkBindings in the indexer for a given namespace.
-	// Objects returned here must be treated as read-only.
-	List(selector labels.Selector) (ret []*v1beta1.SinkBinding, err error)
-	// Get retrieves the SinkBinding from the indexer for a given namespace and name.
-	// Objects returned here must be treated as read-only.
-	Get(name string) (*v1beta1.SinkBinding, error)
-	SinkBindingNamespaceListerExpansion
-}
-
-// sinkBindingNamespaceLister implements the SinkBindingNamespaceLister
-// interface.
-type sinkBindingNamespaceLister struct {
-	indexer   cache.Indexer
-	namespace string
-}
-
-// List lists all SinkBindings in the indexer for a given namespace.
-func (s sinkBindingNamespaceLister) List(selector labels.Selector) (ret []*v1beta1.SinkBinding, err error) {
-	err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
-		ret = append(ret, m.(*v1beta1.SinkBinding))
-	})
-	return ret, err
-}
-
-// Get retrieves the SinkBinding from the indexer for a given namespace and name.
-func (s sinkBindingNamespaceLister) Get(name string) (*v1beta1.SinkBinding, error) {
-	obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
-	if err != nil {
-		return nil, err
-	}
-	if !exists {
-		return nil, errors.NewNotFound(v1beta1.Resource("sinkbinding"), name)
-	}
-	return obj.(*v1beta1.SinkBinding), nil
-}
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 6123ad408..734c10fbf 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -1091,7 +1091,7 @@ k8s.io/utils/buffer
 k8s.io/utils/integer
 k8s.io/utils/pointer
 k8s.io/utils/trace
-# knative.dev/control-protocol v0.0.0-20210428072553-79468156aad1
+# knative.dev/control-protocol v0.0.0-20210504094437-d6392770de44
 ## explicit
 knative.dev/control-protocol/pkg
 knative.dev/control-protocol/pkg/certificates
@@ -1099,7 +1099,7 @@ knative.dev/control-protocol/pkg/message
 knative.dev/control-protocol/pkg/network
 knative.dev/control-protocol/pkg/reconciler
 knative.dev/control-protocol/pkg/service
-# knative.dev/eventing v0.22.1-0.20210428222054-c2d6649ea36d
+# knative.dev/eventing v0.22.1-0.20210504001137-8a094e6031f2
 ## explicit
 knative.dev/eventing/pkg/adapter/v2
 knative.dev/eventing/pkg/adapter/v2/test
@@ -1119,7 +1119,6 @@ knative.dev/eventing/pkg/apis/messaging/v1
 knative.dev/eventing/pkg/apis/sources
 knative.dev/eventing/pkg/apis/sources/config
 knative.dev/eventing/pkg/apis/sources/v1
-knative.dev/eventing/pkg/apis/sources/v1beta1
 knative.dev/eventing/pkg/apis/sources/v1beta2
 knative.dev/eventing/pkg/channel
 knative.dev/eventing/pkg/channel/attributes
@@ -1137,8 +1136,6 @@ knative.dev/eventing/pkg/client/clientset/versioned/typed/messaging/v1
 knative.dev/eventing/pkg/client/clientset/versioned/typed/messaging/v1/fake
 knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1
 knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1/fake
-knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1
-knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta1/fake
 knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta2
 knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta2/fake
 knative.dev/eventing/pkg/client/informers/externalversions
@@ -1152,7 +1149,6 @@ knative.dev/eventing/pkg/client/informers/externalversions/messaging
 knative.dev/eventing/pkg/client/informers/externalversions/messaging/v1
 knative.dev/eventing/pkg/client/informers/externalversions/sources
 knative.dev/eventing/pkg/client/informers/externalversions/sources/v1
-knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta1
 knative.dev/eventing/pkg/client/informers/externalversions/sources/v1beta2
 knative.dev/eventing/pkg/client/injection/client
 knative.dev/eventing/pkg/client/injection/client/fake
@@ -1164,7 +1160,6 @@ knative.dev/eventing/pkg/client/listers/eventing/v1beta1
 knative.dev/eventing/pkg/client/listers/flows/v1
 knative.dev/eventing/pkg/client/listers/messaging/v1
 knative.dev/eventing/pkg/client/listers/sources/v1
-knative.dev/eventing/pkg/client/listers/sources/v1beta1
 knative.dev/eventing/pkg/client/listers/sources/v1beta2
 knative.dev/eventing/pkg/duck
 knative.dev/eventing/pkg/kncloudevents


Test patch:
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go
index 333c0873f..d3a01164c 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/listers.go
@@ -31,10 +31,8 @@ import (
 	corev1listers "k8s.io/client-go/listers/core/v1"
 	rbacv1listers "k8s.io/client-go/listers/rbac/v1"
 	"k8s.io/client-go/tools/cache"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
 	sourcesv1beta2 "knative.dev/eventing/pkg/apis/sources/v1beta2"
 	fakeeventingclientset "knative.dev/eventing/pkg/client/clientset/versioned/fake"
-	sourcev1beta1listers "knative.dev/eventing/pkg/client/listers/sources/v1beta1"
 	sourcev1beta2listers "knative.dev/eventing/pkg/client/listers/sources/v1beta2"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 	"knative.dev/pkg/reconciler/testing"
@@ -114,18 +112,10 @@ func (l *Listers) GetAllObjects() []runtime.Object {
 	return all
 }
 
-func (l *Listers) GetPingSourceV1beta1Lister() sourcev1beta1listers.PingSourceLister {
-	return sourcev1beta1listers.NewPingSourceLister(l.indexerFor(&sourcesv1beta1.PingSource{}))
-}
-
 func (l *Listers) GetPingSourceV1beta2Lister() sourcev1beta2listers.PingSourceLister {
 	return sourcev1beta2listers.NewPingSourceLister(l.indexerFor(&sourcesv1beta2.PingSource{}))
 }
 
-func (l *Listers) GetSinkBindingV1beta1Lister() sourcev1beta1listers.SinkBindingLister {
-	return sourcev1beta1listers.NewSinkBindingLister(l.indexerFor(&sourcesv1beta1.SinkBinding{}))
-}
-
 func (l *Listers) GetDeploymentLister() appsv1listers.DeploymentLister {
 	return appsv1listers.NewDeploymentLister(l.indexerFor(&appsv1.Deployment{}))
 }
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/pingsource.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/pingsource.go
new file mode 100644
index 000000000..711152329
--- /dev/null
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/pingsource.go
@@ -0,0 +1,109 @@
+/*
+Copyright 2021 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 testing
+
+import (
+	"context"
+	"time"
+
+	"knative.dev/eventing/pkg/reconciler/testing"
+
+	"knative.dev/pkg/apis"
+	duckv1 "knative.dev/pkg/apis/duck/v1"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/types"
+	v1 "knative.dev/eventing/pkg/apis/sources/v1"
+)
+
+// PingSourceOption enables further configuration of a CronJob.
+type PingSourceOption func(*v1.PingSource)
+
+// NewPingSource creates a PingSource with PingSourceOption.
+func NewPingSource(name, namespace string, o ...PingSourceOption) *v1.PingSource {
+	c := &v1.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
+}
+
+func WithPingSource(uid string) PingSourceOption {
+	return func(c *v1.PingSource) {
+		c.UID = types.UID(uid)
+	}
+}
+
+func WithInitPingSourceConditions(s *v1.PingSource) {
+	s.Status.InitializeConditions()
+}
+
+func WithPingSourceSinkNotFound(s *v1.PingSource) {
+	s.Status.MarkNoSink("NotFound", "")
+}
+
+func WithPingSourceSink(uri *apis.URL) PingSourceOption {
+	return func(s *v1.PingSource) {
+		s.Status.MarkSink(uri)
+	}
+}
+
+func WithPingSourceDeployed(s *v1.PingSource) {
+	s.Status.PropagateDeploymentAvailability(testing.NewDeployment("any", "any", testing.WithDeploymentAvailable()))
+}
+
+func WithPingSourceCloudEventAttributes(s *v1.PingSource) {
+	s.Status.CloudEventAttributes = []duckv1.CloudEventAttributes{{
+		Type:   v1.PingSourceEventType,
+		Source: v1.PingSourceSource(s.Namespace, s.Name),
+	}}
+}
+
+func WithPingSourceSpec(spec v1.PingSourceSpec) PingSourceOption {
+	return func(c *v1.PingSource) {
+		c.Spec = spec
+	}
+}
+
+func WithPingSourceStatusObservedGeneration(generation int64) PingSourceOption {
+	return func(c *v1.PingSource) {
+		c.Status.ObservedGeneration = generation
+	}
+}
+
+func WithPingSourceObjectMetaGeneration(generation int64) PingSourceOption {
+	return func(c *v1.PingSource) {
+		c.ObjectMeta.Generation = generation
+	}
+}
+
+func WithPingSourceFinalizers(finalizers ...string) PingSourceOption {
+	return func(c *v1.PingSource) {
+		c.Finalizers = finalizers
+	}
+}
+
+func WithPingSourceDeleted(c *v1.PingSource) {
+	t := metav1.NewTime(time.Unix(1e9, 0))
+	c.SetDeletionTimestamp(&t)
+}
diff --git a/vendor/knative.dev/eventing/test/README.md b/vendor/knative.dev/eventing/test/README.md
index f75addbea..ef7283741 100644
--- a/vendor/knative.dev/eventing/test/README.md
+++ b/vendor/knative.dev/eventing/test/README.md
@@ -61,8 +61,8 @@ If you have set up a running environment that meets
 with
 `test/e2e-tests.sh --run-tests --skip-knative-setup --gcp-project-id=$PROJECT_ID`.
 
-If you want to turn off the [`chaosduck`](config/chaosduck/chaosduck.yaml) during the test,
-you can set `$SCALE_CHAOSDUCK_TO_ZERO` to 1.
+If you want to turn off the [`chaosduck`](config/chaosduck/chaosduck.yaml)
+during the test, you can set `$SCALE_CHAOSDUCK_TO_ZERO` to 1.
 
 ## Running tests with `go test` command
 
diff --git a/vendor/knative.dev/eventing/test/e2e-common.sh b/vendor/knative.dev/eventing/test/e2e-common.sh
index cfbb7816d..3a6e8ddf6 100644
--- a/vendor/knative.dev/eventing/test/e2e-common.sh
+++ b/vendor/knative.dev/eventing/test/e2e-common.sh
@@ -173,8 +173,6 @@ function install_knative_eventing() {
 
   scale_controlplane eventing-webhook eventing-controller
 
-  if (( SCALE_CHAOSDUCK_TO_ZERO )); then kubectl -n "${SYSTEM_NAMESPACE}" scale deployment/chaosduck --replicas=0; fi
-
   wait_until_pods_running ${SYSTEM_NAMESPACE} || fail_test "Knative Eventing did not come up"
 
   echo "check the config map"
@@ -254,6 +252,7 @@ function unleash_duck() {
   cat test/config/chaosduck.yaml | \
     sed "s/namespace: ${KNATIVE_DEFAULT_NAMESPACE}/namespace: ${SYSTEM_NAMESPACE}/g" | \
     ko apply ${KO_FLAGS} -f - || return $?
+    if (( SCALE_CHAOSDUCK_TO_ZERO )); then kubectl -n "${SYSTEM_NAMESPACE}" scale deployment/chaosduck --replicas=0; fi
 }
 
 # Teardown the Knative environment after tests finish.
diff --git a/vendor/knative.dev/eventing/test/e2e-conformance-tests.sh b/vendor/knative.dev/eventing/test/e2e-conformance-tests.sh
index dc7270d29..3f264f1bd 100644
--- a/vendor/knative.dev/eventing/test/e2e-conformance-tests.sh
+++ b/vendor/knative.dev/eventing/test/e2e-conformance-tests.sh
@@ -32,11 +32,11 @@ source "$(dirname "$0")/e2e-common.sh"
 
 initialize $@ --skip-istio-addon
 
-echo "Running Conformance tests for: Multi Tenant Channel Based Broker (v1), Channel (v1), InMemoryChannel (v1) , ApiServerSource (v1beta1, v1), ContainerSource (v1beta1, v1) and PingSource (v1beta1, v1beta2)"
+echo "Running Conformance tests for: Multi Tenant Channel Based Broker (v1), Channel (v1), InMemoryChannel (v1) , ApiServerSource (v1), ContainerSource (v1) and PingSource (v1beta2)"
 go_test_e2e -timeout=30m -parallel=12 ./test/conformance \
   -brokers=eventing.knative.dev/v1:MTChannelBasedBroker \
   -channels=messaging.knative.dev/v1:Channel,messaging.knative.dev/v1:InMemoryChannel \
-  -sources=sources.knative.dev/v1beta1:ApiServerSource,sources.knative.dev/v1beta1:PingSource,sources.knative.dev/v1beta2:PingSource,sources.knative.dev/v1:ApiServerSource,sources.knative.dev/v1:ContainerSource \
+  -sources=sources.knative.dev/v1beta2:PingSource,sources.knative.dev/v1:ApiServerSource,sources.knative.dev/v1:ContainerSource \
   || fail_test
 
 success
diff --git a/vendor/knative.dev/eventing/test/e2e-tests.sh b/vendor/knative.dev/eventing/test/e2e-tests.sh
index 9ec5468e3..f1fabed92 100644
--- a/vendor/knative.dev/eventing/test/e2e-tests.sh
+++ b/vendor/knative.dev/eventing/test/e2e-tests.sh
@@ -32,11 +32,11 @@ source "$(dirname "$0")/e2e-common.sh"
 
 initialize $@ --skip-istio-addon
 
-echo "Running E2E tests for: Multi Tenant Channel Based Broker, Channel (v1), InMemoryChannel (v1) , ApiServerSource (v1beta1, v1), ContainerSource (v1alpha2, v1) and PingSource (v1beta1, v1beta2)"
+echo "Running E2E tests for: Multi Tenant Channel Based Broker, Channel (v1), InMemoryChannel (v1) , ApiServerSource (v1), ContainerSource (v1) and PingSource (v1beta2)"
 go_test_e2e -timeout=30m -parallel=20 ./test/e2e \
   -brokerclass=MTChannelBasedBroker \
   -channels=messaging.knative.dev/v1:Channel,messaging.knative.dev/v1:InMemoryChannel \
-  -sources=sources.knative.dev/v1beta1:ApiServerSource,sources.knative.dev/v1beta1:PingSource,sources.knative.dev/v1beta2:PingSource,sources.knative.dev/v1:ApiServerSource,sources.knative.dev/v1:ContainerSource \
+  -sources=sources.knative.dev/v1beta2:PingSource,sources.knative.dev/v1:ApiServerSource,sources.knative.dev/v1:ContainerSource \
   || fail_test
 
 success
diff --git a/vendor/knative.dev/eventing/test/lib/creation.go b/vendor/knative.dev/eventing/test/lib/creation.go
index b5600890c..18f96722f 100644
--- a/vendor/knative.dev/eventing/test/lib/creation.go
+++ b/vendor/knative.dev/eventing/test/lib/creation.go
@@ -38,7 +38,6 @@ import (
 	flowsv1 "knative.dev/eventing/pkg/apis/flows/v1"
 	messagingv1 "knative.dev/eventing/pkg/apis/messaging/v1"
 	sourcesv1 "knative.dev/eventing/pkg/apis/sources/v1"
-	sourcesv1beta1 "knative.dev/eventing/pkg/apis/sources/v1beta1"
 	sourcesv1beta2 "knative.dev/eventing/pkg/apis/sources/v1beta2"
 	"knative.dev/eventing/pkg/utils"
 	"knative.dev/eventing/test/lib/duck"
@@ -320,23 +319,6 @@ func (c *Client) CreateFlowsParallelOrFail(parallel *flowsv1.Parallel) {
 	c.Tracker.AddObj(parallel)
 }
 
-// CreateSinkBindingV1Beta1OrFail will create a SinkBinding or fail the test if there is an error.
-func (c *Client) CreateSinkBindingV1Beta1OrFail(sb *sourcesv1beta1.SinkBinding) {
-	c.T.Logf("Creating sinkbinding %+v", sb)
-	sbInterface := c.Eventing.SourcesV1beta1().SinkBindings(c.Namespace)
-	err := c.RetryWebhookErrors(func(attempts int) (err error) {
-		_, e := sbInterface.Create(context.Background(), sb, metav1.CreateOptions{})
-		if e != nil {
-			c.T.Logf("Failed to create sinkbinding %q: %v", sb.Name, e)
-		}
-		return e
-	})
-	if err != nil && !errors.IsAlreadyExists(err) {
-		c.T.Fatalf("Failed to create sinkbinding %q: %v", sb.Name, err)
-	}
-	c.Tracker.AddObj(sb)
-}
-
 // CreateSinkBindingV1OrFail will create a SinkBinding or fail the test if there is an error.
 func (c *Client) CreateSinkBindingV1OrFail(sb *sourcesv1.SinkBinding) {
 	c.T.Logf("Creating sinkbinding %+v", sb)
@@ -354,23 +336,6 @@ func (c *Client) CreateSinkBindingV1OrFail(sb *sourcesv1.SinkBinding) {
 	c.Tracker.AddObj(sb)
 }
 
-// CreateApiServerSourceV1Beta1OrFail will create an v1beta1 ApiServerSource
-func (c *Client) CreateApiServerSourceV1Beta1OrFail(apiServerSource *sourcesv1beta1.ApiServerSource) {
-	c.T.Logf("Creating apiserversource %+v", apiServerSource)
-	apiServerInterface := c.Eventing.SourcesV1beta1().ApiServerSources(c.Namespace)
-	err := c.RetryWebhookErrors(func(attempts int) (err error) {
-		_, e := apiServerInterface.Create(context.Background(), apiServerSource, metav1.CreateOptions{})
-		if e != nil {
-			c.T.Logf("Failed to create apiserversource %q: %v", apiServerSource.Name, e)
-		}
-		return e
-	})
-	if err != nil && !errors.IsAlreadyExists(err) {
-		c.T.Fatalf("Failed to create apiserversource %q: %v", apiServerSource.Name, err)
-	}
-	c.Tracker.AddObj(apiServerSource)
-}
-
 // CreateApiServerSourceV1OrFail will create an v1 ApiServerSource
 func (c *Client) CreateApiServerSourceV1OrFail(apiServerSource *sourcesv1.ApiServerSource) {
 	c.T.Logf("Creating apiserversource %+v", apiServerSource)
@@ -388,23 +353,6 @@ func (c *Client) CreateApiServerSourceV1OrFail(apiServerSource *sourcesv1.ApiSer
 	c.Tracker.AddObj(apiServerSource)
 }
 
-// CreateContainerSourceV1Beta1OrFail will create a v1beta1 ContainerSource.
-func (c *Client) CreateContainerSourceV1Beta1OrFail(containerSource *sourcesv1beta1.ContainerSource) {
-	c.T.Logf("Creating containersource %+v", containerSource)
-	containerInterface := c.Eventing.SourcesV1beta1().ContainerSources(c.Namespace)
-	err := c.RetryWebhookErrors(func(attempts int) (err error) {
-		_, e := containerInterface.Create(context.Background(), containerSource, metav1.CreateOptions{})
-		if e != nil {
-			c.T.Logf("Failed to create containersource %q: %v", containerSource.Name, e)
-		}
-		return e
-	})
-	if err != nil && !errors.IsAlreadyExists(err) {
-		c.T.Fatalf("Failed to create containersource %q: %v", containerSource.Name, err)
-	}
-	c.Tracker.AddObj(containerSource)
-}
-
 // CreateContainerSourceV1OrFail will create a v1 ContainerSource.
 func (c *Client) CreateContainerSourceV1OrFail(containerSource *sourcesv1.ContainerSource) {
 	c.T.Logf("Creating containersource %+v", containerSource)
@@ -422,10 +370,10 @@ func (c *Client) CreateContainerSourceV1OrFail(containerSource *sourcesv1.Contai
 	c.Tracker.AddObj(containerSource)
 }
 
-// CreatePingSourceV1Beta1OrFail will create a PingSource
-func (c *Client) CreatePingSourceV1Beta1OrFail(pingSource *sourcesv1beta1.PingSource) {
+// CreatePingSourceV1Beta2OrFail will create a PingSource
+func (c *Client) CreatePingSourceV1Beta2OrFail(pingSource *sourcesv1beta2.PingSource) {
 	c.T.Logf("Creating pingsource %+v", pingSource)
-	pingInterface := c.Eventing.SourcesV1beta1().PingSources(c.Namespace)
+	pingInterface := c.Eventing.SourcesV1beta2().PingSources(c.Namespace)
 	err := c.RetryWebhookErrors(func(attempts int) (err error) {
 		_, e := pingInterface.Create(context.Background(), pingSource, metav1.CreateOptions{})
 		if e != nil {
@@ -439,10 +387,10 @@ func (c *Client) CreatePingSourceV1Beta1OrFail(pingSource *sourcesv1beta1.PingSo
 	c.Tracker.AddObj(pingSource)
 }
 
-// CreatePingSourceV1Beta2OrFail will create a PingSource
-func (c *Client) CreatePingSourceV1Beta2OrFail(pingSource *sourcesv1beta2.PingSource) {
+// CreatePingSourceV1OrFail will create a PingSource
+func (c *Client) CreatePingSourceV1OrFail(pingSource *sourcesv1.PingSource) {
 	c.T.Logf("Creating pingsource %+v", pingSource)
-	pingInterface := c.Eventing.SourcesV1beta2().PingSources(c.Namespace)
+	pingInterface := c.Eventing.SourcesV1().PingSources(c.Namespace)
 	err := c.RetryWebhookErrors(func(attempts int) (err error) {
 		_, e := pingInterface.Create(context.Background(), pingSource, metav1.CreateOptions{})
 		if e != nil {