Skip to content

Commit

Permalink
Updating broker to be v1 (#3958)
Browse files Browse the repository at this point in the history
Signed-off-by: Matthias Wessendorf <mwessend@redhat.com>
  • Loading branch information
matzew authored Aug 28, 2020
1 parent eaba553 commit 7be9b4e
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions test/e2e/broker_redelivery_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@ import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/utils/pointer"

eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
"knative.dev/eventing/pkg/apis/eventing/v1beta1"
eventingduckv1 "knative.dev/eventing/pkg/apis/duck/v1"
v1 "knative.dev/eventing/pkg/apis/eventing/v1"
"knative.dev/eventing/test/e2e/helpers"
testlib "knative.dev/eventing/test/lib"
"knative.dev/eventing/test/lib/resources"
Expand All @@ -40,14 +40,14 @@ func ChannelBasedBrokerCreator(channel metav1.TypeMeta, brokerClass string) help
// create a ConfigMap used by the broker.
config := client.CreateBrokerConfigMapOrFail("config-"+brokerName, &channel)

backoff := eventingduckv1beta1.BackoffPolicyLinear
backoff := eventingduckv1.BackoffPolicyLinear

// create a new broker.
client.CreateBrokerV1Beta1OrFail(brokerName,
resources.WithBrokerClassForBrokerV1Beta1(brokerClass),
resources.WithConfigForBrokerV1Beta1(config),
func(broker *v1beta1.Broker) {
broker.Spec.Delivery = &eventingduckv1beta1.DeliverySpec{
client.CreateBrokerV1OrFail(brokerName,
resources.WithBrokerClassForBrokerV1(brokerClass),
resources.WithConfigForBrokerV1(config),
func(broker *v1.Broker) {
broker.Spec.Delivery = &eventingduckv1.DeliverySpec{
Retry: &numRetries,
BackoffPolicy: &backoff,
BackoffDelay: pointer.StringPtr("PT1S"),
Expand Down

0 comments on commit 7be9b4e

Please sign in to comment.